public class QpidRAMessageProducer extends Object implements javax.jms.MessageProducer
Modifier and Type | Field and Description |
---|---|
protected javax.jms.MessageProducer |
_producer
The wrapped message producer
|
protected QpidRASessionImpl |
_session
The session for this consumer
|
Constructor and Description |
---|
QpidRAMessageProducer(javax.jms.MessageProducer producer,
QpidRASessionImpl session)
Create a new wrapper
|
Modifier and Type | Method and Description |
---|---|
void |
close()
Close
|
int |
getDeliveryMode()
Get the delivery mode
|
javax.jms.Destination |
getDestination()
Get the destination
|
boolean |
getDisableMessageID()
Disable message id
|
boolean |
getDisableMessageTimestamp()
Disable message timestamp
|
int |
getPriority()
Get the priority
|
long |
getTimeToLive()
Get the time to live
|
void |
send(javax.jms.Destination destination,
javax.jms.Message message)
Send message
|
void |
send(javax.jms.Destination destination,
javax.jms.Message message,
int deliveryMode,
int priority,
long timeToLive)
Send message
|
void |
send(javax.jms.Message message)
Send message
|
void |
send(javax.jms.Message message,
int deliveryMode,
int priority,
long timeToLive)
Send message
|
void |
setDeliveryMode(int deliveryMode)
Set the delivery mode
|
void |
setDisableMessageID(boolean value)
Set disable message id
|
void |
setDisableMessageTimestamp(boolean value)
Set disable message timestamp
|
void |
setPriority(int defaultPriority)
Set the priority
|
void |
setTimeToLive(long timeToLive)
Set the ttl
|
protected javax.jms.MessageProducer _producer
protected QpidRASessionImpl _session
public QpidRAMessageProducer(javax.jms.MessageProducer producer, QpidRASessionImpl session)
producer
- the producersession
- the sessionpublic void close() throws javax.jms.JMSException
close
in interface javax.jms.MessageProducer
javax.jms.JMSException
- Thrown if an error occurspublic void send(javax.jms.Destination destination, javax.jms.Message message, int deliveryMode, int priority, long timeToLive) throws javax.jms.JMSException
send
in interface javax.jms.MessageProducer
destination
- The destinationmessage
- The messagedeliveryMode
- The delivery modepriority
- The prioritytimeToLive
- The time to livejavax.jms.JMSException
- Thrown if an error occurspublic void send(javax.jms.Destination destination, javax.jms.Message message) throws javax.jms.JMSException
send
in interface javax.jms.MessageProducer
destination
- The destinationmessage
- The messagejavax.jms.JMSException
- Thrown if an error occurspublic void send(javax.jms.Message message, int deliveryMode, int priority, long timeToLive) throws javax.jms.JMSException
send
in interface javax.jms.MessageProducer
message
- The messagedeliveryMode
- The delivery modepriority
- The prioritytimeToLive
- The time to livejavax.jms.JMSException
- Thrown if an error occurspublic void send(javax.jms.Message message) throws javax.jms.JMSException
send
in interface javax.jms.MessageProducer
message
- The messagejavax.jms.JMSException
- Thrown if an error occurspublic int getDeliveryMode() throws javax.jms.JMSException
getDeliveryMode
in interface javax.jms.MessageProducer
javax.jms.JMSException
- Thrown if an error occurspublic javax.jms.Destination getDestination() throws javax.jms.JMSException
getDestination
in interface javax.jms.MessageProducer
javax.jms.JMSException
- Thrown if an error occurspublic boolean getDisableMessageID() throws javax.jms.JMSException
getDisableMessageID
in interface javax.jms.MessageProducer
javax.jms.JMSException
- Thrown if an error occurspublic boolean getDisableMessageTimestamp() throws javax.jms.JMSException
getDisableMessageTimestamp
in interface javax.jms.MessageProducer
javax.jms.JMSException
- Thrown if an error occurspublic int getPriority() throws javax.jms.JMSException
getPriority
in interface javax.jms.MessageProducer
javax.jms.JMSException
- Thrown if an error occurspublic long getTimeToLive() throws javax.jms.JMSException
getTimeToLive
in interface javax.jms.MessageProducer
javax.jms.JMSException
- Thrown if an error occurspublic void setDeliveryMode(int deliveryMode) throws javax.jms.JMSException
setDeliveryMode
in interface javax.jms.MessageProducer
deliveryMode
- The modejavax.jms.JMSException
- Thrown if an error occurspublic void setDisableMessageID(boolean value) throws javax.jms.JMSException
setDisableMessageID
in interface javax.jms.MessageProducer
value
- The valuejavax.jms.JMSException
- Thrown if an error occurspublic void setDisableMessageTimestamp(boolean value) throws javax.jms.JMSException
setDisableMessageTimestamp
in interface javax.jms.MessageProducer
value
- The valuejavax.jms.JMSException
- Thrown if an error occurspublic void setPriority(int defaultPriority) throws javax.jms.JMSException
setPriority
in interface javax.jms.MessageProducer
defaultPriority
- The valuejavax.jms.JMSException
- Thrown if an error occurspublic void setTimeToLive(long timeToLive) throws javax.jms.JMSException
setTimeToLive
in interface javax.jms.MessageProducer
timeToLive
- The valuejavax.jms.JMSException
- Thrown if an error occursCopyright © 2006–2016 The Apache Software Foundation. All rights reserved.