bitronix.tm.resource.jms
Class MessageProducerWrapper
java.lang.Object
bitronix.tm.resource.jms.MessageProducerWrapper
- All Implemented Interfaces:
- javax.jms.MessageProducer
public class MessageProducerWrapper
- extends java.lang.Object
- implements javax.jms.MessageProducer
MessageProducer
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
MessageProducerWrapper
public MessageProducerWrapper(javax.jms.MessageProducer messageProducer,
DualSessionWrapper session,
PoolingConnectionFactory poolingConnectionFactory)
getMessageProducer
public javax.jms.MessageProducer getMessageProducer()
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
send
public void send(javax.jms.Message message)
throws javax.jms.JMSException
- Specified by:
send
in interface javax.jms.MessageProducer
- Throws:
javax.jms.JMSException
send
public void send(javax.jms.Message message,
int deliveryMode,
int priority,
long timeToLive)
throws javax.jms.JMSException
- Specified by:
send
in interface javax.jms.MessageProducer
- Throws:
javax.jms.JMSException
send
public void send(javax.jms.Destination destination,
javax.jms.Message message)
throws javax.jms.JMSException
- Specified by:
send
in interface javax.jms.MessageProducer
- Throws:
javax.jms.JMSException
send
public void send(javax.jms.Destination destination,
javax.jms.Message message,
int deliveryMode,
int priority,
long timeToLive)
throws javax.jms.JMSException
- Specified by:
send
in interface javax.jms.MessageProducer
- Throws:
javax.jms.JMSException
close
public void close()
throws javax.jms.JMSException
- Specified by:
close
in interface javax.jms.MessageProducer
- Throws:
javax.jms.JMSException
setDisableMessageID
public void setDisableMessageID(boolean value)
throws javax.jms.JMSException
- Specified by:
setDisableMessageID
in interface javax.jms.MessageProducer
- Throws:
javax.jms.JMSException
getDisableMessageID
public boolean getDisableMessageID()
throws javax.jms.JMSException
- Specified by:
getDisableMessageID
in interface javax.jms.MessageProducer
- Throws:
javax.jms.JMSException
setDisableMessageTimestamp
public void setDisableMessageTimestamp(boolean value)
throws javax.jms.JMSException
- Specified by:
setDisableMessageTimestamp
in interface javax.jms.MessageProducer
- Throws:
javax.jms.JMSException
getDisableMessageTimestamp
public boolean getDisableMessageTimestamp()
throws javax.jms.JMSException
- Specified by:
getDisableMessageTimestamp
in interface javax.jms.MessageProducer
- Throws:
javax.jms.JMSException
setDeliveryMode
public void setDeliveryMode(int deliveryMode)
throws javax.jms.JMSException
- Specified by:
setDeliveryMode
in interface javax.jms.MessageProducer
- Throws:
javax.jms.JMSException
getDeliveryMode
public int getDeliveryMode()
throws javax.jms.JMSException
- Specified by:
getDeliveryMode
in interface javax.jms.MessageProducer
- Throws:
javax.jms.JMSException
setPriority
public void setPriority(int defaultPriority)
throws javax.jms.JMSException
- Specified by:
setPriority
in interface javax.jms.MessageProducer
- Throws:
javax.jms.JMSException
getPriority
public int getPriority()
throws javax.jms.JMSException
- Specified by:
getPriority
in interface javax.jms.MessageProducer
- Throws:
javax.jms.JMSException
setTimeToLive
public void setTimeToLive(long timeToLive)
throws javax.jms.JMSException
- Specified by:
setTimeToLive
in interface javax.jms.MessageProducer
- Throws:
javax.jms.JMSException
getTimeToLive
public long getTimeToLive()
throws javax.jms.JMSException
- Specified by:
getTimeToLive
in interface javax.jms.MessageProducer
- Throws:
javax.jms.JMSException
getDestination
public javax.jms.Destination getDestination()
throws javax.jms.JMSException
- Specified by:
getDestination
in interface javax.jms.MessageProducer
- Throws:
javax.jms.JMSException