Following is the code of the class Queue, but I think this error is not
caused by this Queue.

////////////////////////////////////////////////////////////////////////////////////////
import java.lang.InterruptedException;

abstract class QueueItem
{
   protected QueueItem Next;
   public QueueItem() {
       Next = null;
   }
}
class ByteQueueItem extends QueueItem
{
   byte[] bArray;
   int len;
   public ByteQueueItem(byte[] buff) {
       len = buff.length;
       bArray = new byte[len];
       for (int i = 0; i < len; i++) {
           bArray[i] = buff[i];
       }
   }

   public byte[] getBArray() {
       return bArray;
   }

   public int getLen() {
       return len;
   }
}

public class Queue {
   public Queue() {
       QueueHead = null;
   }

   private QueueItem QueueHead;
   static int count = 0;

   protected synchronized QueueItem GetMessage() {
       while (count == 0) {
           try {
               this.wait();
           } catch (InterruptedException e) {
               System.out.println("ERROR In GetMessage--" +
e.toString());
           }
       }
       this.notify();
       if (QueueHead != null) {
           QueueItem msgItem = QueueHead;
           QueueHead = QueueHead.Next;
           msgItem.Next = null;
           count--;
           return msgItem;
       }
       return null;
   }

   synchronized void AppendMessage(QueueItem msgItem) {
       while (count >= 100000) {
           try {
               this.wait();
           } catch (InterruptedException e) {
               System.out.println("ERROR in AppendMessage" +
e.toString());
           }
       }
       this.notify();
       if (QueueHead == null) {
           QueueHead = msgItem;
           count = 1;
       } else {
           QueueItem Last;
           Last = QueueHead;
           while (Last.Next != null)
               Last = Last.Next;
           Last.Next = msgItem;
           count++;
       }
       msgItem.Next = null;
   }
}
//////////////////////////////////////////////////////////////////////

I use this Queue in a thread, which like this, following is the
implementation of the run method of the thread

public void run() {
   Timer timer = new Timer();
       timer.schedule(new TimerTask() {
           public void run() {
               if (getReadyFlag()) {
                    StreamQueue.AppendMessage(new
ByteQueueItem(getStreamBytes()));

           setReadyFlag();
               }
           }
       }, 1000, 1);
       //throw new java.lang.UnsupportedOperationException(
       //        "Method run() not yet implemented.");
   }