public class MessageProvider extends Object
Modifier and Type | Field and Description |
---|---|
static String |
DELIVERY_MODE |
static String |
PRIORITY |
static String[] |
STANDARD_JMS_PROPERTIES |
static String |
TTL |
Constructor and Description |
---|
MessageProvider(Map<String,PropertyValue> messageProperties) |
Modifier and Type | Method and Description |
---|---|
protected javax.jms.Message |
createTextMessage(javax.jms.Session ssn,
CreateProducerCommand command) |
protected String |
getMessagePayload(CreateProducerCommand command) |
boolean |
isPropertySet(String name) |
protected boolean |
isStandardProperty(String propertyName) |
javax.jms.Message |
nextMessage(javax.jms.Session session,
CreateProducerCommand command) |
protected void |
setCustomProperty(javax.jms.Message message,
String propertyName,
Object propertyValue) |
void |
setMessageProperties(javax.jms.Message message) |
protected void |
setStandardProperty(javax.jms.Message message,
String property,
Object propertyValue) |
String |
toString() |
public static final String TTL
public static final String DELIVERY_MODE
public static final String PRIORITY
public static final String[] STANDARD_JMS_PROPERTIES
public MessageProvider(Map<String,PropertyValue> messageProperties)
public javax.jms.Message nextMessage(javax.jms.Session session, CreateProducerCommand command) throws javax.jms.JMSException
javax.jms.JMSException
public boolean isPropertySet(String name)
public void setMessageProperties(javax.jms.Message message) throws javax.jms.JMSException
javax.jms.JMSException
protected void setCustomProperty(javax.jms.Message message, String propertyName, Object propertyValue) throws javax.jms.JMSException
javax.jms.JMSException
protected void setStandardProperty(javax.jms.Message message, String property, Object propertyValue) throws javax.jms.JMSException
javax.jms.JMSException
protected boolean isStandardProperty(String propertyName)
protected javax.jms.Message createTextMessage(javax.jms.Session ssn, CreateProducerCommand command) throws javax.jms.JMSException
javax.jms.JMSException
protected String getMessagePayload(CreateProducerCommand command)
Copyright © 2006–2016 The Apache Software Foundation. All rights reserved.