org.apache.qpid.client.message
Class JMSBytesMessage

java.lang.Object
  extended by org.apache.qpid.client.message.AbstractJMSMessage
      extended by org.apache.qpid.client.message.AbstractBytesMessage
          extended by org.apache.qpid.client.message.JMSBytesMessage
All Implemented Interfaces:
BytesMessage, Message

public class JMSBytesMessage
extends AbstractBytesMessage
implements BytesMessage


Field Summary
static String MIME_TYPE
           
 
Fields inherited from class org.apache.qpid.client.message.AbstractJMSMessage
_changedData, _data, _delegate, _readableMessage
 
Fields inherited from interface javax.jms.Message
DEFAULT_DELIVERY_MODE, DEFAULT_PRIORITY, DEFAULT_TIME_TO_LIVE
 
Fields inherited from interface org.apache.qpid.jms.Message
JMS_TYPE
 
Constructor Summary
JMSBytesMessage(AMQMessageDelegate delegate, org.apache.mina.common.ByteBuffer data)
           
JMSBytesMessage(AMQMessageDelegateFactory delegateFactory)
           
JMSBytesMessage(AMQMessageDelegateFactory delegateFactory, org.apache.mina.common.ByteBuffer data)
          Construct a bytes message with existing data.
 
Method Summary
 long getBodyLength()
           
protected  String getMimeType()
           
 boolean readBoolean()
           
 byte readByte()
           
 int readBytes(byte[] bytes)
           
 int readBytes(byte[] bytes, int maxLength)
           
 char readChar()
          Note that this method reads a unicode character as two bytes from the stream
 double readDouble()
           
 float readFloat()
           
 int readInt()
           
 long readLong()
           
 short readShort()
           
 int readUnsignedByte()
           
 int readUnsignedShort()
           
 String readUTF()
           
 void reset()
           
 void writeBoolean(boolean b)
           
 void writeByte(byte b)
           
 void writeBytes(byte[] bytes)
           
 void writeBytes(byte[] bytes, int offset, int length)
           
 void writeChar(char c)
           
 void writeDouble(double v)
           
 void writeFloat(float v)
           
 void writeInt(int i)
           
 void writeLong(long l)
           
 void writeObject(Object object)
           
 void writeShort(short i)
           
 void writeUTF(String string)
           
 
Methods inherited from class org.apache.qpid.client.message.AbstractBytesMessage
allocateInitialBuffer, checkAvailable, clearBodyImpl, toBodyString
 
Methods inherited from class org.apache.qpid.client.message.AbstractJMSMessage
acknowledge, acknowledgeThis, checkReadable, checkWritable, clearBody, clearProperties, getAMQSession, getBooleanProperty, getByteProperty, getContentLength, getContentType, getData, getDelegate, getDeliveryTag, getDoubleProperty, getEncoding, getFloatProperty, getIntProperty, getJMSCorrelationID, getJMSCorrelationIDAsBytes, getJMSDeliveryMode, getJMSDestination, getJMSExpiration, getJMSMessageID, getJMSPriority, getJMSRedelivered, getJMSReplyTo, getJMSTimestamp, getJMSType, getLongProperty, getObjectProperty, getPropertyNames, getReplyToString, getShortProperty, getStringProperty, prepareForSending, propertyExists, receivedFromServer, removeProperty, setAMQSession, setBooleanProperty, setByteProperty, setContentType, setDoubleProperty, setEncoding, setFloatProperty, setIntProperty, setJMSCorrelationID, setJMSCorrelationIDAsBytes, setJMSDeliveryMode, setJMSDestination, setJMSExpiration, setJMSMessageID, setJMSMessageID, setJMSPriority, setJMSRedelivered, setJMSReplyTo, setJMSTimestamp, setJMSType, setLongProperty, setObjectProperty, setShortProperty, setStringProperty, toString
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
 
Methods inherited from interface javax.jms.Message
acknowledge, clearBody, clearProperties, getBooleanProperty, getByteProperty, getDoubleProperty, getFloatProperty, getIntProperty, getJMSCorrelationID, getJMSCorrelationIDAsBytes, getJMSDeliveryMode, getJMSDestination, getJMSExpiration, getJMSMessageID, getJMSPriority, getJMSRedelivered, getJMSReplyTo, getJMSTimestamp, getJMSType, getLongProperty, getObjectProperty, getPropertyNames, getShortProperty, getStringProperty, propertyExists, setBooleanProperty, setByteProperty, setDoubleProperty, setFloatProperty, setIntProperty, setJMSCorrelationID, setJMSCorrelationIDAsBytes, setJMSDeliveryMode, setJMSDestination, setJMSExpiration, setJMSMessageID, setJMSPriority, setJMSRedelivered, setJMSReplyTo, setJMSTimestamp, setJMSType, setLongProperty, setObjectProperty, setShortProperty, setStringProperty
 

Field Detail

MIME_TYPE

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

JMSBytesMessage

public JMSBytesMessage(AMQMessageDelegateFactory delegateFactory)

JMSBytesMessage

JMSBytesMessage(AMQMessageDelegateFactory delegateFactory,
                org.apache.mina.common.ByteBuffer data)
Construct a bytes message with existing data.

Parameters:
delegateFactory -
data - the data that comprises this message. If data is null, you get a 1024 byte buffer that is

JMSBytesMessage

JMSBytesMessage(AMQMessageDelegate delegate,
                org.apache.mina.common.ByteBuffer data)
          throws org.apache.qpid.AMQException
Throws:
org.apache.qpid.AMQException
Method Detail

reset

public void reset()
Specified by:
reset in interface BytesMessage
Overrides:
reset in class AbstractJMSMessage

getMimeType

protected String getMimeType()
Specified by:
getMimeType in class AbstractJMSMessage

getBodyLength

public long getBodyLength()
                   throws JMSException
Specified by:
getBodyLength in interface BytesMessage
Throws:
JMSException

readBoolean

public boolean readBoolean()
                    throws JMSException
Specified by:
readBoolean in interface BytesMessage
Throws:
JMSException

readByte

public byte readByte()
              throws JMSException
Specified by:
readByte in interface BytesMessage
Throws:
JMSException

readUnsignedByte

public int readUnsignedByte()
                     throws JMSException
Specified by:
readUnsignedByte in interface BytesMessage
Throws:
JMSException

readShort

public short readShort()
                throws JMSException
Specified by:
readShort in interface BytesMessage
Throws:
JMSException

readUnsignedShort

public int readUnsignedShort()
                      throws JMSException
Specified by:
readUnsignedShort in interface BytesMessage
Throws:
JMSException

readChar

public char readChar()
              throws JMSException
Note that this method reads a unicode character as two bytes from the stream

Specified by:
readChar in interface BytesMessage
Returns:
the character read from the stream
Throws:
JMSException

readInt

public int readInt()
            throws JMSException
Specified by:
readInt in interface BytesMessage
Throws:
JMSException

readLong

public long readLong()
              throws JMSException
Specified by:
readLong in interface BytesMessage
Throws:
JMSException

readFloat

public float readFloat()
                throws JMSException
Specified by:
readFloat in interface BytesMessage
Throws:
JMSException

readDouble

public double readDouble()
                  throws JMSException
Specified by:
readDouble in interface BytesMessage
Throws:
JMSException

readUTF

public String readUTF()
               throws JMSException
Specified by:
readUTF in interface BytesMessage
Throws:
JMSException

readBytes

public int readBytes(byte[] bytes)
              throws JMSException
Specified by:
readBytes in interface BytesMessage
Throws:
JMSException

readBytes

public int readBytes(byte[] bytes,
                     int maxLength)
              throws JMSException
Specified by:
readBytes in interface BytesMessage
Throws:
JMSException

writeBoolean

public void writeBoolean(boolean b)
                  throws JMSException
Specified by:
writeBoolean in interface BytesMessage
Throws:
JMSException

writeByte

public void writeByte(byte b)
               throws JMSException
Specified by:
writeByte in interface BytesMessage
Throws:
JMSException

writeShort

public void writeShort(short i)
                throws JMSException
Specified by:
writeShort in interface BytesMessage
Throws:
JMSException

writeChar

public void writeChar(char c)
               throws JMSException
Specified by:
writeChar in interface BytesMessage
Throws:
JMSException

writeInt

public void writeInt(int i)
              throws JMSException
Specified by:
writeInt in interface BytesMessage
Throws:
JMSException

writeLong

public void writeLong(long l)
               throws JMSException
Specified by:
writeLong in interface BytesMessage
Throws:
JMSException

writeFloat

public void writeFloat(float v)
                throws JMSException
Specified by:
writeFloat in interface BytesMessage
Throws:
JMSException

writeDouble

public void writeDouble(double v)
                 throws JMSException
Specified by:
writeDouble in interface BytesMessage
Throws:
JMSException

writeUTF

public void writeUTF(String string)
              throws JMSException
Specified by:
writeUTF in interface BytesMessage
Throws:
JMSException

writeBytes

public void writeBytes(byte[] bytes)
                throws JMSException
Specified by:
writeBytes in interface BytesMessage
Throws:
JMSException

writeBytes

public void writeBytes(byte[] bytes,
                       int offset,
                       int length)
                throws JMSException
Specified by:
writeBytes in interface BytesMessage
Throws:
JMSException

writeObject

public void writeObject(Object object)
                 throws JMSException
Specified by:
writeObject in interface BytesMessage
Throws:
JMSException


Licensed to the Apache Software Foundation