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