| |
|
| java.lang.Object org.mockejb.jms.MockConsumer
All known Subclasses: org.mockejb.jms.TopicSubscriberImpl, org.mockejb.jms.QueueReceiverImpl,
MockConsumer | public class MockConsumer implements MessageConsumer(Code) | | author: Dimitar Gospodinov |
close | public void close() throws JMSException(Code) | | See Also: javax.jms.MessageConsumer.close |
consume | void consume() throws JMSException(Code) | | Asynchronously consume all received messages.
|
consume | void consume(Message msg) throws JMSException(Code) | | Consume message sent from destination.
If MessageListener is available and the connection is started, message is consumed immediatelly.
In all other cases message is stored and will be consumed later.
Parameters: msg - throws: JMSException - |
consume | void consume(Collection messages) throws JMSException(Code) | | Consumes all specified messages. messages is collection of
Message .
Each message is copied and consume(Message) is called with the copy.
Parameters: messages - |
getMessageListener | public MessageListener getMessageListener() throws JMSException(Code) | | See Also: javax.jms.MessageConsumer.getMessageListener |
getMessageSelector | public String getMessageSelector() throws JMSException(Code) | | See Also: javax.jms.MessageConsumer.getMessageSelector |
isClosed | boolean isClosed()(Code) | | |
receive | public Message receive() throws JMSException(Code) | | See Also: javax.jms.MessageConsumer.receive |
receive | public Message receive(long timeout) throws JMSException(Code) | | See Also: javax.jms.MessageConsumer.receive(long) |
receiveNoWait | public Message receiveNoWait() throws JMSException(Code) | | See Also: javax.jms.MessageConsumer.receiveNoWait |
setMessageListener | public void setMessageListener(MessageListener listener) throws JMSException(Code) | | See Also: javax.jms.MessageConsumer.setMessageListener(javax.jms.MessageListener) |
|
|
|