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 StatelessDefaultWireFormat  

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

All Implemented Interfaces:

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

---

public class StatelessDefaultWireFormat

extends AbstractDefaultWireFormat

Provides a stateless implementation of AbstractDefaultWireFormat. Safe for use by multiple threads and incurs no locking overhead.

Version:

$Revision: 1.1.1.1 $

---

Field Summary
private static long	serialVersionUID

 

Fields inherited from class org.activemq.io.impl.AbstractDefaultWireFormat

brokerAdminCommandReader, brokerAdminCommandWriter, brokerInfoReader, brokerInfoWriter, bytesMessageReader, bytesMessageWriter, cachedValueReader, cachedValueWriter, capacityInfoReader, capacityInfoRequestReader, capacityInfoRequestWriter, capacityInfoWriter, cleanupConnectionAndSessionInfoReader, cleanupConnectionAndSessionInfoWriter, connectionInfoReader, connectionInfoWriter, consumerInfoReader, consumerInfoWriter, currentWireFormatVersion, durableUnsubscribeReader, durableUnsubscribeWriter, intReponseReceiptReader, intReponseReceiptWriter, keepAliveReader, keepAliveWriter, mapMessageReader, mapMessageWriter, messageAckReader, messageAckWriter, messageReader, messageWriter, objectMessageReader, objectMessageWriter, producerInfoReader, producerInfoWriter, receiptReader, receiptWriter, reponseReceiptReader, reponseReceiptWriter, sessionInfoReader, sessionInfoWriter, streamMessageReader, streamMessageWriter, textMessageReader, textMessageWriter, transactionInfoReader, transactionInfoWriter, WIRE_FORMAT_VERSION, wireFormatInfoReader, wireFormatInfoWriter, xaTransactionInfoReader, 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

StatelessDefaultWireFormat()

 

Method Summary
org.activemq.io.WireFormat	copy()           Creates a new copy of this wire format so it can be used in another thread/context
java.lang.Object	getValueFromReadCache(short key)
(package private)  short	getWriteCachedKey(java.lang.Object value)
protected  void	handleCachedValue(org.activemq.message.CachedValue cv)
boolean	isCachingEnabled()
protected  org.activemq.message.Packet	readPacket(java.io.DataInput dataIn, PacketReader reader)
org.activemq.message.Packet	readPacket(org.activeio.Packet dataIn)
private  java.lang.Object	readResolve()
byte[]	toBytes(org.activemq.message.Packet packet)           A helper method which converts a packet into a byte array Overrides the WireFormat to make use of the internal BytesOutputStream
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.impl.AbstractDefaultWireFormat

canProcessWireFormatVersion, getCurrentWireFormatVersion, getWriter, initiateClientSideProtocol, initiateServerSideProtocol, readPacket, setCurrentWireFormatVersion

 

Methods inherited from class org.activemq.io.AbstractWireFormat

doesSupportMessageCompression, doesSupportMessageFragmentation, fromBytes, fromBytes, getTransportDataIn, getTransportDataOut, initiateClientSideProtocol, initiateServerSideProtocol, 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

serialVersionUID

private static final long serialVersionUID

See Also:

Constant Field Values

Constructor Detail

StatelessDefaultWireFormat

public StatelessDefaultWireFormat()

Method Detail

writePacket

public 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

Specified by:

writePacket in class AbstractDefaultWireFormat

---

toBytes

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

A helper method which converts a packet into a byte array Overrides the WireFormat to make use of the internal BytesOutputStream

Specified by:

toBytes in interface org.activemq.io.WireFormat

Specified by:

toBytes in class AbstractDefaultWireFormat

---

readPacket

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

Specified by:

readPacket in class AbstractDefaultWireFormat

---

readPacket

public org.activemq.message.Packet readPacket(org.activeio.Packet dataIn)
                                       throws java.io.IOException

---

handleCachedValue

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

Specified by:

handleCachedValue in class AbstractDefaultWireFormat

---

getValueFromReadCache

public java.lang.Object getValueFromReadCache(short key)

Specified by:

getValueFromReadCache in class AbstractDefaultWireFormat

---

getWriteCachedKey

short getWriteCachedKey(java.lang.Object value)

Specified by:

getWriteCachedKey in class AbstractDefaultWireFormat

---

isCachingEnabled

public boolean isCachingEnabled()

---

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

Specified by:

copy in interface org.activemq.io.WireFormat

Specified by:

copy in class AbstractDefaultWireFormat

---

readResolve

private java.lang.Object readResolve()
                              throws java.io.ObjectStreamException

---

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

---