public interface MessageDispatchChannel
Modifier and Type | Method and Description |
---|---|
void |
clear() |
void |
close() |
MessageDispatch |
dequeue(long timeout)
Used to get an enqueued message.
|
MessageDispatch |
dequeueNoWait() |
void |
enqueue(MessageDispatch message) |
void |
enqueueFirst(MessageDispatch message) |
Object |
getMutex() |
boolean |
isClosed() |
boolean |
isEmpty() |
boolean |
isRunning() |
MessageDispatch |
peek() |
List<MessageDispatch> |
removeAll() |
int |
size() |
void |
start() |
void |
stop() |
void enqueue(MessageDispatch message)
void enqueueFirst(MessageDispatch message)
boolean isEmpty()
MessageDispatch dequeue(long timeout) throws InterruptedException
JMSException
InterruptedException
MessageDispatch dequeueNoWait()
MessageDispatch peek()
void start()
void stop()
void close()
void clear()
boolean isClosed()
int size()
boolean isRunning()
List<MessageDispatch> removeAll()
Copyright © 2005–2016 FuseSource, Corp.. All rights reserved.