public class MQMessageProducer extends MQRoot implements javax.jms.MessageProducer, JmsMessageProducer
Modifier and Type | Method and Description |
---|---|
void |
close()
Closes the message producer.
|
long |
getDeliveryDelay() |
int |
getDeliveryMode()
Gets the producer's default delivery mode.
|
javax.jms.Destination |
getDestination()
Gets the destination associated with the message producer.
|
boolean |
getDisableMessageID()
Indicates whether message IDs are disabled.
|
boolean |
getDisableMessageTimestamp()
Indicates whether message timestamps are disabled.
|
int |
getPriority()
Gets the producer's default priority.
|
long |
getTimeToLive()
Gets the default length of time that a produced message will be retained by the message system.
|
void |
send(javax.jms.Destination destination,
javax.jms.Message message,
javax.jms.CompletionListener completionListener) |
void |
send(javax.jms.Destination destination,
javax.jms.Message message,
int deliveryMode,
int priority,
long timeToLive,
javax.jms.CompletionListener completionListener) |
void |
send(javax.jms.Message message)
Sends a message.
|
void |
send(javax.jms.Message message,
javax.jms.CompletionListener completionListener) |
void |
send(javax.jms.Message message,
int deliveryMode,
int priority,
long timeToLive)
Sends a message specifying a delivery mode, a priority, and the lifetime of the message.
|
void |
send(javax.jms.Message message,
int deliveryMode,
int priority,
long timeToLive,
javax.jms.CompletionListener completionListener) |
void |
setDeliveryDelay(long deliveryDelay) |
void |
setDeliveryMode(int deliveryMode)
Sets the producer's default delivery mode.
|
void |
setDisableMessageID(boolean value)
Sets whether message IDs are disabled.
|
void |
setDisableMessageTimestamp(boolean value)
Sets whether message timestamps are disabled.
|
void |
setPriority(int priority)
Sets the producer's default priority.
|
void |
setTimeToLive(long timeToLive)
Sets the default length of time that the message system retains a produced message.
|
clear, containsKey, containsValue, entrySet, equals, get, getBooleanProperty, getByteProperty, getBytesProperty, getCharProperty, getDoubleProperty, getFloatProperty, getIntProperty, getLongProperty, getObjectProperty, getPropertyNames, getShortProperty, getStringProperty, hashCode, isEmpty, keySet, propertyExists, put, putAll, remove, setBatchProperties, setBooleanProperty, setByteProperty, setBytesProperty, setCharProperty, setDoubleProperty, setFloatProperty, setIntProperty, setLongProperty, setObjectProperty, setShortProperty, setStringProperty, size, values
getClass, notify, notifyAll, toString, wait, wait, wait
setBatchProperties, setBooleanProperty, setByteProperty, setBytesProperty, setCharProperty, setDoubleProperty, setFloatProperty, setIntProperty, setLongProperty, setObjectProperty, setShortProperty, setStringProperty
getBooleanProperty, getByteProperty, getBytesProperty, getCharProperty, getDoubleProperty, getFloatProperty, getIntProperty, getLongProperty, getObjectProperty, getPropertyNames, getShortProperty, getStringProperty, propertyExists
public void close() throws javax.jms.JMSException
close
in interface java.lang.AutoCloseable
close
in interface javax.jms.MessageProducer
javax.jms.JMSException
- if the operation does not succeedpublic int getDeliveryMode() throws javax.jms.JMSException
getDeliveryMode
in interface javax.jms.MessageProducer
javax.jms.JMSException
- if the operation fails.setDeliveryMode(int)
public javax.jms.Destination getDestination() throws javax.jms.JMSException
getDestination
in interface javax.jms.MessageProducer
javax.jms.JMSException
- if the operation failspublic boolean getDisableMessageID() throws javax.jms.JMSException
getDisableMessageID
in interface javax.jms.MessageProducer
javax.jms.JMSException
- if the operation failspublic boolean getDisableMessageTimestamp() throws javax.jms.JMSException
getDisableMessageTimestamp
in interface javax.jms.MessageProducer
javax.jms.JMSException
- if the operation failspublic int getPriority() throws javax.jms.JMSException
getPriority
in interface javax.jms.MessageProducer
javax.jms.JMSException
- if the operation failssetPriority(int)
public long getTimeToLive() throws javax.jms.JMSException
getTimeToLive
in interface javax.jms.MessageProducer
javax.jms.JMSException
- if the operation failssetTimeToLive(long)
public void send(javax.jms.Message message) throws javax.jms.JMSException
send
in interface javax.jms.MessageProducer
message
- the message to be sent.javax.jms.JMSException
- if the operation failspublic void send(javax.jms.Message message, int deliveryMode, int priority, long timeToLive) throws javax.jms.JMSException
send
in interface javax.jms.MessageProducer
message
- the message to send.deliveryMode
- the delivery mode to use.priority
- the priority for the messagetimeToLive
- the lifetime of the message in milliseconds.javax.jms.JMSException
- if the operation failspublic void setDeliveryMode(int deliveryMode) throws javax.jms.JMSException
setDeliveryMode
in interface javax.jms.MessageProducer
deliveryMode
- the message delivery mode for this message producer. Possible values are:
DeliveryMode.NON_PERSISTENT
DeliveryMode.PERSISTENT
, the default
javax.jms.JMSException
- if the operation failsgetDeliveryMode()
,
Message.DEFAULT_DELIVERY_MODE
public void setDisableMessageID(boolean value) throws javax.jms.JMSException
Note: This method is ignored in the IBM MQ Java Message Service extensions implementation.
setDisableMessageID
in interface javax.jms.MessageProducer
value
- true if message IDs are disabled. Message IDs are enabled by default.javax.jms.JMSException
- if the operation failspublic void setDisableMessageTimestamp(boolean value) throws javax.jms.JMSException
setDisableMessageTimestamp
in interface javax.jms.MessageProducer
value
- true indicates that timestamps are disabled.javax.jms.JMSException
- if the operation failspublic void setPriority(int priority) throws javax.jms.JMSException
setPriority
in interface javax.jms.MessageProducer
priority
- the message priority for this message producer. Possible values are:
WMQConstants.WMQ_PRI_QDEF
javax.jms.JMSException
- if the operation failsgetPriority()
,
Message.DEFAULT_PRIORITY
public void setTimeToLive(long timeToLive) throws javax.jms.JMSException
Note that this method throws a JMSException if set to other than 0 when you make a real-time connection to a broker.
setTimeToLive
in interface javax.jms.MessageProducer
timeToLive
- the length of time from its dispatch that a message is retained by default
(milliseconds). The default is zero which means unlimited time.javax.jms.JMSException
- if the operation failsgetTimeToLive()
,
Message.DEFAULT_TIME_TO_LIVE
public long getDeliveryDelay() throws javax.jms.JMSException
getDeliveryDelay
in interface javax.jms.MessageProducer
javax.jms.JMSException
MessageProducer.getDeliveryDelay()
public void send(javax.jms.Message message, javax.jms.CompletionListener completionListener) throws javax.jms.JMSException, javax.jms.MessageFormatException, javax.jms.InvalidDestinationException, java.lang.IllegalArgumentException, java.lang.UnsupportedOperationException
send
in interface javax.jms.MessageProducer
javax.jms.JMSException
javax.jms.MessageFormatException
javax.jms.InvalidDestinationException
java.lang.IllegalArgumentException
java.lang.UnsupportedOperationException
public void send(javax.jms.Destination destination, javax.jms.Message message, javax.jms.CompletionListener completionListener) throws javax.jms.JMSException, javax.jms.MessageFormatException, javax.jms.InvalidDestinationException, java.lang.IllegalArgumentException, java.lang.UnsupportedOperationException
send
in interface javax.jms.MessageProducer
javax.jms.JMSException
javax.jms.MessageFormatException
javax.jms.InvalidDestinationException
java.lang.IllegalArgumentException
java.lang.UnsupportedOperationException
public void send(javax.jms.Message message, int deliveryMode, int priority, long timeToLive, javax.jms.CompletionListener completionListener) throws javax.jms.JMSException, javax.jms.MessageFormatException, javax.jms.InvalidDestinationException, java.lang.IllegalArgumentException, java.lang.UnsupportedOperationException
send
in interface javax.jms.MessageProducer
javax.jms.JMSException
javax.jms.MessageFormatException
javax.jms.InvalidDestinationException
java.lang.IllegalArgumentException
java.lang.UnsupportedOperationException
public void send(javax.jms.Destination destination, javax.jms.Message message, int deliveryMode, int priority, long timeToLive, javax.jms.CompletionListener completionListener) throws javax.jms.JMSException, javax.jms.MessageFormatException, javax.jms.InvalidDestinationException, java.lang.IllegalArgumentException, java.lang.UnsupportedOperationException
send
in interface javax.jms.MessageProducer
javax.jms.JMSException
javax.jms.MessageFormatException
javax.jms.InvalidDestinationException
java.lang.IllegalArgumentException
java.lang.UnsupportedOperationException
public void setDeliveryDelay(long deliveryDelay) throws javax.jms.JMSException
setDeliveryDelay
in interface javax.jms.MessageProducer
javax.jms.JMSException
MessageProducer.setDeliveryDelay(long)