{ return cons.receive(1000);
{ m = cons.receive(RECEIVE_TIMEOUT);
   protected Message getMessage() throws Exception   {      if (isListener)      {         long start = System.currentTimeMillis();         Message m = null;         while (System.currentTimeMillis() - start < 1000)         {            if (theMessage != null)            {               m = theMessage;               theMessage = null;               break;            }            Thread.yield();         }         return m;               }      else      {         return cons.receive(1000);      }   }