Overview  Package   Class  Use  Deprecated  Index
Home >> All >> org >> activemq >> io >> [ impl overview ]	PREV CLASS  NEXT CLASS
SUMMARY:  JAVADOC |  SOURCE |  DOWNLOAD | NESTED | FIELD | CONSTR | METHOD	DETAIL: FIELD | CONSTR | METHOD

---

org.activemq.io.impl
Class AbstractDefaultWireFormat  

java.lang.Object
  org.activemq.io.AbstractWireFormat
      org.activemq.io.impl.AbstractDefaultWireFormat

All Implemented Interfaces:

java.io.Serializable, org.activemq.io.WireFormat

Direct Known Subclasses:

DefaultWireFormat, StatelessDefaultWireFormat

---

public abstract class AbstractDefaultWireFormat

extends org.activemq.io.AbstractWireFormat

implements java.io.Serializable

Default implementation used for Java-Java protocols. When talking to non-Java nodes we may use a different wire format.

Version:

$Revision: 1.1.1.1 $

---

Field Summary
protected  PacketReader	brokerAdminCommandReader
protected  PacketWriter	brokerAdminCommandWriter
protected  PacketReader	brokerInfoReader
protected  PacketWriter	brokerInfoWriter
protected  PacketReader	bytesMessageReader
protected  PacketWriter	bytesMessageWriter
protected  PacketReader	cachedValueReader
protected  PacketWriter	cachedValueWriter
protected  PacketReader	capacityInfoReader
protected  PacketReader	capacityInfoRequestReader
protected  PacketWriter	capacityInfoRequestWriter
protected  PacketWriter	capacityInfoWriter
protected  PacketReader	cleanupConnectionAndSessionInfoReader
protected  PacketWriter	cleanupConnectionAndSessionInfoWriter
protected  PacketReader	connectionInfoReader
protected  PacketWriter	connectionInfoWriter
protected  PacketReader	consumerInfoReader
protected  PacketWriter	consumerInfoWriter
protected  int	currentWireFormatVersion
protected  PacketReader	durableUnsubscribeReader
protected  PacketWriter	durableUnsubscribeWriter
protected  PacketReader	intReponseReceiptReader
protected  PacketWriter	intReponseReceiptWriter
protected  PacketReader	keepAliveReader
protected  PacketWriter	keepAliveWriter
private static org.apache.commons.logging.Log	log
protected  PacketReader	mapMessageReader
protected  PacketWriter	mapMessageWriter
protected  PacketReader	messageAckReader
protected  PacketWriter	messageAckWriter
protected  PacketReader	messageReader
protected  PacketWriter	messageWriter
protected  PacketReader	objectMessageReader
protected  PacketWriter	objectMessageWriter
protected  PacketReader	producerInfoReader
protected  PacketWriter	producerInfoWriter
private  java.util.List	readers
protected  PacketReader	receiptReader
protected  PacketWriter	receiptWriter
protected  PacketReader	reponseReceiptReader
protected  PacketWriter	reponseReceiptWriter
protected  PacketReader	sessionInfoReader
protected  PacketWriter	sessionInfoWriter
protected  PacketReader	streamMessageReader
protected  PacketWriter	streamMessageWriter
protected  PacketReader	textMessageReader
protected  PacketWriter	textMessageWriter
protected  PacketReader	transactionInfoReader
protected  PacketWriter	transactionInfoWriter
static int	WIRE_FORMAT_VERSION           Current wire format version for this implementation
protected  PacketReader	wireFormatInfoReader
protected  PacketWriter	wireFormatInfoWriter
private  java.util.List	writers
protected  PacketReader	xaTransactionInfoReader
protected  PacketWriter	xaTransactionInfoWriter

 

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

AbstractDefaultWireFormat()           Default Constructor

 

Method Summary
boolean	canProcessWireFormatVersion(int version)           Can this wireformat process packets of this version
abstract  org.activemq.io.WireFormat	copy()           Creates a new copy of this wire format so it can be used in another thread/context
int	getCurrentWireFormatVersion()
abstract  java.lang.Object	getValueFromReadCache(short key)
(package private) abstract  short	getWriteCachedKey(java.lang.Object value)
protected  PacketWriter	getWriter(org.activemq.message.Packet packet)
protected abstract  void	handleCachedValue(org.activemq.message.CachedValue cv)
private  void	initializeReaders()
private  void	initializeWriters()
void	initiateClientSideProtocol(java.io.DataOutputStream dataOut, java.io.DataInputStream dataIn)           Some wire formats require a handshake at start-up
void	initiateServerSideProtocol(java.io.DataOutputStream dataOut, java.io.DataInputStream dataIn)           Some wire formats require a handshake at start-up
protected abstract  org.activemq.message.Packet	readPacket(java.io.DataInput dataIn, PacketReader reader)
org.activemq.message.Packet	readPacket(int firstByte, java.io.DataInput dataIn)           A helper method for working with sockets where the first byte is read first, then the rest of the message is read.
void	setCurrentWireFormatVersion(int version)           set the current version
abstract  byte[]	toBytes(org.activemq.message.Packet packet)           A helper method which converts a packet into a byte array
abstract  org.activemq.message.Packet	writePacket(org.activemq.message.Packet packet, java.io.DataOutput dataOut)           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, readPacket, registerTransportStreams, setCachingEnabled, setTransportDataIn, setTransportDataOut, writePacket

 

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

 

Field Detail

WIRE_FORMAT_VERSION

public static final int WIRE_FORMAT_VERSION

Current wire format version for this implementation

See Also:

Constant Field Values

---

log

private static final org.apache.commons.logging.Log log

---

messageReader

protected transient PacketReader messageReader

---

textMessageReader

protected transient PacketReader textMessageReader

---

objectMessageReader

protected transient PacketReader objectMessageReader

---

bytesMessageReader

protected transient PacketReader bytesMessageReader

---

streamMessageReader

protected transient PacketReader streamMessageReader

---

mapMessageReader

protected transient PacketReader mapMessageReader

---

messageAckReader

protected transient PacketReader messageAckReader

---

receiptReader

protected transient PacketReader receiptReader

---

consumerInfoReader

protected transient PacketReader consumerInfoReader

---

producerInfoReader

protected transient PacketReader producerInfoReader

---

transactionInfoReader

protected transient PacketReader transactionInfoReader

---

xaTransactionInfoReader

protected transient PacketReader xaTransactionInfoReader

---

brokerInfoReader

protected transient PacketReader brokerInfoReader

---

connectionInfoReader

protected transient PacketReader connectionInfoReader

---

sessionInfoReader

protected transient PacketReader sessionInfoReader

---

durableUnsubscribeReader

protected transient PacketReader durableUnsubscribeReader

---

reponseReceiptReader

protected transient PacketReader reponseReceiptReader

---

intReponseReceiptReader

protected transient PacketReader intReponseReceiptReader

---

capacityInfoReader

protected transient PacketReader capacityInfoReader

---

capacityInfoRequestReader

protected transient PacketReader capacityInfoRequestReader

---

wireFormatInfoReader

protected transient PacketReader wireFormatInfoReader

---

keepAliveReader

protected transient PacketReader keepAliveReader

---

brokerAdminCommandReader

protected transient PacketReader brokerAdminCommandReader

---

cachedValueReader

protected transient PacketReader cachedValueReader

---

cleanupConnectionAndSessionInfoReader

protected transient PacketReader cleanupConnectionAndSessionInfoReader

---

messageWriter

protected transient PacketWriter messageWriter

---

textMessageWriter

protected transient PacketWriter textMessageWriter

---

objectMessageWriter

protected transient PacketWriter objectMessageWriter

---

bytesMessageWriter

protected transient PacketWriter bytesMessageWriter

---

streamMessageWriter

protected transient PacketWriter streamMessageWriter

---

mapMessageWriter

protected transient PacketWriter mapMessageWriter

---

messageAckWriter

protected transient PacketWriter messageAckWriter

---

receiptWriter

protected transient PacketWriter receiptWriter

---

consumerInfoWriter

protected transient PacketWriter consumerInfoWriter

---

producerInfoWriter

protected transient PacketWriter producerInfoWriter

---

transactionInfoWriter

protected transient PacketWriter transactionInfoWriter

---

xaTransactionInfoWriter

protected transient PacketWriter xaTransactionInfoWriter

---

brokerInfoWriter

protected transient PacketWriter brokerInfoWriter

---

connectionInfoWriter

protected transient PacketWriter connectionInfoWriter

---

sessionInfoWriter

protected transient PacketWriter sessionInfoWriter

---

durableUnsubscribeWriter

protected transient PacketWriter durableUnsubscribeWriter

---

reponseReceiptWriter

protected transient PacketWriter reponseReceiptWriter

---

intReponseReceiptWriter

protected transient PacketWriter intReponseReceiptWriter

---

capacityInfoWriter

protected transient PacketWriter capacityInfoWriter

---

capacityInfoRequestWriter

protected transient PacketWriter capacityInfoRequestWriter

---

wireFormatInfoWriter

protected transient PacketWriter wireFormatInfoWriter

---

keepAliveWriter

protected transient PacketWriter keepAliveWriter

---

brokerAdminCommandWriter

protected transient PacketWriter brokerAdminCommandWriter

---

cachedValueWriter

protected transient PacketWriter cachedValueWriter

---

cleanupConnectionAndSessionInfoWriter

protected transient PacketWriter cleanupConnectionAndSessionInfoWriter

---

readers

private java.util.List readers

---

writers

private java.util.List writers

---

currentWireFormatVersion

protected transient int currentWireFormatVersion

Constructor Detail

AbstractDefaultWireFormat

public AbstractDefaultWireFormat()

Default Constructor

Method Detail

toBytes

public abstract byte[] toBytes(org.activemq.message.Packet packet)
                        throws java.io.IOException

Description copied from class: org.activemq.io.AbstractWireFormat

A helper method which converts a packet into a byte array

Specified by:

toBytes in interface org.activemq.io.WireFormat

---

writePacket

public abstract org.activemq.message.Packet writePacket(org.activemq.message.Packet packet,
                                                        java.io.DataOutput dataOut)
                                                 throws java.io.IOException

Description copied from interface: org.activemq.io.WireFormat

Writes the packet to the given output stream

Specified by:

writePacket in interface org.activemq.io.WireFormat

---

readPacket

protected abstract org.activemq.message.Packet readPacket(java.io.DataInput dataIn,
                                                          PacketReader reader)
                                                   throws java.io.IOException

---

handleCachedValue

protected abstract void handleCachedValue(org.activemq.message.CachedValue cv)

---

getValueFromReadCache

public abstract java.lang.Object getValueFromReadCache(short key)

---

getWriteCachedKey

abstract short getWriteCachedKey(java.lang.Object value)
                          throws java.io.IOException

---

initiateClientSideProtocol

public void initiateClientSideProtocol(java.io.DataOutputStream dataOut,
                                       java.io.DataInputStream dataIn)
                                throws javax.jms.JMSException

Some wire formats require a handshake at start-up

---

initiateServerSideProtocol

public void initiateServerSideProtocol(java.io.DataOutputStream dataOut,
                                       java.io.DataInputStream dataIn)
                                throws javax.jms.JMSException

Some wire formats require a handshake at start-up

---

copy

public abstract 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

Specified by:

copy in interface org.activemq.io.WireFormat

---

readPacket

public org.activemq.message.Packet readPacket(int firstByte,
                                              java.io.DataInput dataIn)
                                       throws java.io.IOException

Description copied from interface: org.activemq.io.WireFormat

A helper method for working with sockets where the first byte is read first, then the rest of the message is read.

Its common when dealing with sockets to have different timeout semantics until the first non-zero byte is read of a message, after which time a zero timeout is used.

Specified by:

readPacket in interface org.activemq.io.WireFormat

---

getWriter

protected PacketWriter getWriter(org.activemq.message.Packet packet)
                          throws java.io.IOException

---

canProcessWireFormatVersion

public boolean canProcessWireFormatVersion(int version)

Can this wireformat process packets of this version

Specified by:

canProcessWireFormatVersion in interface org.activemq.io.WireFormat

---

getCurrentWireFormatVersion

public int getCurrentWireFormatVersion()

Specified by:

getCurrentWireFormatVersion in interface org.activemq.io.WireFormat

---

setCurrentWireFormatVersion

public void setCurrentWireFormatVersion(int version)

set the current version

---

initializeReaders

private void initializeReaders()

---

initializeWriters

private void initializeWriters()

---

Overview  Package   Class  Use  Deprecated  Index
Home >> All >> org >> activemq >> io >> [ impl overview ]	PREV CLASS  NEXT CLASS
SUMMARY:  JAVADOC |  SOURCE |  DOWNLOAD | NESTED | FIELD | CONSTR | METHOD	DETAIL: FIELD | CONSTR | METHOD

---