java.lang.Object
com.presumo.jms.client.JmsMessageProducer
- All Implemented Interfaces:
- javax.jms.MessageProducer
- Direct Known Subclasses:
- JmsQueueSender, JmsTopicPublisher
- public abstract class JmsMessageProducer
- extends java.lang.Object
- implements javax.jms.MessageProducer
Implementation of the interface javax.jms.MessageProducer.
TopicPublishers and QueueSenders have pratically
identical functionality in this implementation (actually the differences
are just differred to the routing logic elsewhere). Consequently, almost
all logic is in this base class.
| Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
disableMessageTimestamp
protected boolean disableMessageTimestamp
deliveryMode
protected int deliveryMode
priority
protected int priority
timeToLive
protected long timeToLive
mySession
protected final JmsSession mySession
JmsMessageProducer
JmsMessageProducer(JmsSession session)
setDisableMessageID
public final void setDisableMessageID(boolean value)
throws javax.jms.JMSException
- This option is ignored because the internal routing mechanism is
dependent on Message IDs.
- Specified by:
setDisableMessageID in interface javax.jms.MessageProducer
getDisableMessageID
public final boolean getDisableMessageID()
throws javax.jms.JMSException
- Always returns false because message IDs may never be disabled due to
the internal routing mechanism's dependance on this feature.
- Specified by:
getDisableMessageID in interface javax.jms.MessageProducer
setDisableMessageTimestamp
public final void setDisableMessageTimestamp(boolean value)
throws javax.jms.JMSException
- Specified by:
setDisableMessageTimestamp in interface javax.jms.MessageProducer
getDisableMessageTimestamp
public final boolean getDisableMessageTimestamp()
throws javax.jms.JMSException
- Specified by:
getDisableMessageTimestamp in interface javax.jms.MessageProducer
setDeliveryMode
public final void setDeliveryMode(int deliveryMode)
throws javax.jms.JMSException
- Specified by:
setDeliveryMode in interface javax.jms.MessageProducer
getDeliveryMode
public final int getDeliveryMode()
throws javax.jms.JMSException
- Specified by:
getDeliveryMode in interface javax.jms.MessageProducer
setPriority
public final void setPriority(int priority)
throws javax.jms.JMSException
- Specified by:
setPriority in interface javax.jms.MessageProducer
getPriority
public final int getPriority()
throws javax.jms.JMSException
- Specified by:
getPriority in interface javax.jms.MessageProducer
setTimeToLive
public final void setTimeToLive(long timeToLive)
throws javax.jms.JMSException
- Specified by:
setTimeToLive in interface javax.jms.MessageProducer
getTimeToLive
public final long getTimeToLive()
throws javax.jms.JMSException
- Specified by:
getTimeToLive in interface javax.jms.MessageProducer
close
public void close()
throws javax.jms.JMSException
- Specified by:
close in interface javax.jms.MessageProducer
prepareAndSend
protected final void prepareAndSend(javax.jms.Destination destination,
javax.jms.Message message,
int _deliveryMode,
int _priority,
long _timeToLive)
throws javax.jms.JMSException
- Sets all the necessary properties on the message before passing it off
to this instance's session for routing.