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