public class JMSProducer extends Object implements jakarta.jms.JMSProducer
Modifier and Type | Field and Description |
---|---|
private jakarta.jms.CompletionListener |
completionListener |
(package private) String |
jmsCorrelationID |
private String |
jmsType |
static Logger |
logger |
private MessageProducer |
messageProducer |
private Map<String,Object> |
properties |
private jakarta.jms.Destination |
replyTo |
private Session |
session |
Constructor and Description |
---|
JMSProducer(Session session) |
Modifier and Type | Method and Description |
---|---|
jakarta.jms.JMSProducer |
clearProperties() |
private Object |
doGetProperty(String name) |
private void |
doSend(jakarta.jms.Destination destination,
jakarta.jms.Message message)
Send message to destination
|
jakarta.jms.CompletionListener |
getAsync() |
boolean |
getBooleanProperty(String name) |
byte |
getByteProperty(String name) |
long |
getDeliveryDelay()
API method
|
int |
getDeliveryMode()
API method
|
boolean |
getDisableMessageID()
API method
|
boolean |
getDisableMessageTimestamp()
API method
|
double |
getDoubleProperty(String name) |
float |
getFloatProperty(String name) |
int |
getIntProperty(String name) |
String |
getJMSCorrelationID() |
byte[] |
getJMSCorrelationIDAsBytes() |
jakarta.jms.Destination |
getJMSReplyTo() |
String |
getJMSType() |
long |
getLongProperty(String name) |
Object |
getObjectProperty(String name) |
int |
getPriority() |
Set<String> |
getPropertyNames() |
short |
getShortProperty(String name) |
String |
getString2Property(String name) |
String |
getStringProperty(String name) |
long |
getTimeToLive() |
boolean |
propertyExists(String name) |
jakarta.jms.JMSProducer |
send(jakarta.jms.Destination destination,
byte[] body)
JMS 2.0 API method.
|
jakarta.jms.JMSProducer |
send(jakarta.jms.Destination destination,
Map<String,Object> body)
JMS 2.0 API method.
|
jakarta.jms.JMSProducer |
send(jakarta.jms.Destination destination,
jakarta.jms.Message message)
JMS 2.0 API method.
|
jakarta.jms.JMSProducer |
send(jakarta.jms.Destination destination,
Serializable body)
JMS 2.0 API method.
|
jakarta.jms.JMSProducer |
send(jakarta.jms.Destination destination,
String body)
JMS 2.0 API method.
|
jakarta.jms.JMSProducer |
setAsync(jakarta.jms.CompletionListener completionListener) |
jakarta.jms.JMSProducer |
setDeliveryDelay(long deliveryDelay) |
jakarta.jms.JMSProducer |
setDeliveryMode(int deliveryMode) |
jakarta.jms.JMSProducer |
setDisableMessageID(boolean value)
API method
|
jakarta.jms.JMSProducer |
setDisableMessageTimestamp(boolean value)
API method
|
jakarta.jms.JMSProducer |
setJMSCorrelationID(String correlationID) |
jakarta.jms.JMSProducer |
setJMSCorrelationIDAsBytes(byte[] correlationID) |
jakarta.jms.JMSProducer |
setJMSReplyTo(jakarta.jms.Destination replyTo) |
jakarta.jms.JMSProducer |
setJMSType(String type) |
jakarta.jms.JMSProducer |
setPriority(int priority) |
jakarta.jms.JMSProducer |
setProperty(String name,
boolean value) |
jakarta.jms.JMSProducer |
setProperty(String name,
byte value) |
jakarta.jms.JMSProducer |
setProperty(String name,
double value) |
jakarta.jms.JMSProducer |
setProperty(String name,
float value) |
jakarta.jms.JMSProducer |
setProperty(String name,
int value) |
jakarta.jms.JMSProducer |
setProperty(String name,
long value) |
jakarta.jms.JMSProducer |
setProperty(String name,
Object value) |
jakarta.jms.JMSProducer |
setProperty(String name,
short value) |
jakarta.jms.JMSProducer |
setProperty(String name,
String value) |
jakarta.jms.JMSProducer |
setTimeToLive(long timeToLive) |
private jakarta.jms.Message |
writeCurrentProperties(jakarta.jms.Message message)
Writes properties previously stored, in message and sets reply destination
|
public static Logger logger
private jakarta.jms.CompletionListener completionListener
String jmsCorrelationID
private String jmsType
private MessageProducer messageProducer
private jakarta.jms.Destination replyTo
private Session session
public JMSProducer(Session session) throws jakarta.jms.JMSException
jakarta.jms.JMSException
public jakarta.jms.JMSProducer setAsync(jakarta.jms.CompletionListener completionListener)
setAsync
in interface jakarta.jms.JMSProducer
public jakarta.jms.CompletionListener getAsync()
getAsync
in interface jakarta.jms.JMSProducer
private void doSend(jakarta.jms.Destination destination, jakarta.jms.Message message)
destination
- message
- message to sendjakarta.jms.JMSException
- if error occurspublic long getDeliveryDelay()
getDeliveryDelay
in interface jakarta.jms.JMSProducer
public int getDeliveryMode()
getDeliveryMode
in interface jakarta.jms.JMSProducer
public boolean getDisableMessageID()
getDisableMessageID
in interface jakarta.jms.JMSProducer
public boolean getDisableMessageTimestamp()
getDisableMessageTimestamp
in interface jakarta.jms.JMSProducer
public String getJMSCorrelationID()
getJMSCorrelationID
in interface jakarta.jms.JMSProducer
public jakarta.jms.JMSProducer setJMSCorrelationID(String correlationID)
setJMSCorrelationID
in interface jakarta.jms.JMSProducer
public byte[] getJMSCorrelationIDAsBytes()
getJMSCorrelationIDAsBytes
in interface jakarta.jms.JMSProducer
public jakarta.jms.JMSProducer setJMSCorrelationIDAsBytes(byte[] correlationID)
setJMSCorrelationIDAsBytes
in interface jakarta.jms.JMSProducer
public jakarta.jms.Destination getJMSReplyTo()
getJMSReplyTo
in interface jakarta.jms.JMSProducer
public String getJMSType()
getJMSType
in interface jakarta.jms.JMSProducer
public int getPriority()
getPriority
in interface jakarta.jms.JMSProducer
public Set<String> getPropertyNames()
getPropertyNames
in interface jakarta.jms.JMSProducer
public long getTimeToLive()
getTimeToLive
in interface jakarta.jms.JMSProducer
public boolean propertyExists(String name)
propertyExists
in interface jakarta.jms.JMSProducer
public jakarta.jms.JMSProducer send(jakarta.jms.Destination destination, byte[] body)
send
in interface jakarta.jms.JMSProducer
public jakarta.jms.JMSProducer send(jakarta.jms.Destination destination, Map<String,Object> body)
send
in interface jakarta.jms.JMSProducer
public jakarta.jms.JMSProducer send(jakarta.jms.Destination destination, jakarta.jms.Message message)
send
in interface jakarta.jms.JMSProducer
public jakarta.jms.JMSProducer send(jakarta.jms.Destination destination, Serializable body)
send
in interface jakarta.jms.JMSProducer
public jakarta.jms.JMSProducer send(jakarta.jms.Destination destination, String body)
send
in interface jakarta.jms.JMSProducer
public jakarta.jms.JMSProducer setDeliveryDelay(long deliveryDelay)
setDeliveryDelay
in interface jakarta.jms.JMSProducer
public jakarta.jms.JMSProducer setDeliveryMode(int deliveryMode)
setDeliveryMode
in interface jakarta.jms.JMSProducer
public jakarta.jms.JMSProducer setDisableMessageID(boolean value)
setDisableMessageID
in interface jakarta.jms.JMSProducer
public jakarta.jms.JMSProducer setDisableMessageTimestamp(boolean value)
setDisableMessageTimestamp
in interface jakarta.jms.JMSProducer
public jakarta.jms.JMSProducer setJMSReplyTo(jakarta.jms.Destination replyTo)
setJMSReplyTo
in interface jakarta.jms.JMSProducer
public jakarta.jms.JMSProducer setJMSType(String type)
setJMSType
in interface jakarta.jms.JMSProducer
public jakarta.jms.JMSProducer setPriority(int priority)
setPriority
in interface jakarta.jms.JMSProducer
public jakarta.jms.JMSProducer setTimeToLive(long timeToLive)
setTimeToLive
in interface jakarta.jms.JMSProducer
private jakarta.jms.Message writeCurrentProperties(jakarta.jms.Message message) throws jakarta.jms.JMSException
Message
- messagejakarta.jms.JMSException
- when property is not assignable to messagepublic final String getString2Property(String name) throws jakarta.jms.JMSException
jakarta.jms.JMSException
public jakarta.jms.JMSProducer clearProperties()
clearProperties
in interface jakarta.jms.JMSProducer
public boolean getBooleanProperty(String name)
getBooleanProperty
in interface jakarta.jms.JMSProducer
public byte getByteProperty(String name)
getByteProperty
in interface jakarta.jms.JMSProducer
public short getShortProperty(String name)
getShortProperty
in interface jakarta.jms.JMSProducer
public int getIntProperty(String name)
getIntProperty
in interface jakarta.jms.JMSProducer
public long getLongProperty(String name)
getLongProperty
in interface jakarta.jms.JMSProducer
public float getFloatProperty(String name)
getFloatProperty
in interface jakarta.jms.JMSProducer
public double getDoubleProperty(String name)
getDoubleProperty
in interface jakarta.jms.JMSProducer
public String getStringProperty(String name)
getStringProperty
in interface jakarta.jms.JMSProducer
public Object getObjectProperty(String name)
getObjectProperty
in interface jakarta.jms.JMSProducer
public jakarta.jms.JMSProducer setProperty(String name, boolean value)
setProperty
in interface jakarta.jms.JMSProducer
public jakarta.jms.JMSProducer setProperty(String name, byte value)
setProperty
in interface jakarta.jms.JMSProducer
public jakarta.jms.JMSProducer setProperty(String name, double value)
setProperty
in interface jakarta.jms.JMSProducer
public jakarta.jms.JMSProducer setProperty(String name, float value)
setProperty
in interface jakarta.jms.JMSProducer
public jakarta.jms.JMSProducer setProperty(String name, int value)
setProperty
in interface jakarta.jms.JMSProducer
public jakarta.jms.JMSProducer setProperty(String name, long value)
setProperty
in interface jakarta.jms.JMSProducer
public jakarta.jms.JMSProducer setProperty(String name, Object value)
setProperty
in interface jakarta.jms.JMSProducer
public jakarta.jms.JMSProducer setProperty(String name, short value)
setProperty
in interface jakarta.jms.JMSProducer
Copyright © 2023 ScalAgent D.T.. All rights reserved.