| java.lang.Object com.caucho.jms.connection.MessageConsumerImpl
All known Subclasses: com.caucho.jms.connection.TopicSubscriberImpl, com.caucho.jms.connection.QueueReceiverImpl,
MessageConsumerImpl | public class MessageConsumerImpl implements MessageConsumer(Code) | | A basic message consumer.
|
close | public void close() throws JMSException(Code) | | Closes the consumer.
|
getMessageListener | public MessageListener getMessageListener() throws JMSException(Code) | | Returns the message listener
|
getMessageSelector | public String getMessageSelector() throws JMSException(Code) | | Returns the message consumer's selector.
|
getNoLocal | public boolean getNoLocal() throws JMSException(Code) | | Returns true if local messages are not sent.
|
getSelector | public Selector getSelector()(Code) | | Returns the parsed selector.
|
handleMessage | boolean handleMessage(MessageListener listener)(Code) | | Called with the session's thread to handle any messages
|
isActive | public boolean isActive() throws JMSException(Code) | | Returns true if active
|
isClosed | public boolean isClosed()(Code) | | Returns true if closed
|
notifyMessageAvailable | public boolean notifyMessageAvailable()(Code) | | Notifies that a message is available.
|
receive | public Message receive() throws JMSException(Code) | | Receives the next message, blocking until a message is available.
|
receive | public Message receive(long timeout) throws JMSException(Code) | | Receives a message from the queue.
|
receiveNoWait | public Message receiveNoWait() throws JMSException(Code) | | Receives a message from the queue.
|
setMessageListener | public void setMessageListener(MessageListener listener) throws JMSException(Code) | | Sets the message listener
|
setMessageListener | public void setMessageListener(MessageListener listener, long pollInterval) throws JMSException(Code) | | Sets the message listener with a poll interval
|
stop | public void stop() throws JMSException(Code) | | Stops the consumer.
|
|
|