Blocking Queue support

[GoogleCodeExporter]

implement java.util.concurrent.BlockingQueue:

QueueManager queueManager = QueueManagers.create(dispatcher)
Queue queue = queueManager.get("my/topic/name")
while(true) queue.take()

Original issue reported on code.google.com by mathieu....@gmail.com on 26 Feb 2010 at 3:10

[GoogleCodeExporter]

Dispatcher dispatcher = Dispatchers.asynchronousUnsafe(ErrorHandlers.rethrow());
EventQueueManager queueManager = EventQueueManagers.create(dispatcher);

BlockingQueue<String> queue1 =
queueManager.createUnboundedQueue(Topics.matching("a/b"), String.class);
BlockingQueue<String> queue2 =
queueManager.createSynchronousQueue(Topics.matching("a/b"), String.class);
BlockingQueue<String> queue3 =
queueManager.createBoundedQueue(Topics.matching("a/b"), String.class, 2);
BlockingQueue<String> queue4 =
queueManager.createBoundedQueue(Topics.matching("a/b"), String.class, 2);

Original comment by mathieu....@gmail.com on 11 Apr 2010 at 12:47

• Changed state: Fixed
• Added labels: Milestone-Release3.2
• Removed labels: Milestone-Release3.1

[GoogleCodeExporter]

Original comment by mathieu....@gmail.com on 14 May 2010 at 1:47

• Changed state: Deployed