~cpp 
import java.util.*;

public class MessageQueueBounded extends MessageQueue
{
	public MessageQueueBounded() {
		items = new Object[SIZE];
		position = 0;
		isRoom = true;
}

/*
 * This implements a blocking send
 */

public void send(Object o) {
	// wait until there is room
	while (_________________) {
		System.out.println ("Producer Blocked");
		try {
			Thread.sleep(500);
		}
		catch (InterruptedException e) {  }
	}
	System.out.println("Producer UnBlocked");
	_______________ = 0;
	
	if (____________________) {
		isRoom = false;
		System.out.println("Full");
	}
}

/*
 * This implements a blocking receive
 */

public Object receive() {
	// wait until something is there
	while (_________________) {
		System.out.println("Consumer Blocked");
		try {
			Thread.sleep(500);
		}
		catch (InterruptedException e) { }
	}
	System.out.println("Consumer UnBlocked");

	Object it = _________________;
	isRoom = true;
	return it;
}
private Object[] items;
private static final int SIZE = 3;
private volatile int position;
private volatile boolean isRoom;