bitronix.tm.resource.jms
Class MessageConsumerWrapper
java.lang.Object
bitronix.tm.resource.jms.MessageConsumerWrapper
- All Implemented Interfaces:
- javax.jms.MessageConsumer
- Direct Known Subclasses:
- TopicSubscriberWrapper
public class MessageConsumerWrapper
- extends java.lang.Object
- implements javax.jms.MessageConsumer
MessageConsumer
wrapper that adds XA enlistment semantics.
© Bitronix Software
- Author:
- lorban
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
session
protected DualSessionWrapper session
MessageConsumerWrapper
public MessageConsumerWrapper(javax.jms.MessageConsumer messageConsumer,
DualSessionWrapper session,
PoolingConnectionFactory poolingConnectionFactory)
getMessageConsumer
public javax.jms.MessageConsumer getMessageConsumer()
enlistResource
protected void enlistResource()
throws javax.jms.JMSException
- Enlist this connection into the current transaction if automaticEnlistingEnabled = true for this resource.
If no transaction is running then this method does nothing.
- Throws:
javax.jms.JMSException
toString
public java.lang.String toString()
- Overrides:
toString
in class java.lang.Object
receive
public javax.jms.Message receive()
throws javax.jms.JMSException
- Specified by:
receive
in interface javax.jms.MessageConsumer
- Throws:
javax.jms.JMSException
receive
public javax.jms.Message receive(long timeout)
throws javax.jms.JMSException
- Specified by:
receive
in interface javax.jms.MessageConsumer
- Throws:
javax.jms.JMSException
receiveNoWait
public javax.jms.Message receiveNoWait()
throws javax.jms.JMSException
- Specified by:
receiveNoWait
in interface javax.jms.MessageConsumer
- Throws:
javax.jms.JMSException
close
public void close()
throws javax.jms.JMSException
- Specified by:
close
in interface javax.jms.MessageConsumer
- Throws:
javax.jms.JMSException
getMessageSelector
public java.lang.String getMessageSelector()
throws javax.jms.JMSException
- Specified by:
getMessageSelector
in interface javax.jms.MessageConsumer
- Throws:
javax.jms.JMSException
getMessageListener
public javax.jms.MessageListener getMessageListener()
throws javax.jms.JMSException
- Specified by:
getMessageListener
in interface javax.jms.MessageConsumer
- Throws:
javax.jms.JMSException
setMessageListener
public void setMessageListener(javax.jms.MessageListener listener)
throws javax.jms.JMSException
- Specified by:
setMessageListener
in interface javax.jms.MessageConsumer
- Throws:
javax.jms.JMSException