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