org.apache.qpid.client.message
Class AbstractBytesTypedMessage

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.AbstractBytesTypedMessage
All Implemented Interfaces:
Message
Direct Known Subclasses:
JMSMapMessage, JMSStreamMessage

public abstract class AbstractBytesTypedMessage
extends AbstractBytesMessage


Field Summary
protected static byte BOOLEAN_TYPE
           
protected static byte BYTE_TYPE
           
protected static byte BYTEARRAY_TYPE
           
protected static byte CHAR_TYPE
           
protected static byte DOUBLE_TYPE
           
protected static byte FLOAT_TYPE
           
protected static byte INT_TYPE
           
protected static byte LONG_TYPE
           
protected static byte NULL_STRING_TYPE
           
protected static byte SHORT_TYPE
           
protected static byte STRING_TYPE
           
 
Fields inherited from class org.apache.qpid.client.message.AbstractJMSMessage
_changedData, _data, _delegate, _readableMessage
 
Fields inherited from interface org.apache.qpid.jms.Message
JMS_TYPE
 
Fields inherited from interface javax.jms.Message
DEFAULT_DELIVERY_MODE, DEFAULT_PRIORITY, DEFAULT_TIME_TO_LIVE
 
Constructor Summary
AbstractBytesTypedMessage(AMQMessageDelegate delegate, org.apache.mina.common.ByteBuffer data)
           
AbstractBytesTypedMessage(AMQMessageDelegateFactory delegateFactory)
           
AbstractBytesTypedMessage(AMQMessageDelegateFactory delegateFactory, org.apache.mina.common.ByteBuffer data)
          Construct a stream message with existing data.
 
Method Summary
protected  boolean readBoolean()
           
protected  byte readByte()
           
protected  int readBytes(byte[] bytes)
           
protected  char readChar()
          Note that this method reads a unicode character as two bytes from the stream
protected  double readDouble()
           
protected  float readFloat()
           
protected  int readInt()
           
protected  int readIntImpl()
           
protected  long readLong()
           
protected  Object readObject()
           
protected  short readShort()
           
protected  String readString()
           
protected  String readStringImpl()
           
protected  byte readWireType()
           
protected  void writeBoolean(boolean b)
           
protected  void writeByte(byte b)
           
protected  void writeBytes(byte[] bytes)
           
protected  void writeBytes(byte[] bytes, int offset, int length)
           
protected  void writeChar(char c)
           
protected  void writeDouble(double v)
           
protected  void writeFloat(float v)
           
protected  void writeInt(int i)
           
protected  void writeIntImpl(int i)
           
protected  void writeLong(long l)
           
protected  void writeObject(Object object)
           
protected  void writeShort(short i)
           
protected  void writeString(String string)
           
protected  void writeStringImpl(String string)
           
protected  void writeTypeDiscriminator(byte type)
           
 
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, getMimeType, getObjectProperty, getPropertyNames, getReplyToString, getShortProperty, getStringProperty, prepareForSending, propertyExists, receivedFromServer, removeProperty, reset, 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
 

Field Detail

BOOLEAN_TYPE

protected static final byte BOOLEAN_TYPE
See Also:
Constant Field Values

BYTE_TYPE

protected static final byte BYTE_TYPE
See Also:
Constant Field Values

BYTEARRAY_TYPE

protected static final byte BYTEARRAY_TYPE
See Also:
Constant Field Values

SHORT_TYPE

protected static final byte SHORT_TYPE
See Also:
Constant Field Values

CHAR_TYPE

protected static final byte CHAR_TYPE
See Also:
Constant Field Values

INT_TYPE

protected static final byte INT_TYPE
See Also:
Constant Field Values

LONG_TYPE

protected static final byte LONG_TYPE
See Also:
Constant Field Values

FLOAT_TYPE

protected static final byte FLOAT_TYPE
See Also:
Constant Field Values

DOUBLE_TYPE

protected static final byte DOUBLE_TYPE
See Also:
Constant Field Values

STRING_TYPE

protected static final byte STRING_TYPE
See Also:
Constant Field Values

NULL_STRING_TYPE

protected static final byte NULL_STRING_TYPE
See Also:
Constant Field Values
Constructor Detail

AbstractBytesTypedMessage

AbstractBytesTypedMessage(AMQMessageDelegateFactory delegateFactory)

AbstractBytesTypedMessage

AbstractBytesTypedMessage(AMQMessageDelegateFactory delegateFactory,
                          org.apache.mina.common.ByteBuffer data)
Construct a stream 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

AbstractBytesTypedMessage

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

readWireType

protected byte readWireType()
                     throws MessageFormatException,
                            MessageEOFException,
                            MessageNotReadableException
Throws:
MessageFormatException
MessageEOFException
MessageNotReadableException

writeTypeDiscriminator

protected void writeTypeDiscriminator(byte type)
                               throws MessageNotWriteableException
Throws:
MessageNotWriteableException

readBoolean

protected boolean readBoolean()
                       throws JMSException
Throws:
JMSException

readByte

protected byte readByte()
                 throws JMSException
Throws:
JMSException

readShort

protected short readShort()
                   throws JMSException
Throws:
JMSException

readChar

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

Returns:
the character read from the stream
Throws:
JMSException

readInt

protected int readInt()
               throws JMSException
Throws:
JMSException

readIntImpl

protected int readIntImpl()

readLong

protected long readLong()
                 throws JMSException
Throws:
JMSException

readFloat

protected float readFloat()
                   throws JMSException
Throws:
JMSException

readDouble

protected double readDouble()
                     throws JMSException
Throws:
JMSException

readString

protected String readString()
                     throws JMSException
Throws:
JMSException

readStringImpl

protected String readStringImpl()
                         throws JMSException
Throws:
JMSException

readBytes

protected int readBytes(byte[] bytes)
                 throws JMSException
Throws:
JMSException

readObject

protected Object readObject()
                     throws JMSException
Throws:
JMSException

writeBoolean

protected void writeBoolean(boolean b)
                     throws JMSException
Throws:
JMSException

writeByte

protected void writeByte(byte b)
                  throws JMSException
Throws:
JMSException

writeShort

protected void writeShort(short i)
                   throws JMSException
Throws:
JMSException

writeChar

protected void writeChar(char c)
                  throws JMSException
Throws:
JMSException

writeInt

protected void writeInt(int i)
                 throws JMSException
Throws:
JMSException

writeIntImpl

protected void writeIntImpl(int i)

writeLong

protected void writeLong(long l)
                  throws JMSException
Throws:
JMSException

writeFloat

protected void writeFloat(float v)
                   throws JMSException
Throws:
JMSException

writeDouble

protected void writeDouble(double v)
                    throws JMSException
Throws:
JMSException

writeString

protected void writeString(String string)
                    throws JMSException
Throws:
JMSException

writeStringImpl

protected void writeStringImpl(String string)
                        throws CharacterCodingException
Throws:
CharacterCodingException

writeBytes

protected void writeBytes(byte[] bytes)
                   throws JMSException
Throws:
JMSException

writeBytes

protected void writeBytes(byte[] bytes,
                          int offset,
                          int length)
                   throws JMSException
Throws:
JMSException

writeObject

protected void writeObject(Object object)
                    throws JMSException
Throws:
JMSException


Licensed to the Apache Software Foundation