org.apache.qpid.client.message
Class AMQMessageDelegate_0_8

java.lang.Object
  extended by org.apache.qpid.client.message.AbstractAMQMessageDelegate
      extended by org.apache.qpid.client.message.AMQMessageDelegate_0_8
All Implemented Interfaces:
AMQMessageDelegate

public class AMQMessageDelegate_0_8
extends AbstractAMQMessageDelegate


Field Summary
static String JMS_TYPE
           
 
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)
           
 
Method Summary
 void acknowledge()
           
 void acknowledgeThis()
           
protected  void checkWritableProperties()
           
 void clearProperties()
           
 AMQSession getAMQSession()
           
 boolean getBooleanProperty(String propertyName)
           
 byte getByteProperty(String propertyName)
           
 org.apache.qpid.framing.BasicContentHeaderProperties getContentHeaderProperties()
           
 String getContentType()
           
 long getDeliveryTag()
          Get the AMQ message number assigned to this message
 double getDoubleProperty(String propertyName)
           
 String getEncoding()
           
 float getFloatProperty(String propertyName)
           
 int getIntProperty(String propertyName)
           
 String getJMSCorrelationID()
           
 byte[] getJMSCorrelationIDAsBytes()
           
 int getJMSDeliveryMode()
           
 Destination getJMSDestination()
           
 long getJMSExpiration()
           
 String getJMSMessageID()
           
 int getJMSPriority()
           
 Destination getJMSReplyTo()
           
 long getJMSTimestamp()
           
 String getJMSType()
           
 long getLongProperty(String propertyName)
           
 Object getObjectProperty(String propertyName)
           
 Enumeration getPropertyNames()
           
 String getReplyToString()
           
 short getShortProperty(String propertyName)
           
 String getStringProperty(String propertyName)
           
 boolean propertyExists(String propertyName)
           
 void removeProperty(String propertyName)
           
 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()
 void setBooleanProperty(String propertyName, boolean b)
           
 void setByteProperty(String propertyName, byte b)
           
 void setContentType(String contentType)
           
 void setDoubleProperty(String propertyName, double v)
           
 void setEncoding(String encoding)
           
 void setFloatProperty(String propertyName, float f)
           
 void setIntProperty(String propertyName, int i)
           
 void setJMSCorrelationID(String correlationId)
           
 void setJMSCorrelationIDAsBytes(byte[] bytes)
           
 void setJMSDeliveryMode(int i)
           
 void setJMSDestination(Destination destination)
           
 void setJMSExpiration(long l)
           
 void setJMSMessageID(String messageId)
           
 void setJMSMessageID(UUID messageId)
           
 void setJMSPriority(int i)
           
 void setJMSReplyTo(Destination destination)
           
 void setJMSTimestamp(long timestamp)
           
 void setJMSType(String string)
           
 void setLongProperty(String propertyName, long l)
           
 void setObjectProperty(String propertyName, Object object)
           
 void setShortProperty(String propertyName, short i)
           
 void setStringProperty(String propertyName, String value)
           
 
Methods inherited from class org.apache.qpid.client.message.AbstractAMQMessageDelegate
exchangeMapContains, generateDestination, updateExchangeType
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

JMS_TYPE

public static final String JMS_TYPE
See Also:
Constant Field Values
Constructor Detail

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)
Method Detail

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