Docjar: A Java Source and Docuemnt Enginecom.*    java.*    javax.*    org.*    all    new    plug-in

Quick Search    Search Deep

org.activemq.transport.openwire
Class OpenWirePacketMarshallerSupport  view OpenWirePacketMarshallerSupport download OpenWirePacketMarshallerSupport.java

java.lang.Object
  extended byorg.activemq.io.impl.AbstractPacketReader
      extended byorg.activemq.io.impl.AbstractPacketMarshaller
          extended byorg.activemq.transport.openwire.OpenWirePacketMarshallerSupport
All Implemented Interfaces:
org.activemq.io.impl.PacketReader, org.activemq.io.impl.PacketWriter

public abstract class OpenWirePacketMarshallerSupport
extends org.activemq.io.impl.AbstractPacketMarshaller

Version:
$Revision: 1.1 $

Field Summary
 
Fields inherited from class org.activemq.io.impl.AbstractPacketMarshaller
wireFormatVersion
 
Constructor Summary
OpenWirePacketMarshallerSupport()
           
 
Method Summary
 void buildPacket(org.activemq.message.Packet p, java.io.DataInput dataIn)
          build a Packet instance from the data input stream
protected  boolean readBoolean(java.io.DataInput dataIn)
           
protected  byte[] readBytes(java.io.DataInput dataIn)
           
protected  org.activemq.message.ActiveMQDestination readDestination(java.io.DataInput dataIn)
          Reads a destination from the input stream
 java.util.Properties readProperties(java.io.DataInput dataIn)
           
protected  java.lang.String readString(java.io.DataInput dataIn)
           
protected  void writeBoolean(boolean value, java.io.DataOutput dataOut)
           
protected  void writeBytes(byte[] data, java.io.DataOutput dataOut)
           
protected  void writeDestination(org.activemq.message.ActiveMQDestination destination, java.io.DataOutput dataOut)
          Writes the given destination to the stream
protected  void writeDestination(javax.jms.Destination destination, java.io.DataOutput dataOut)
           
 void writePacket(org.activemq.message.Packet packet, java.io.DataOutput dataOut)
          Write a Packet instance to data output stream
 void writeProperties(java.util.Map map, java.io.DataOutput dataOut)
           
 void writeProperties(java.util.Properties properties, java.io.DataOutput dataOut)
           
protected  void writeString(java.lang.String text, java.io.DataOutput dataOut)
           
 
Methods inherited from class org.activemq.io.impl.AbstractPacketMarshaller
canWrite, getWireFormatVersion, setWireFormatVersion, writeObject, writePacketToByteArray, writeUTF
 
Methods inherited from class org.activemq.io.impl.AbstractPacketReader
canRead, readObject, readPacketFromByteArray, readUTF
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 
Methods inherited from interface org.activemq.io.impl.PacketWriter
getPacketType
 
Methods inherited from interface org.activemq.io.impl.PacketReader
createPacket, getPacketType
 

Constructor Detail

OpenWirePacketMarshallerSupport

public OpenWirePacketMarshallerSupport()
Method Detail

writePacket

public void writePacket(org.activemq.message.Packet packet,
                        java.io.DataOutput dataOut)
                 throws java.io.IOException
Description copied from class: org.activemq.io.impl.AbstractPacketMarshaller
Write a Packet instance to data output stream


buildPacket

public void buildPacket(org.activemq.message.Packet p,
                        java.io.DataInput dataIn)
                 throws java.io.IOException
Description copied from class: org.activemq.io.impl.AbstractPacketReader
build a Packet instance from the data input stream


writeProperties

public void writeProperties(java.util.Map map,
                            java.io.DataOutput dataOut)
                     throws java.io.IOException

writeProperties

public void writeProperties(java.util.Properties properties,
                            java.io.DataOutput dataOut)
                     throws java.io.IOException

readProperties

public java.util.Properties readProperties(java.io.DataInput dataIn)
                                    throws java.io.IOException

readDestination

protected org.activemq.message.ActiveMQDestination readDestination(java.io.DataInput dataIn)
                                                            throws java.io.IOException
Description copied from class: org.activemq.io.impl.AbstractPacketMarshaller
Reads a destination from the input stream


writeDestination

protected void writeDestination(javax.jms.Destination destination,
                                java.io.DataOutput dataOut)
                         throws java.io.IOException

writeDestination

protected void writeDestination(org.activemq.message.ActiveMQDestination destination,
                                java.io.DataOutput dataOut)
                         throws java.io.IOException
Description copied from class: org.activemq.io.impl.AbstractPacketMarshaller
Writes the given destination to the stream


readString

protected java.lang.String readString(java.io.DataInput dataIn)
                               throws java.io.IOException

writeString

protected void writeString(java.lang.String text,
                           java.io.DataOutput dataOut)
                    throws java.io.IOException

readBytes

protected byte[] readBytes(java.io.DataInput dataIn)
                    throws java.io.IOException

writeBytes

protected void writeBytes(byte[] data,
                          java.io.DataOutput dataOut)
                   throws java.io.IOException

writeBoolean

protected void writeBoolean(boolean value,
                            java.io.DataOutput dataOut)
                     throws java.io.IOException

readBoolean

protected boolean readBoolean(java.io.DataInput dataIn)
                       throws java.io.IOException