public class AMQMessageDelegate_0_10 extends AbstractAMQMessageDelegate
Modifier | Constructor and Description |
---|---|
protected |
AMQMessageDelegate_0_10() |
protected |
AMQMessageDelegate_0_10(AMQDestination.DestSyntax destSyntax,
MessageProperties messageProps,
DeliveryProperties deliveryProps,
long deliveryTag) |
protected |
AMQMessageDelegate_0_10(MessageProperties messageProps,
DeliveryProperties deliveryProps,
long deliveryTag) |
acknowledge, acknowledgeThis, convertToAddressBasedDestination, exchangeMapContains, generateDestination, getAMQSession, getDeliveryTag, setAMQSession, updateExchangeType
public static final String JMS_TYPE
protected AMQMessageDelegate_0_10()
protected AMQMessageDelegate_0_10(MessageProperties messageProps, DeliveryProperties deliveryProps, long deliveryTag)
protected AMQMessageDelegate_0_10(AMQDestination.DestSyntax destSyntax, MessageProperties messageProps, DeliveryProperties deliveryProps, long deliveryTag)
public static void updateExchangeTypeMapping(Header header, Session session)
header
- The message headers, from which the exchange name can be extractedsession
- The 0-10 session to use to call ExchangeQuerypublic String getJMSMessageID() throws javax.jms.JMSException
javax.jms.JMSException
public void setJMSMessageID(String messageId) throws javax.jms.JMSException
javax.jms.JMSException
public void setJMSMessageID(UUID messageId) throws javax.jms.JMSException
javax.jms.JMSException
public long getJMSTimestamp() throws javax.jms.JMSException
javax.jms.JMSException
public void setJMSTimestamp(long timestamp) throws javax.jms.JMSException
javax.jms.JMSException
public byte[] getJMSCorrelationIDAsBytes() throws javax.jms.JMSException
javax.jms.JMSException
public void setJMSCorrelationIDAsBytes(byte[] bytes) throws javax.jms.JMSException
javax.jms.JMSException
public void setJMSCorrelationID(String correlationId) throws javax.jms.JMSException
javax.jms.JMSException
public String getJMSCorrelationID() throws javax.jms.JMSException
javax.jms.JMSException
public javax.jms.Destination getJMSReplyTo()
public void setJMSReplyTo(javax.jms.Destination destination) throws javax.jms.JMSException
javax.jms.JMSException
public javax.jms.Destination getJMSDestination()
public void setJMSDestination(javax.jms.Destination destination)
public void setContentType(String contentType)
public String getContentType()
public void setEncoding(String encoding)
public String getEncoding()
public String getReplyToString()
public int getJMSDeliveryMode() throws javax.jms.JMSException
javax.jms.JMSException
public void setJMSDeliveryMode(int deliveryMode) throws javax.jms.JMSException
javax.jms.JMSException
public String getJMSType() throws javax.jms.JMSException
javax.jms.JMSException
public void setJMSType(String type) throws javax.jms.JMSException
javax.jms.JMSException
public long getJMSExpiration() throws javax.jms.JMSException
javax.jms.JMSException
public void setJMSExpiration(long l) throws javax.jms.JMSException
javax.jms.JMSException
public boolean propertyExists(String propertyName) throws javax.jms.JMSException
javax.jms.JMSException
public boolean getBooleanProperty(String propertyName) throws javax.jms.JMSException
javax.jms.JMSException
public byte getByteProperty(String propertyName) throws javax.jms.JMSException
javax.jms.JMSException
public short getShortProperty(String propertyName) throws javax.jms.JMSException
javax.jms.JMSException
public int getIntProperty(String propertyName) throws javax.jms.JMSException
javax.jms.JMSException
public long getLongProperty(String propertyName) throws javax.jms.JMSException
javax.jms.JMSException
public float getFloatProperty(String propertyName) throws javax.jms.JMSException
javax.jms.JMSException
public double getDoubleProperty(String propertyName) throws javax.jms.JMSException
javax.jms.JMSException
public String getStringProperty(String propertyName) throws javax.jms.JMSException
javax.jms.JMSException
public Object getObjectProperty(String propertyName) throws javax.jms.JMSException
javax.jms.JMSException
public Enumeration getPropertyNames() throws javax.jms.JMSException
javax.jms.JMSException
public void setBooleanProperty(String propertyName, boolean b) throws javax.jms.JMSException
javax.jms.JMSException
public void setByteProperty(String propertyName, byte b) throws javax.jms.JMSException
javax.jms.JMSException
public void setShortProperty(String propertyName, short i) throws javax.jms.JMSException
javax.jms.JMSException
public void setIntProperty(String propertyName, int i) throws javax.jms.JMSException
javax.jms.JMSException
public void setLongProperty(String propertyName, long l) throws javax.jms.JMSException
javax.jms.JMSException
public void setFloatProperty(String propertyName, float f) throws javax.jms.JMSException
javax.jms.JMSException
public void setDoubleProperty(String propertyName, double v) throws javax.jms.JMSException
javax.jms.JMSException
public void setStringProperty(String propertyName, String value) throws javax.jms.JMSException
javax.jms.JMSException
public void setObjectProperty(String propertyName, Object object) throws javax.jms.JMSException
javax.jms.JMSException
public void removeProperty(String propertyName) throws javax.jms.JMSException
javax.jms.JMSException
protected void checkWritableProperties() throws javax.jms.MessageNotWriteableException
javax.jms.MessageNotWriteableException
public int getJMSPriority() throws javax.jms.JMSException
javax.jms.JMSException
public void setJMSPriority(int i) throws javax.jms.JMSException
javax.jms.JMSException
public void clearProperties() throws javax.jms.JMSException
javax.jms.JMSException
protected void checkPropertyName(CharSequence propertyName)
protected void checkIdentiferFormat(CharSequence propertyName)
public MessageProperties getMessageProperties()
public DeliveryProperties getDeliveryProperties()
Copyright © 2006–2016 The Apache Software Foundation. All rights reserved.