public class OutboundProducer extends Object implements javax.jms.MessageProducer
OutboundProducer
instance wraps a JMS producer
for a component involved in outbound messaging.Modifier and Type | Field and Description |
---|---|
static org.objectweb.util.monolog.api.Logger |
logger |
protected javax.jms.MessageProducer |
producer
The wrapped JMS producer.
|
protected OutboundSession |
session
The
OutboundSession this producer belongs to. |
(package private) boolean |
valid
false if producer is no more valid. |
Constructor and Description |
---|
OutboundProducer(javax.jms.MessageProducer producer,
OutboundSession session)
Constructs an
OutboundProducer instance. |
Modifier and Type | Method and Description |
---|---|
protected void |
checkValidity()
Checks the validity of the subscriber instance.
|
void |
close()
Delegates the call to the wrapped producer.
|
long |
getDeliveryDelay()
Delegates the call to the wrapped producer.
|
int |
getDeliveryMode()
Delegates the call to the wrapped producer.
|
javax.jms.Destination |
getDestination()
Delegates the call to the wrapped producer.
|
boolean |
getDisableMessageID()
Delegates the call to the wrapped producer.
|
boolean |
getDisableMessageTimestamp()
Delegates the call to the wrapped producer.
|
int |
getPriority()
Delegates the call to the wrapped producer.
|
long |
getTimeToLive()
Delegates the call to the wrapped producer.
|
void |
send(javax.jms.Destination dest,
javax.jms.Message message)
Delegates the call to the wrapped producer.
|
void |
send(javax.jms.Destination destination,
javax.jms.Message message,
javax.jms.CompletionListener completionListener)
Delegates the call to the wrapped producer.
|
void |
send(javax.jms.Destination dest,
javax.jms.Message message,
int deliveryMode,
int priority,
long timeToLive)
Delegates the call to the wrapped producer.
|
void |
send(javax.jms.Destination destination,
javax.jms.Message message,
int deliveryMode,
int priority,
long timeToLive,
javax.jms.CompletionListener completionListener)
Delegates the call to the wrapped producer.
|
void |
send(javax.jms.Message message)
Delegates the call to the wrapped producer.
|
void |
send(javax.jms.Message message,
javax.jms.CompletionListener completionListener)
Delegates the call to the wrapped producer.
|
void |
send(javax.jms.Message message,
int deliveryMode,
int priority,
long timeToLive)
Delegates the call to the wrapped producer.
|
void |
send(javax.jms.Message message,
int deliveryMode,
int priority,
long timeToLive,
javax.jms.CompletionListener completionListener)
Delegates the call to the wrapped producer.
|
void |
setDeliveryDelay(long deliveryDelay)
Delegates the call to the wrapped producer.
|
void |
setDeliveryMode(int deliveryMode)
Delegates the call to the wrapped producer.
|
void |
setDisableMessageID(boolean value)
Delegates the call to the wrapped producer.
|
void |
setDisableMessageTimestamp(boolean value)
Delegates the call to the wrapped producer.
|
void |
setPriority(int priority)
Delegates the call to the wrapped producer.
|
void |
setTimeToLive(long timeToLive)
Delegates the call to the wrapped producer.
|
public static org.objectweb.util.monolog.api.Logger logger
protected OutboundSession session
OutboundSession
this producer belongs to.protected javax.jms.MessageProducer producer
boolean valid
false
if producer is no more valid.OutboundProducer(javax.jms.MessageProducer producer, OutboundSession session)
OutboundProducer
instance.producer
- The JMS producer to wrap.session
- The OutboundSession this producer belongs to.public void setDisableMessageID(boolean value) throws javax.jms.JMSException
setDisableMessageID
in interface javax.jms.MessageProducer
javax.jms.JMSException
public void setDeliveryMode(int deliveryMode) throws javax.jms.JMSException
setDeliveryMode
in interface javax.jms.MessageProducer
javax.jms.JMSException
public void setPriority(int priority) throws javax.jms.JMSException
setPriority
in interface javax.jms.MessageProducer
javax.jms.JMSException
public void setTimeToLive(long timeToLive) throws javax.jms.JMSException
setTimeToLive
in interface javax.jms.MessageProducer
javax.jms.JMSException
public void setDisableMessageTimestamp(boolean value) throws javax.jms.JMSException
setDisableMessageTimestamp
in interface javax.jms.MessageProducer
javax.jms.JMSException
public javax.jms.Destination getDestination() throws javax.jms.JMSException
getDestination
in interface javax.jms.MessageProducer
javax.jms.JMSException
public boolean getDisableMessageID() throws javax.jms.JMSException
getDisableMessageID
in interface javax.jms.MessageProducer
javax.jms.JMSException
public int getDeliveryMode() throws javax.jms.JMSException
getDeliveryMode
in interface javax.jms.MessageProducer
javax.jms.JMSException
public int getPriority() throws javax.jms.JMSException
getPriority
in interface javax.jms.MessageProducer
javax.jms.JMSException
public long getTimeToLive() throws javax.jms.JMSException
getTimeToLive
in interface javax.jms.MessageProducer
javax.jms.JMSException
public boolean getDisableMessageTimestamp() throws javax.jms.JMSException
getDisableMessageTimestamp
in interface javax.jms.MessageProducer
javax.jms.JMSException
public void send(javax.jms.Message message) 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) throws javax.jms.JMSException
send
in interface javax.jms.MessageProducer
javax.jms.JMSException
public void send(javax.jms.Destination dest, javax.jms.Message message) throws javax.jms.JMSException
send
in interface javax.jms.MessageProducer
javax.jms.JMSException
public void send(javax.jms.Destination dest, javax.jms.Message message, int deliveryMode, int priority, long timeToLive) throws javax.jms.JMSException
send
in interface javax.jms.MessageProducer
javax.jms.JMSException
public void close() throws javax.jms.JMSException
close
in interface AutoCloseable
close
in interface javax.jms.MessageProducer
javax.jms.JMSException
protected void checkValidity() throws javax.jms.IllegalStateException
javax.jms.IllegalStateException
public 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 © 2018 ScalAgent D.T.. All Rights Reserved.