public class ActiveMQRAMessageProducer extends Object implements javax.jms.MessageProducer
Modifier and Type | Field and Description |
---|---|
protected javax.jms.MessageProducer |
producer
The wrapped message producer
|
protected ActiveMQRASession |
session
The session for this consumer
|
Constructor and Description |
---|
ActiveMQRAMessageProducer(javax.jms.MessageProducer producer,
ActiveMQRASession session)
Create a new wrapper
|
Modifier and Type | Method and Description |
---|---|
void |
close()
Close
|
long |
getDeliveryDelay() |
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,
javax.jms.CompletionListener completionListener) |
void |
send(javax.jms.Destination destination,
javax.jms.Message message,
int deliveryMode,
int priority,
long timeToLive)
Send message
|
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)
Send message
|
void |
send(javax.jms.Message message,
javax.jms.CompletionListener completionListener) |
void |
send(javax.jms.Message message,
int deliveryMode,
int priority,
long timeToLive)
Send 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)
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 ActiveMQRASession session
public ActiveMQRAMessageProducer(javax.jms.MessageProducer producer, ActiveMQRASession session)
producer
- the producersession
- the sessionpublic void close() throws javax.jms.JMSException
close
in interface AutoCloseable
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 occurspublic void setDeliveryDelay(long deliveryDelay) throws javax.jms.JMSException
setDeliveryDelay
in interface javax.jms.MessageProducer
javax.jms.JMSException
public long getDeliveryDelay() throws javax.jms.JMSException
getDeliveryDelay
in interface javax.jms.MessageProducer
javax.jms.JMSException
public void send(javax.jms.Message message, javax.jms.CompletionListener completionListener) throws javax.jms.JMSException
send
in interface javax.jms.MessageProducer
javax.jms.JMSException
public void send(javax.jms.Message message, int deliveryMode, int priority, long timeToLive, javax.jms.CompletionListener completionListener) throws javax.jms.JMSException
send
in interface javax.jms.MessageProducer
javax.jms.JMSException
public void send(javax.jms.Destination destination, javax.jms.Message message, javax.jms.CompletionListener completionListener) throws javax.jms.JMSException
send
in interface javax.jms.MessageProducer
javax.jms.JMSException
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
send
in interface javax.jms.MessageProducer
javax.jms.JMSException
Copyright © 2016 The Apache Software Foundation. All rights reserved.