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

Quick Search    Search Deep

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

java.lang.Object
  extended byorg.activemq.io.AbstractWireFormat
      extended byorg.activemq.transport.openwire.OpenWireFormatSupport
All Implemented Interfaces:
org.activemq.io.WireFormat

public abstract class OpenWireFormatSupport
extends org.activemq.io.AbstractWireFormat

Base class for the code generated org.activemq.transport.openwire.io.OpenWireFormat

Version:
$Revision: 1.1 $

Field Summary
 
Fields inherited from class org.activemq.io.AbstractWireFormat
cachingEnabled, transportDataIn, transportDataOut
 
Fields inherited from interface org.activemq.io.WireFormat
DEFAULT_MAXIMUM_MESSAGE_SIZE
 
Constructor Summary
OpenWireFormatSupport()
           
 
Method Summary
 boolean canProcessWireFormatVersion(int version)
          Can this wireformat process packets of this version
 org.activemq.io.WireFormat copy()
          Creates a new copy of this wire format so it can be used in another thread/context
 int getCurrentWireFormatVersion()
           
protected abstract  org.activemq.io.impl.AbstractPacketMarshaller getMarshaller(org.activemq.message.Packet packet)
           
 org.activemq.message.Packet readPacket(java.io.DataInput dataIn)
          Reads a packet from the given input stream
protected  org.activemq.message.Packet readPacket(java.io.DataInput dataIn, org.activemq.io.impl.AbstractPacketMarshaller marshaler)
           
 org.activemq.message.Packet writePacket(org.activemq.message.Packet packet, java.io.DataOutput out)
          Writes the packet to the given output stream
 
Methods inherited from class org.activemq.io.AbstractWireFormat
doesSupportMessageCompression, doesSupportMessageFragmentation, fromBytes, fromBytes, getTransportDataIn, getTransportDataOut, initiateClientSideProtocol, initiateServerSideProtocol, isCachingEnabled, readPacket, registerTransportStreams, setCachingEnabled, setTransportDataIn, setTransportDataOut, toBytes, writePacket
 
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.WireFormat
readPacket
 

Constructor Detail

OpenWireFormatSupport

public OpenWireFormatSupport()
Method Detail

readPacket

public org.activemq.message.Packet readPacket(java.io.DataInput dataIn)
                                       throws java.io.IOException
Description copied from interface: org.activemq.io.WireFormat
Reads a packet from the given input stream


canProcessWireFormatVersion

public boolean canProcessWireFormatVersion(int version)
Description copied from interface: org.activemq.io.WireFormat
Can this wireformat process packets of this version


copy

public org.activemq.io.WireFormat copy()
Description copied from interface: org.activemq.io.WireFormat
Creates a new copy of this wire format so it can be used in another thread/context


getCurrentWireFormatVersion

public int getCurrentWireFormatVersion()

writePacket

public org.activemq.message.Packet writePacket(org.activemq.message.Packet packet,
                                               java.io.DataOutput out)
                                        throws java.io.IOException,
                                               javax.jms.JMSException
Description copied from interface: org.activemq.io.WireFormat
Writes the packet to the given output stream


readPacket

protected org.activemq.message.Packet readPacket(java.io.DataInput dataIn,
                                                 org.activemq.io.impl.AbstractPacketMarshaller marshaler)
                                          throws java.io.IOException

getMarshaller

protected abstract org.activemq.io.impl.AbstractPacketMarshaller getMarshaller(org.activemq.message.Packet packet)