Searched refs:QueueMessage (Results 1 – 1 of 1) sorted by relevance
184 protected BlockingQueue<QueueMessage> mMessageQueue;207 mMessageQueue = new LinkedBlockingQueue<QueueMessage>(); in PairingSession()240 mMessageQueue.put(new QueueMessage(message)); in PairingSession()243 mMessageQueue.put(new QueueMessage(exception)); in PairingSession()247 mMessageQueue.put(new QueueMessage(new PoloException(exception))); in PairingSession()465 return mMessageQueue.offer(new QueueMessage(secret)); in setSecret()483 mMessageQueue.offer(new QueueMessage(exception)); in doPairingPhase()491 QueueMessage message = waitForMessage(); in doPairingPhase()633 QueueMessage message = waitForMessage(); in getNextMessage()651 private QueueMessage waitForMessage() throws PoloException { in waitForMessage()[all …]