org.apache.qpid.client.message
Class AMQMessageDelegate_0_8
java.lang.Object
org.apache.qpid.client.message.AbstractAMQMessageDelegate
org.apache.qpid.client.message.AMQMessageDelegate_0_8
- All Implemented Interfaces:
- AMQMessageDelegate
public class AMQMessageDelegate_0_8
- extends AbstractAMQMessageDelegate
Constructor Summary |
protected |
AMQMessageDelegate_0_8()
|
protected |
AMQMessageDelegate_0_8(long deliveryTag,
org.apache.qpid.framing.BasicContentHeaderProperties contentHeader,
org.apache.qpid.framing.AMQShortString exchange,
org.apache.qpid.framing.AMQShortString routingKey)
|
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
JMS_TYPE
public static final String JMS_TYPE
- See Also:
- Constant Field Values
AMQMessageDelegate_0_8
protected AMQMessageDelegate_0_8()
AMQMessageDelegate_0_8
protected AMQMessageDelegate_0_8(long deliveryTag,
org.apache.qpid.framing.BasicContentHeaderProperties contentHeader,
org.apache.qpid.framing.AMQShortString exchange,
org.apache.qpid.framing.AMQShortString routingKey)
getJMSMessageID
public String getJMSMessageID()
throws JMSException
- Throws:
JMSException
setJMSMessageID
public void setJMSMessageID(String messageId)
throws JMSException
- Throws:
JMSException
setJMSMessageID
public void setJMSMessageID(UUID messageId)
throws JMSException
- Throws:
JMSException
getJMSTimestamp
public long getJMSTimestamp()
throws JMSException
- Throws:
JMSException
setJMSTimestamp
public void setJMSTimestamp(long timestamp)
throws JMSException
- Throws:
JMSException
getJMSCorrelationIDAsBytes
public byte[] getJMSCorrelationIDAsBytes()
throws JMSException
- Throws:
JMSException
setJMSCorrelationIDAsBytes
public void setJMSCorrelationIDAsBytes(byte[] bytes)
throws JMSException
- Throws:
JMSException
setJMSCorrelationID
public void setJMSCorrelationID(String correlationId)
throws JMSException
- Throws:
JMSException
getJMSCorrelationID
public String getJMSCorrelationID()
throws JMSException
- Throws:
JMSException
getJMSReplyTo
public Destination getJMSReplyTo()
throws JMSException
- Throws:
JMSException
setJMSReplyTo
public void setJMSReplyTo(Destination destination)
throws JMSException
- Throws:
JMSException
getJMSDestination
public Destination getJMSDestination()
throws JMSException
- Throws:
JMSException
setJMSDestination
public void setJMSDestination(Destination destination)
setContentType
public void setContentType(String contentType)
getContentType
public String getContentType()
setEncoding
public void setEncoding(String encoding)
getEncoding
public String getEncoding()
getReplyToString
public String getReplyToString()
getJMSDeliveryMode
public int getJMSDeliveryMode()
throws JMSException
- Throws:
JMSException
setJMSDeliveryMode
public void setJMSDeliveryMode(int i)
throws JMSException
- Throws:
JMSException
getContentHeaderProperties
public org.apache.qpid.framing.BasicContentHeaderProperties getContentHeaderProperties()
getJMSType
public String getJMSType()
throws JMSException
- Throws:
JMSException
setJMSType
public void setJMSType(String string)
throws JMSException
- Throws:
JMSException
getJMSExpiration
public long getJMSExpiration()
throws JMSException
- Throws:
JMSException
setJMSExpiration
public void setJMSExpiration(long l)
throws JMSException
- Throws:
JMSException
propertyExists
public boolean propertyExists(String propertyName)
throws JMSException
- Throws:
JMSException
getBooleanProperty
public boolean getBooleanProperty(String propertyName)
throws JMSException
- Throws:
JMSException
getByteProperty
public byte getByteProperty(String propertyName)
throws JMSException
- Throws:
JMSException
getShortProperty
public short getShortProperty(String propertyName)
throws JMSException
- Throws:
JMSException
getIntProperty
public int getIntProperty(String propertyName)
throws JMSException
- Throws:
JMSException
getLongProperty
public long getLongProperty(String propertyName)
throws JMSException
- Throws:
JMSException
getFloatProperty
public float getFloatProperty(String propertyName)
throws JMSException
- Throws:
JMSException
getDoubleProperty
public double getDoubleProperty(String propertyName)
throws JMSException
- Throws:
JMSException
getStringProperty
public String getStringProperty(String propertyName)
throws JMSException
- Throws:
JMSException
getObjectProperty
public Object getObjectProperty(String propertyName)
throws JMSException
- Throws:
JMSException
getPropertyNames
public Enumeration getPropertyNames()
throws JMSException
- Throws:
JMSException
setBooleanProperty
public void setBooleanProperty(String propertyName,
boolean b)
throws JMSException
- Throws:
JMSException
setByteProperty
public void setByteProperty(String propertyName,
byte b)
throws JMSException
- Throws:
JMSException
setShortProperty
public void setShortProperty(String propertyName,
short i)
throws JMSException
- Throws:
JMSException
setIntProperty
public void setIntProperty(String propertyName,
int i)
throws JMSException
- Throws:
JMSException
setLongProperty
public void setLongProperty(String propertyName,
long l)
throws JMSException
- Throws:
JMSException
setFloatProperty
public void setFloatProperty(String propertyName,
float f)
throws JMSException
- Throws:
JMSException
setDoubleProperty
public void setDoubleProperty(String propertyName,
double v)
throws JMSException
- Throws:
JMSException
setStringProperty
public void setStringProperty(String propertyName,
String value)
throws JMSException
- Throws:
JMSException
setObjectProperty
public void setObjectProperty(String propertyName,
Object object)
throws JMSException
- Throws:
JMSException
removeProperty
public void removeProperty(String propertyName)
throws JMSException
- Throws:
JMSException
checkWritableProperties
protected void checkWritableProperties()
throws MessageNotWriteableException
- Throws:
MessageNotWriteableException
getJMSPriority
public int getJMSPriority()
throws JMSException
- Throws:
JMSException
setJMSPriority
public void setJMSPriority(int i)
throws JMSException
- Throws:
JMSException
clearProperties
public void clearProperties()
throws JMSException
- Throws:
JMSException
acknowledgeThis
public void acknowledgeThis()
throws JMSException
- Throws:
JMSException
acknowledge
public void acknowledge()
throws JMSException
- Throws:
JMSException
setAMQSession
public void setAMQSession(AMQSession s)
- The session is set when CLIENT_ACKNOWLEDGE mode is used so that the CHANNEL ACK can be sent when the user calls
acknowledge()
- Parameters:
s
- the AMQ session that delivered this message
getAMQSession
public AMQSession getAMQSession()
getDeliveryTag
public long getDeliveryTag()
- Get the AMQ message number assigned to this message
- Returns:
- the message number
Licensed to the Apache Software Foundation