public class ProducerContext extends SessionContext
Modifier and Type | Field and Description |
---|---|
private String |
dfltCorrelationID |
private long |
dfltDeliveryDelay |
private int |
dfltDeliveryMode |
private int |
dfltPriority |
private long |
dfltTimeToLive |
static Logger |
logger |
private JMSProducer |
producer |
private int |
sent |
lastId
Constructor and Description |
---|
ProducerContext(RestClientContext clientCtx) |
Modifier and Type | Method and Description |
---|---|
(package private) Message |
createMessage(String type,
Object jmsBody) |
JMSProducer |
getProducer() |
(package private) long |
send(String type,
Map<String,Object> jmsHeaders,
Map<String,Object> jmsProps,
Object jmsBody,
int deliveryMode,
long deliveryDelay,
int priority,
long timeToLive,
String correlationID) |
void |
setDefaultDeliveryDelay(long deliveryDelay) |
void |
setDefaultDeliveryMode(int deliveryMode) |
void |
setDefaultJMSCorrelationID(String correlationID) |
void |
setDefaultPriority(int priority) |
void |
setDefaultTimeToLive(long timeToLive) |
(package private) void |
setJMSProperties(Message msg,
Map<String,Object> jmsProps) |
void |
setProducer(JMSProducer producer) |
String |
toString() |
getClientCtx, getDest, getJmsContext, getLastId, incLastId, setDest, setJmsContext, setLastId, viewLastId
public static Logger logger
private JMSProducer producer
private int dfltDeliveryMode
private String dfltCorrelationID
private int dfltPriority
private long dfltTimeToLive
private long dfltDeliveryDelay
private int sent
public ProducerContext(RestClientContext clientCtx)
public JMSProducer getProducer()
public void setProducer(JMSProducer producer)
producer
- the producer to setpublic void setDefaultDeliveryMode(int deliveryMode)
public void setDefaultJMSCorrelationID(String correlationID)
public void setDefaultPriority(int priority)
public void setDefaultTimeToLive(long timeToLive)
public void setDefaultDeliveryDelay(long deliveryDelay)
final Message createMessage(String type, Object jmsBody) throws Exception
Exception
final void setJMSProperties(Message msg, Map<String,Object> jmsProps) throws JMSException
JMSException
long send(String type, Map<String,Object> jmsHeaders, Map<String,Object> jmsProps, Object jmsBody, int deliveryMode, long deliveryDelay, int priority, long timeToLive, String correlationID) throws Exception
Exception
public String toString()
toString
in class SessionContext
Copyright © 2023 ScalAgent D.T.. All rights reserved.