public class OutboundProducer extends Object implements 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 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(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.
|
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(Destination dest,
Message message)
Delegates the call to the wrapped producer.
|
void |
send(Destination destination,
Message message,
CompletionListener completionListener)
Delegates the call to the wrapped producer.
|
void |
send(Destination dest,
Message message,
int deliveryMode,
int priority,
long timeToLive)
Delegates the call to the wrapped producer.
|
void |
send(Destination destination,
Message message,
int deliveryMode,
int priority,
long timeToLive,
CompletionListener completionListener)
Delegates the call to the wrapped producer.
|
void |
send(Message message)
Delegates the call to the wrapped producer.
|
void |
send(Message message,
CompletionListener completionListener)
Delegates the call to the wrapped producer.
|
void |
send(Message message,
int deliveryMode,
int priority,
long timeToLive)
Delegates the call to the wrapped producer.
|
void |
send(Message message,
int deliveryMode,
int priority,
long timeToLive,
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 MessageProducer producer
boolean valid
false
if producer is no more valid.OutboundProducer(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 JMSException
setDisableMessageID
in interface MessageProducer
JMSException
public void setDeliveryMode(int deliveryMode) throws JMSException
setDeliveryMode
in interface MessageProducer
JMSException
public void setPriority(int priority) throws JMSException
setPriority
in interface MessageProducer
JMSException
public void setTimeToLive(long timeToLive) throws JMSException
setTimeToLive
in interface MessageProducer
JMSException
public void setDisableMessageTimestamp(boolean value) throws JMSException
setDisableMessageTimestamp
in interface MessageProducer
JMSException
public Destination getDestination() throws JMSException
getDestination
in interface MessageProducer
JMSException
public boolean getDisableMessageID() throws JMSException
getDisableMessageID
in interface MessageProducer
JMSException
public int getDeliveryMode() throws JMSException
getDeliveryMode
in interface MessageProducer
JMSException
public int getPriority() throws JMSException
getPriority
in interface MessageProducer
JMSException
public long getTimeToLive() throws JMSException
getTimeToLive
in interface MessageProducer
JMSException
public boolean getDisableMessageTimestamp() throws JMSException
getDisableMessageTimestamp
in interface MessageProducer
JMSException
public void send(Message message) throws JMSException
send
in interface MessageProducer
JMSException
public void send(Message message, int deliveryMode, int priority, long timeToLive) throws JMSException
send
in interface MessageProducer
JMSException
public void send(Destination dest, Message message) throws JMSException
send
in interface MessageProducer
JMSException
public void send(Destination dest, Message message, int deliveryMode, int priority, long timeToLive) throws JMSException
send
in interface MessageProducer
JMSException
public void close() throws JMSException
close
in interface AutoCloseable
close
in interface MessageProducer
JMSException
protected void checkValidity() throws IllegalStateException
IllegalStateException
public void setDeliveryDelay(long deliveryDelay) throws JMSException
setDeliveryDelay
in interface MessageProducer
JMSException
public long getDeliveryDelay() throws JMSException
getDeliveryDelay
in interface MessageProducer
JMSException
public void send(Message message, CompletionListener completionListener) throws JMSException
send
in interface MessageProducer
JMSException
public void send(Message message, int deliveryMode, int priority, long timeToLive, CompletionListener completionListener) throws JMSException
send
in interface MessageProducer
JMSException
public void send(Destination destination, Message message, CompletionListener completionListener) throws JMSException
send
in interface MessageProducer
JMSException
public void send(Destination destination, Message message, int deliveryMode, int priority, long timeToLive, CompletionListener completionListener) throws JMSException
send
in interface MessageProducer
JMSException
Copyright © 2019 ScalAgent D.T.. All rights reserved.