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
javax.jms.JMSException
InterruptedException
MessageDispatch dequeueNoWait()
MessageDispatch peek()
void start()
void stop()
void close()
void clear()
boolean isClosed()
int size()
Object getMutex()
boolean isRunning()
List<MessageDispatch> removeAll()
Copyright © 2005–2017 The Apache Software Foundation. All rights reserved.