jrun.jms.wrapper.enterprise
Class JRunMessageConsumerWrapper

java.lang.Object
  |
  +--jrun.jms.wrapper.enterprise.AbstractMessageProcessorWrapper
        |
        +--jrun.jms.wrapper.enterprise.JRunMessageConsumerWrapper

All Implemented Interfaces:

MessageConsumerWrapper

public class JRunMessageConsumerWrapper

extends AbstractMessageProcessorWrapper

implements MessageConsumerWrapper

Method Summary

javax.jms.MessageListener	getMessageListener()
java.lang.String	getMessageSelector()
boolean	getNoLocal()
javax.jms.Queue	getQueue()
javax.jms.Topic	getTopic()
javax.jms.Message	receive()
javax.jms.Message	receive(long timeout)
javax.jms.Message	receiveNoWait()
void	setMessageListener(javax.jms.MessageListener listener)

Methods inherited from class jrun.jms.wrapper.enterprise.AbstractMessageProcessorWrapper

close, getDelegate, getSessionWrapper, isClosed, setDelegate, setSessionWrapper

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

getMessageSelector

public java.lang.String getMessageSelector()
                                    throws javax.jms.JMSException

getMessageListener

public javax.jms.MessageListener getMessageListener()
                                             throws javax.jms.JMSException

setMessageListener

public void setMessageListener(javax.jms.MessageListener listener)
                        throws javax.jms.JMSException

receive

public javax.jms.Message receive()
                          throws javax.jms.JMSException

receive

public javax.jms.Message receive(long timeout)
                          throws javax.jms.JMSException

receiveNoWait

public javax.jms.Message receiveNoWait()
                                throws javax.jms.JMSException

getQueue

public javax.jms.Queue getQueue()
                         throws javax.jms.JMSException

getNoLocal

public boolean getNoLocal()
                   throws javax.jms.JMSException

getTopic

public javax.jms.Topic getTopic()
                         throws javax.jms.JMSException