|
|||||||||
| Home >> All >> org >> activemq >> io >> [ impl overview ] | PREV NEXT | ||||||||
A
- AbstractDefaultWireFormat - class org.activemq.io.impl.AbstractDefaultWireFormat.
- Default implementation used for Java-Java protocols.
- AbstractDefaultWireFormat() - Constructor for class org.activemq.io.impl.AbstractDefaultWireFormat
- Default Constructor
- AbstractPacketMarshaller - class org.activemq.io.impl.AbstractPacketMarshaller.
- AbstractPacketMarshaller() - Constructor for class org.activemq.io.impl.AbstractPacketMarshaller
- AbstractPacketReader - class org.activemq.io.impl.AbstractPacketReader.
- Allows instances implementing Packet interface to be deserailized
- AbstractPacketReader() - Constructor for class org.activemq.io.impl.AbstractPacketReader
- AbstractPacketWriter - class org.activemq.io.impl.AbstractPacketWriter.
- Allows instances implementing Packet interface to be serailized/deserailized
- AbstractPacketWriter() - Constructor for class org.activemq.io.impl.AbstractPacketWriter
- ActiveMQBytesMessageReader - class org.activemq.io.impl.ActiveMQBytesMessageReader.
- Reads a Message object to a Stream
- ActiveMQBytesMessageReader(AbstractDefaultWireFormat) - Constructor for class org.activemq.io.impl.ActiveMQBytesMessageReader
- ActiveMQBytesMessageReaderTest - class org.activemq.io.impl.ActiveMQBytesMessageReaderTest.
- ActiveMQBytesMessageReaderTest(String) - Constructor for class org.activemq.io.impl.ActiveMQBytesMessageReaderTest
- Constructor for ActiveMQTextMessageReaderTest.
- ActiveMQBytesMessageWriter - class org.activemq.io.impl.ActiveMQBytesMessageWriter.
- Writes a Message object to a Stream
- ActiveMQBytesMessageWriter(AbstractDefaultWireFormat) - Constructor for class org.activemq.io.impl.ActiveMQBytesMessageWriter
- ActiveMQMapMessageReader - class org.activemq.io.impl.ActiveMQMapMessageReader.
- Reads a Message object to a Stream
- ActiveMQMapMessageReader(AbstractDefaultWireFormat) - Constructor for class org.activemq.io.impl.ActiveMQMapMessageReader
- ActiveMQMapMessageReaderTest - class org.activemq.io.impl.ActiveMQMapMessageReaderTest.
- ActiveMQMapMessageReaderTest(String) - Constructor for class org.activemq.io.impl.ActiveMQMapMessageReaderTest
- Constructor for ActiveMQTextMessageReaderTest.
- ActiveMQMapMessageWriter - class org.activemq.io.impl.ActiveMQMapMessageWriter.
- Writes a Message object to a Stream
- ActiveMQMapMessageWriter(AbstractDefaultWireFormat) - Constructor for class org.activemq.io.impl.ActiveMQMapMessageWriter
- ActiveMQMessageReader - class org.activemq.io.impl.ActiveMQMessageReader.
- Writes a ProducerInfo object to a Stream
- ActiveMQMessageReader(AbstractDefaultWireFormat) - Constructor for class org.activemq.io.impl.ActiveMQMessageReader
- ActiveMQMessageReaderTest - class org.activemq.io.impl.ActiveMQMessageReaderTest.
- To change the template for this generated type comment go to Window - Preferences - Java - Code Generation - Code and Comments
- ActiveMQMessageReaderTest(String) - Constructor for class org.activemq.io.impl.ActiveMQMessageReaderTest
- Constructor for ActiveMQMessageReaderTest.
- ActiveMQMessageWriter - class org.activemq.io.impl.ActiveMQMessageWriter.
- Writes a ActiveMQMessage packet to a Stream
- ActiveMQMessageWriter(AbstractDefaultWireFormat) - Constructor for class org.activemq.io.impl.ActiveMQMessageWriter
- ActiveMQObjectMessageReader - class org.activemq.io.impl.ActiveMQObjectMessageReader.
- Reads a Message object to a Stream
- ActiveMQObjectMessageReader(AbstractDefaultWireFormat) - Constructor for class org.activemq.io.impl.ActiveMQObjectMessageReader
- ActiveMQObjectMessageReaderTest - class org.activemq.io.impl.ActiveMQObjectMessageReaderTest.
- ActiveMQObjectMessageReaderTest(String) - Constructor for class org.activemq.io.impl.ActiveMQObjectMessageReaderTest
- Constructor for ActiveMQTextMessageReaderTest.
- ActiveMQObjectMessageWriter - class org.activemq.io.impl.ActiveMQObjectMessageWriter.
- Writes a Message object to a Stream
- ActiveMQObjectMessageWriter(AbstractDefaultWireFormat) - Constructor for class org.activemq.io.impl.ActiveMQObjectMessageWriter
- ActiveMQStreamMessageReader - class org.activemq.io.impl.ActiveMQStreamMessageReader.
- Reads a Message object to a Stream
- ActiveMQStreamMessageReader(AbstractDefaultWireFormat) - Constructor for class org.activemq.io.impl.ActiveMQStreamMessageReader
- ActiveMQStreamMessageReaderTest - class org.activemq.io.impl.ActiveMQStreamMessageReaderTest.
- ActiveMQStreamMessageReaderTest(String) - Constructor for class org.activemq.io.impl.ActiveMQStreamMessageReaderTest
- Constructor for ActiveMQTextMessageReaderTest.
- ActiveMQStreamMessageWriter - class org.activemq.io.impl.ActiveMQStreamMessageWriter.
- Writes a Message object to a Stream
- ActiveMQStreamMessageWriter(AbstractDefaultWireFormat) - Constructor for class org.activemq.io.impl.ActiveMQStreamMessageWriter
- ActiveMQTextMessageReader - class org.activemq.io.impl.ActiveMQTextMessageReader.
- Writes a ProducerInfo object to a Stream
- ActiveMQTextMessageReader(AbstractDefaultWireFormat) - Constructor for class org.activemq.io.impl.ActiveMQTextMessageReader
- ActiveMQTextMessageReaderTest - class org.activemq.io.impl.ActiveMQTextMessageReaderTest.
- ActiveMQTextMessageReaderTest(String) - Constructor for class org.activemq.io.impl.ActiveMQTextMessageReaderTest
- Constructor for ActiveMQTextMessageReaderTest.
- ActiveMQTextMessageWriter - class org.activemq.io.impl.ActiveMQTextMessageWriter.
- Writes a ProducerInfo object to a Stream
- ActiveMQTextMessageWriter(AbstractDefaultWireFormat) - Constructor for class org.activemq.io.impl.ActiveMQTextMessageWriter
- assertPacket(Packet, Packet) - Method in class org.activemq.io.impl.XATransactionInfoReaderTest
- assertValidPacket(Packet) - Method in class org.activemq.io.impl.ReceiptReaderTest
- assertValidPacket(Packet) - Method in class org.activemq.io.impl.TransactionInfoReaderTest
- assertValidPacket(Packet) - Method in class org.activemq.io.impl.XATransactionInfoReaderTest
B
- BrokerAdminCommandReader - class org.activemq.io.impl.BrokerAdminCommandReader.
- Reads a BrokerAdminCommand object from a Stream
- BrokerAdminCommandReader() - Constructor for class org.activemq.io.impl.BrokerAdminCommandReader
- BrokerAdminCommandWriter - class org.activemq.io.impl.BrokerAdminCommandWriter.
- Writes a BrokerAdminCommand object to a Stream
- BrokerAdminCommandWriter() - Constructor for class org.activemq.io.impl.BrokerAdminCommandWriter
- BrokerInfoReader - class org.activemq.io.impl.BrokerInfoReader.
- Reads a ConsumerInfo object from a Stream
- BrokerInfoReader() - Constructor for class org.activemq.io.impl.BrokerInfoReader
- BrokerInfoWriter - class org.activemq.io.impl.BrokerInfoWriter.
- Writes a ConsumerInfo object to a Stream
- BrokerInfoWriter() - Constructor for class org.activemq.io.impl.BrokerInfoWriter
- brokerAdminCommandReader - Variable in class org.activemq.io.impl.AbstractDefaultWireFormat
- brokerAdminCommandWriter - Variable in class org.activemq.io.impl.AbstractDefaultWireFormat
- brokerInfoReader - Variable in class org.activemq.io.impl.AbstractDefaultWireFormat
- brokerInfoWriter - Variable in class org.activemq.io.impl.AbstractDefaultWireFormat
- buildPacket(Packet, DataInput) - Method in class org.activemq.io.impl.AbstractPacketReader
- build a Packet instance from the data input stream
- buildPacket(Packet, DataInput) - Method in class org.activemq.io.impl.ActiveMQMessageReader
- build a Packet instance from the data input stream
- buildPacket(Packet, DataInput) - Method in class org.activemq.io.impl.BrokerAdminCommandReader
- build a Packet instance from the data input stream
- buildPacket(Packet, DataInput) - Method in class org.activemq.io.impl.BrokerInfoReader
- build a Packet instance from the data input stream
- buildPacket(Packet, DataInput) - Method in class org.activemq.io.impl.CachedValueReader
- build a Packet instance from the data input stream
- buildPacket(Packet, DataInput) - Method in class org.activemq.io.impl.CapacityInfoReader
- build a Packet instance from the data input stream
- buildPacket(Packet, DataInput) - Method in class org.activemq.io.impl.CapacityInfoRequestReader
- build a Packet instance from the data input stream
- buildPacket(Packet, DataInput) - Method in class org.activemq.io.impl.CleanupConnectionInfoReader
- build a Packet instance from the data input stream
- buildPacket(Packet, DataInput) - Method in class org.activemq.io.impl.ConnectionInfoReader
- build a Packet instance from the data input stream
- buildPacket(Packet, DataInput) - Method in class org.activemq.io.impl.ConsumerInfoReader
- build a Packet instance from the data input stream
- buildPacket(Packet, DataInput) - Method in class org.activemq.io.impl.DurableUnsubscribeReader
- build a Packet instance from the data input stream
- buildPacket(Packet, DataInput) - Method in class org.activemq.io.impl.IntResponseReceiptReader
- build a Packet instance from the data input stream
- buildPacket(Packet, DataInput) - Method in class org.activemq.io.impl.KeepAliveReader
- build a Packet instance from the data input stream
- buildPacket(Packet, DataInput) - Method in class org.activemq.io.impl.MessageAckReader
- build a Packet instance from the data input stream
- buildPacket(Packet, DataInput) - Method in interface org.activemq.io.impl.PacketReader
- build a Packet instance from the data input stream
- buildPacket(Packet, DataInput) - Method in class org.activemq.io.impl.ProducerInfoReader
- build a Packet instance from the data input stream
- buildPacket(Packet, DataInput) - Method in class org.activemq.io.impl.ReceiptReader
- build a Packet instance from the data input stream
- buildPacket(Packet, DataInput) - Method in class org.activemq.io.impl.ResponseReceiptReader
- build a Packet instance from the data input stream
- buildPacket(Packet, DataInput) - Method in class org.activemq.io.impl.SessionInfoReader
- build a Packet instance from the data input stream
- buildPacket(Packet, DataInput) - Method in class org.activemq.io.impl.TransactionInfoReader
- build a Packet instance from the data input stream
- buildPacket(Packet, DataInput) - Method in class org.activemq.io.impl.WireFormatInfoReader
- build a Packet instance from the data input stream
- buildPacket(Packet, DataInput) - Method in class org.activemq.io.impl.XATransactionInfoReader
- build a Packet instance from the data input stream
- bytesMessageReader - Variable in class org.activemq.io.impl.AbstractDefaultWireFormat
- bytesMessageWriter - Variable in class org.activemq.io.impl.AbstractDefaultWireFormat
C
- CLEAR_CACHE - Static variable in class org.activemq.io.impl.DefaultWireFormat
- CachedValueReader - class org.activemq.io.impl.CachedValueReader.
- Reads a KeepAlive packet from a stream
- CachedValueReader() - Constructor for class org.activemq.io.impl.CachedValueReader
- CachedValueWriter - class org.activemq.io.impl.CachedValueWriter.
- Writes a KeepAlive object to a Stream
- CachedValueWriter() - Constructor for class org.activemq.io.impl.CachedValueWriter
- CapacityInfoReader - class org.activemq.io.impl.CapacityInfoReader.
- Reads a CapacityInfo object from a Stream
- CapacityInfoReader() - Constructor for class org.activemq.io.impl.CapacityInfoReader
- CapacityInfoRequestReader - class org.activemq.io.impl.CapacityInfoRequestReader.
- Reads a CapacityInfoRequest object from a Stream
- CapacityInfoRequestReader() - Constructor for class org.activemq.io.impl.CapacityInfoRequestReader
- CapacityInfoRequestWriter - class org.activemq.io.impl.CapacityInfoRequestWriter.
- Writes a CapacityInfoRequest object to a Stream
- CapacityInfoRequestWriter() - Constructor for class org.activemq.io.impl.CapacityInfoRequestWriter
- CapacityInfoWriter - class org.activemq.io.impl.CapacityInfoWriter.
- Writes a CapacityInfo object to a Stream
- CapacityInfoWriter() - Constructor for class org.activemq.io.impl.CapacityInfoWriter
- CleanupConnectionInfoReader - class org.activemq.io.impl.CleanupConnectionInfoReader.
- Reads a ConsumerInfo object from a Stream
- CleanupConnectionInfoReader() - Constructor for class org.activemq.io.impl.CleanupConnectionInfoReader
- CleanupConnectionInfoWriter - class org.activemq.io.impl.CleanupConnectionInfoWriter.
- Writes a ConsumerInfo object to a Stream
- CleanupConnectionInfoWriter() - Constructor for class org.activemq.io.impl.CleanupConnectionInfoWriter
- ConnectionInfoReader - class org.activemq.io.impl.ConnectionInfoReader.
- Reads a ConnnectionInfo object from a Stream
- ConnectionInfoReader() - Constructor for class org.activemq.io.impl.ConnectionInfoReader
- ConnectionInfoWriter - class org.activemq.io.impl.ConnectionInfoWriter.
- Writes a ConsumerInfo object to a Stream
- ConnectionInfoWriter() - Constructor for class org.activemq.io.impl.ConnectionInfoWriter
- ConsumerInfoReader - class org.activemq.io.impl.ConsumerInfoReader.
- Reads a ConsumerInfo object from a Stream
- ConsumerInfoReader() - Constructor for class org.activemq.io.impl.ConsumerInfoReader
- ConsumerInfoReaderTest - class org.activemq.io.impl.ConsumerInfoReaderTest.
- To change the template for this generated type comment go to Window - Preferences - Java - Code Generation - Code and Comments
- ConsumerInfoReaderTest(String) - Constructor for class org.activemq.io.impl.ConsumerInfoReaderTest
- Constructor for ConsumerInfoReaderTest.
- ConsumerInfoWriter - class org.activemq.io.impl.ConsumerInfoWriter.
- Writes a ConsumerInfo object to a Stream
- ConsumerInfoWriter() - Constructor for class org.activemq.io.impl.ConsumerInfoWriter
- cachedBytesOut - Variable in class org.activemq.io.impl.DefaultWireFormat
- cachedDataOut - Variable in class org.activemq.io.impl.DefaultWireFormat
- cachedKeyGenerator - Variable in class org.activemq.io.impl.DefaultWireFormat
- cachedValueReader - Variable in class org.activemq.io.impl.AbstractDefaultWireFormat
- cachedValueWriter - Variable in class org.activemq.io.impl.AbstractDefaultWireFormat
- canProcessWireFormatVersion(int) - Method in class org.activemq.io.impl.AbstractDefaultWireFormat
- Can this wireformat process packets of this version
- canRead(int) - Method in class org.activemq.io.impl.AbstractPacketReader
- canRead(int) - Method in interface org.activemq.io.impl.PacketReader
- canWrite(Packet) - Method in class org.activemq.io.impl.AbstractPacketMarshaller
- canWrite(Packet) - Method in class org.activemq.io.impl.AbstractPacketWriter
- canWrite(Packet) - Method in interface org.activemq.io.impl.PacketWriter
- capacityInfoReader - Variable in class org.activemq.io.impl.AbstractDefaultWireFormat
- capacityInfoRequestReader - Variable in class org.activemq.io.impl.AbstractDefaultWireFormat
- capacityInfoRequestWriter - Variable in class org.activemq.io.impl.AbstractDefaultWireFormat
- capacityInfoWriter - Variable in class org.activemq.io.impl.AbstractDefaultWireFormat
- cleanupConnectionAndSessionInfoReader - Variable in class org.activemq.io.impl.AbstractDefaultWireFormat
- cleanupConnectionAndSessionInfoWriter - Variable in class org.activemq.io.impl.AbstractDefaultWireFormat
- clientId - Variable in class org.activemq.io.impl.ConsumerInfoReaderTest
- clientId - Variable in class org.activemq.io.impl.ProducerInfoReaderTest
- connectionInfoReader - Variable in class org.activemq.io.impl.AbstractDefaultWireFormat
- connectionInfoWriter - Variable in class org.activemq.io.impl.AbstractDefaultWireFormat
- consumerIDs - Variable in class org.activemq.io.impl.ActiveMQMessageReaderTest
- consumerId - Variable in class org.activemq.io.impl.ConsumerInfoReaderTest
- consumerId - Variable in class org.activemq.io.impl.MessageAckReaderTest
- consumerInfoReader - Variable in class org.activemq.io.impl.AbstractDefaultWireFormat
- consumerInfoWriter - Variable in class org.activemq.io.impl.AbstractDefaultWireFormat
- consumerNo - Variable in class org.activemq.io.impl.ConsumerInfoReaderTest
- copy() - Method in class org.activemq.io.impl.AbstractDefaultWireFormat
- copy() - Method in class org.activemq.io.impl.DefaultWireFormat
- copy() - Method in class org.activemq.io.impl.StatelessDefaultWireFormat
- correlationId - Variable in class org.activemq.io.impl.ReceiptReaderTest
- createNoXidPacket() - Method in class org.activemq.io.impl.XATransactionInfoReaderTest
- createPacket() - Method in class org.activemq.io.impl.ActiveMQBytesMessageReader
- createPacket() - Method in class org.activemq.io.impl.ActiveMQMapMessageReader
- createPacket() - Method in class org.activemq.io.impl.ActiveMQMessageReader
- createPacket() - Method in class org.activemq.io.impl.ActiveMQObjectMessageReader
- createPacket() - Method in class org.activemq.io.impl.ActiveMQStreamMessageReader
- createPacket() - Method in class org.activemq.io.impl.ActiveMQTextMessageReader
- createPacket() - Method in class org.activemq.io.impl.BrokerAdminCommandReader
- createPacket() - Method in class org.activemq.io.impl.BrokerInfoReader
- createPacket() - Method in class org.activemq.io.impl.CachedValueReader
- createPacket() - Method in class org.activemq.io.impl.CapacityInfoReader
- createPacket() - Method in class org.activemq.io.impl.CapacityInfoRequestReader
- createPacket() - Method in class org.activemq.io.impl.CleanupConnectionInfoReader
- createPacket() - Method in class org.activemq.io.impl.ConnectionInfoReader
- createPacket() - Method in class org.activemq.io.impl.ConsumerInfoReader
- createPacket() - Method in class org.activemq.io.impl.DurableUnsubscribeReader
- createPacket() - Method in class org.activemq.io.impl.IntResponseReceiptReader
- createPacket() - Method in class org.activemq.io.impl.KeepAliveReader
- createPacket() - Method in class org.activemq.io.impl.MessageAckReader
- createPacket() - Method in interface org.activemq.io.impl.PacketReader
- createPacket() - Method in class org.activemq.io.impl.ProducerInfoReader
- createPacket() - Method in class org.activemq.io.impl.ReceiptReader
- createPacket() - Method in class org.activemq.io.impl.ReceiptReaderTest
- createPacket() - Method in class org.activemq.io.impl.ResponseReceiptReader
- createPacket() - Method in class org.activemq.io.impl.SessionInfoReader
- createPacket() - Method in class org.activemq.io.impl.TransactionInfoReader
- createPacket() - Method in class org.activemq.io.impl.TransactionInfoReaderTest
- createPacket() - Method in class org.activemq.io.impl.WireFormatInfoReader
- createPacket() - Method in class org.activemq.io.impl.XATransactionInfoReader
- createPacket() - Method in class org.activemq.io.impl.XATransactionInfoReaderTest
- createWireFormat() - Method in class org.activemq.io.impl.DefaultWireFormatTest
- createXidPacket() - Method in class org.activemq.io.impl.XATransactionInfoReaderTest
- currentWireFormatVersion - Variable in class org.activemq.io.impl.AbstractDefaultWireFormat
D
- DefaultWireFormat - class org.activemq.io.impl.DefaultWireFormat.
- This is a stateful AbstractDefaultWireFormat which implements value caching.
- DefaultWireFormat() - Constructor for class org.activemq.io.impl.DefaultWireFormat
- Default Constructor
- DefaultWireFormatTest - class org.activemq.io.impl.DefaultWireFormatTest.
- DefaultWireFormatTest() - Constructor for class org.activemq.io.impl.DefaultWireFormatTest
- DurableUnsubscribeReader - class org.activemq.io.impl.DurableUnsubscribeReader.
- Reads a DurableUnsubscribe object from a Stream
- DurableUnsubscribeReader() - Constructor for class org.activemq.io.impl.DurableUnsubscribeReader
- DurableUnsubscribeWriter - class org.activemq.io.impl.DurableUnsubscribeWriter.
- Writes a DurableUnsubscribe object to a Stream
- DurableUnsubscribeWriter() - Constructor for class org.activemq.io.impl.DurableUnsubscribeWriter
- destination - Variable in class org.activemq.io.impl.ConsumerInfoReaderTest
- destination - Variable in class org.activemq.io.impl.MessageAckReaderTest
- destination - Variable in class org.activemq.io.impl.ProducerInfoReaderTest
- durableUnsubscribeReader - Variable in class org.activemq.io.impl.AbstractDefaultWireFormat
- durableUnsubscribeWriter - Variable in class org.activemq.io.impl.AbstractDefaultWireFormat
E
- entryBrokerName - Variable in class org.activemq.io.impl.ActiveMQMessageReaderTest
- entryClusterName - Variable in class org.activemq.io.impl.ActiveMQMessageReaderTest
- expired - Variable in class org.activemq.io.impl.MessageAckReaderTest
G
- getCurrentWireFormatVersion() - Method in class org.activemq.io.impl.AbstractDefaultWireFormat
- getNextCacheId() - Method in class org.activemq.io.impl.DefaultWireFormat
- getPacketType() - Method in class org.activemq.io.impl.ActiveMQBytesMessageReader
- Return the type of Packet
- getPacketType() - Method in class org.activemq.io.impl.ActiveMQBytesMessageWriter
- Return the type of Packet
- getPacketType() - Method in class org.activemq.io.impl.ActiveMQMapMessageReader
- Return the type of Packet
- getPacketType() - Method in class org.activemq.io.impl.ActiveMQMapMessageWriter
- Return the type of Packet
- getPacketType() - Method in class org.activemq.io.impl.ActiveMQMessageReader
- Return the type of Packet
- getPacketType() - Method in class org.activemq.io.impl.ActiveMQMessageWriter
- Return the type of Packet
- getPacketType() - Method in class org.activemq.io.impl.ActiveMQObjectMessageReader
- Return the type of Packet
- getPacketType() - Method in class org.activemq.io.impl.ActiveMQObjectMessageWriter
- Return the type of Packet
- getPacketType() - Method in class org.activemq.io.impl.ActiveMQStreamMessageReader
- Return the type of Packet
- getPacketType() - Method in class org.activemq.io.impl.ActiveMQStreamMessageWriter
- Return the type of Packet
- getPacketType() - Method in class org.activemq.io.impl.ActiveMQTextMessageReader
- Return the type of Packet
- getPacketType() - Method in class org.activemq.io.impl.ActiveMQTextMessageWriter
- Return the type of Packet
- getPacketType() - Method in class org.activemq.io.impl.BrokerAdminCommandReader
- Return the type of Packet
- getPacketType() - Method in class org.activemq.io.impl.BrokerAdminCommandWriter
- Return the type of Packet
- getPacketType() - Method in class org.activemq.io.impl.BrokerInfoReader
- Return the type of Packet
- getPacketType() - Method in class org.activemq.io.impl.BrokerInfoWriter
- Return the type of Packet
- getPacketType() - Method in class org.activemq.io.impl.CachedValueReader
- Return the type of Packet
- getPacketType() - Method in class org.activemq.io.impl.CachedValueWriter
- Return the type of Packet
- getPacketType() - Method in class org.activemq.io.impl.CapacityInfoReader
- Return the type of Packet
- getPacketType() - Method in class org.activemq.io.impl.CapacityInfoRequestReader
- Return the type of Packet
- getPacketType() - Method in class org.activemq.io.impl.CapacityInfoRequestWriter
- Return the type of Packet
- getPacketType() - Method in class org.activemq.io.impl.CapacityInfoWriter
- Return the type of Packet
- getPacketType() - Method in class org.activemq.io.impl.CleanupConnectionInfoReader
- Return the type of Packet
- getPacketType() - Method in class org.activemq.io.impl.CleanupConnectionInfoWriter
- Return the type of Packet
- getPacketType() - Method in class org.activemq.io.impl.ConnectionInfoReader
- Return the type of Packet
- getPacketType() - Method in class org.activemq.io.impl.ConnectionInfoWriter
- Return the type of Packet
- getPacketType() - Method in class org.activemq.io.impl.ConsumerInfoReader
- Return the type of Packet
- getPacketType() - Method in class org.activemq.io.impl.ConsumerInfoWriter
- Return the type of Packet
- getPacketType() - Method in class org.activemq.io.impl.DurableUnsubscribeReader
- Return the type of Packet
- getPacketType() - Method in class org.activemq.io.impl.DurableUnsubscribeWriter
- Return the type of Packet
- getPacketType() - Method in class org.activemq.io.impl.IntResponseReceiptReader
- Return the type of Packet
- getPacketType() - Method in class org.activemq.io.impl.IntResponseReceiptWriter
- Return the type of Packet
- getPacketType() - Method in class org.activemq.io.impl.KeepAliveReader
- Return the type of Packet
- getPacketType() - Method in class org.activemq.io.impl.KeepAliveWriter
- Return the type of Packet
- getPacketType() - Method in class org.activemq.io.impl.MessageAckReader
- Return the type of Packet
- getPacketType() - Method in class org.activemq.io.impl.MessageAckWriter
- Return the type of Packet
- getPacketType() - Method in interface org.activemq.io.impl.PacketReader
- Return the type of Packet
- getPacketType() - Method in interface org.activemq.io.impl.PacketWriter
- Return the type of Packet
- getPacketType() - Method in class org.activemq.io.impl.ProducerInfoReader
- Return the type of Packet
- getPacketType() - Method in class org.activemq.io.impl.ProducerInfoWriter
- Return the type of Packet
- getPacketType() - Method in class org.activemq.io.impl.ReceiptReader
- Return the type of Packet
- getPacketType() - Method in class org.activemq.io.impl.ReceiptWriter
- Return the type of Packet
- getPacketType() - Method in class org.activemq.io.impl.ResponseReceiptReader
- Return the type of Packet
- getPacketType() - Method in class org.activemq.io.impl.ResponseReceiptWriter
- Return the type of Packet
- getPacketType() - Method in class org.activemq.io.impl.SessionInfoReader
- Return the type of Packet
- getPacketType() - Method in class org.activemq.io.impl.SessionInfoWriter
- Return the type of Packet
- getPacketType() - Method in class org.activemq.io.impl.TransactionInfoReader
- Return the type of Packet
- getPacketType() - Method in class org.activemq.io.impl.TransactionInfoWriter
- Return the type of Packet
- getPacketType() - Method in class org.activemq.io.impl.WireFormatInfoReader
- Return the type of Packet
- getPacketType() - Method in class org.activemq.io.impl.WireFormatInfoWriter
- Return the type of Packet
- getPacketType() - Method in class org.activemq.io.impl.XATransactionInfoReader
- Return the type of Packet
- getPacketType() - Method in class org.activemq.io.impl.XATransactionInfoWriter
- Return the type of Packet
- getValueFromReadCache(short) - Method in class org.activemq.io.impl.AbstractDefaultWireFormat
- getValueFromReadCache(short) - Method in class org.activemq.io.impl.DefaultWireFormat
- getValueFromReadCache(short) - Method in class org.activemq.io.impl.StatelessDefaultWireFormat
- getWireFormatVersion() - Method in class org.activemq.io.impl.AbstractPacketMarshaller
- getWireFormatVersion() - Method in class org.activemq.io.impl.AbstractPacketReader
- getWireFormatVersion() - Method in class org.activemq.io.impl.AbstractPacketWriter
- getWireFormatVersion() - Method in interface org.activemq.io.impl.PacketReader
- getWireFormatVersion() - Method in interface org.activemq.io.impl.PacketWriter
- getWriteCachedKey(Object) - Method in class org.activemq.io.impl.AbstractDefaultWireFormat
- getWriteCachedKey(Object) - Method in class org.activemq.io.impl.DefaultWireFormat
- getWriteCachedKey(Object) - Method in class org.activemq.io.impl.StatelessDefaultWireFormat
- getWriter(Packet) - Method in class org.activemq.io.impl.AbstractDefaultWireFormat
H
- handleCachedValue(CachedValue) - Method in class org.activemq.io.impl.AbstractDefaultWireFormat
- handleCachedValue(CachedValue) - Method in class org.activemq.io.impl.DefaultWireFormat
- handleCachedValue(CachedValue) - Method in class org.activemq.io.impl.StatelessDefaultWireFormat
I
- IntResponseReceiptReader - class org.activemq.io.impl.IntResponseReceiptReader.
- Reads a ConsumerInfo object from a Stream
- IntResponseReceiptReader() - Constructor for class org.activemq.io.impl.IntResponseReceiptReader
- IntResponseReceiptWriter - class org.activemq.io.impl.IntResponseReceiptWriter.
- Writes a ConsumerInfo object to a Stream
- IntResponseReceiptWriter() - Constructor for class org.activemq.io.impl.IntResponseReceiptWriter
- id - Variable in class org.activemq.io.impl.MessageAckReaderTest
- id - Variable in class org.activemq.io.impl.ProducerInfoReaderTest
- id - Variable in class org.activemq.io.impl.ReceiptReaderTest
- initializeMessage(ActiveMQMessage) - Method in class org.activemq.io.impl.ActiveMQMessageReaderTest
- initializeReaders() - Method in class org.activemq.io.impl.AbstractDefaultWireFormat
- initializeWriters() - Method in class org.activemq.io.impl.AbstractDefaultWireFormat
- initiateClientSideProtocol(DataOutputStream, DataInputStream) - Method in class org.activemq.io.impl.AbstractDefaultWireFormat
- Some wire formats require a handshake at start-up
- initiateServerSideProtocol(DataOutputStream, DataInputStream) - Method in class org.activemq.io.impl.AbstractDefaultWireFormat
- Some wire formats require a handshake at start-up
- intReponseReceiptReader - Variable in class org.activemq.io.impl.AbstractDefaultWireFormat
- intReponseReceiptWriter - Variable in class org.activemq.io.impl.AbstractDefaultWireFormat
- internalBytesIn - Variable in class org.activemq.io.impl.DefaultWireFormat
- internalBytesOut - Variable in class org.activemq.io.impl.DefaultWireFormat
- internalDataIn - Variable in class org.activemq.io.impl.DefaultWireFormat
- internalDataOut - Variable in class org.activemq.io.impl.DefaultWireFormat
- isCachingEnabled() - Method in class org.activemq.io.impl.StatelessDefaultWireFormat
J
- jmsClientID - Variable in class org.activemq.io.impl.ActiveMQMessageReaderTest
- jmsCorrelationID - Variable in class org.activemq.io.impl.ActiveMQMessageReaderTest
- jmsDeliveryMode - Variable in class org.activemq.io.impl.ActiveMQMessageReaderTest
- jmsDestination - Variable in class org.activemq.io.impl.ActiveMQMessageReaderTest
- jmsExpiration - Variable in class org.activemq.io.impl.ActiveMQMessageReaderTest
- jmsMessageID - Variable in class org.activemq.io.impl.ActiveMQMessageReaderTest
- jmsPriority - Variable in class org.activemq.io.impl.ActiveMQMessageReaderTest
- jmsRedelivered - Variable in class org.activemq.io.impl.ActiveMQMessageReaderTest
- jmsReplyTo - Variable in class org.activemq.io.impl.ActiveMQMessageReaderTest
- jmsTimestamp - Variable in class org.activemq.io.impl.ActiveMQMessageReaderTest
- jmsType - Variable in class org.activemq.io.impl.ActiveMQMessageReaderTest
K
- KeepAliveReader - class org.activemq.io.impl.KeepAliveReader.
- Reads a KeepAlive packet from a stream
- KeepAliveReader() - Constructor for class org.activemq.io.impl.KeepAliveReader
- KeepAliveWriter - class org.activemq.io.impl.KeepAliveWriter.
- Writes a KeepAlive object to a Stream
- KeepAliveWriter() - Constructor for class org.activemq.io.impl.KeepAliveWriter
- keepAliveReader - Variable in class org.activemq.io.impl.AbstractDefaultWireFormat
- keepAliveWriter - Variable in class org.activemq.io.impl.AbstractDefaultWireFormat
L
- lastWriteValueCacheEvictionPosition - Variable in class org.activemq.io.impl.DefaultWireFormat
- log - Static variable in class org.activemq.io.impl.AbstractDefaultWireFormat
- log - Static variable in class org.activemq.io.impl.ActiveMQMessageWriter
M
- MAX_CACHE_SIZE - Static variable in class org.activemq.io.impl.DefaultWireFormat
- MessageAckReader - class org.activemq.io.impl.MessageAckReader.
- Reads a ConsumerInfo object from a Stream
- MessageAckReader(AbstractDefaultWireFormat) - Constructor for class org.activemq.io.impl.MessageAckReader
- MessageAckReader() - Constructor for class org.activemq.io.impl.MessageAckReader
- MessageAckReaderTest - class org.activemq.io.impl.MessageAckReaderTest.
- To change the template for this generated type comment go to Window - Preferences - Java - Code Generation - Code and Comments
- MessageAckReaderTest(String) - Constructor for class org.activemq.io.impl.MessageAckReaderTest
- Constructor for ProducerInfoReaderTest.
- MessageAckWriter - class org.activemq.io.impl.MessageAckWriter.
- Writes a ConsumerInfo object to a Stream
- MessageAckWriter(AbstractDefaultWireFormat) - Constructor for class org.activemq.io.impl.MessageAckWriter
- MessageAckWriter() - Constructor for class org.activemq.io.impl.MessageAckWriter
- main(String[]) - Static method in class org.activemq.io.impl.ActiveMQBytesMessageReaderTest
- main(String[]) - Static method in class org.activemq.io.impl.ActiveMQMapMessageReaderTest
- main(String[]) - Static method in class org.activemq.io.impl.ActiveMQMessageReaderTest
- main(String[]) - Static method in class org.activemq.io.impl.ActiveMQObjectMessageReaderTest
- main(String[]) - Static method in class org.activemq.io.impl.ActiveMQStreamMessageReaderTest
- main(String[]) - Static method in class org.activemq.io.impl.ActiveMQTextMessageReaderTest
- main(String[]) - Static method in class org.activemq.io.impl.ConsumerInfoReaderTest
- main(String[]) - Static method in class org.activemq.io.impl.MessageAckReaderTest
- main(String[]) - Static method in class org.activemq.io.impl.ProducerInfoReaderTest
- main(String[]) - Static method in class org.activemq.io.impl.ReceiptReaderTest
- main(String[]) - Static method in class org.activemq.io.impl.TransactionInfoReaderTest
- main(String[]) - Static method in class org.activemq.io.impl.XATransactionInfoReaderTest
- mapMessageReader - Variable in class org.activemq.io.impl.AbstractDefaultWireFormat
- mapMessageWriter - Variable in class org.activemq.io.impl.AbstractDefaultWireFormat
- messageAckReader - Variable in class org.activemq.io.impl.AbstractDefaultWireFormat
- messageAckWriter - Variable in class org.activemq.io.impl.AbstractDefaultWireFormat
- messageId - Variable in class org.activemq.io.impl.MessageAckReaderTest
- messageRead - Variable in class org.activemq.io.impl.MessageAckReaderTest
- messageReader - Variable in class org.activemq.io.impl.AbstractDefaultWireFormat
- messageWriter - Variable in class org.activemq.io.impl.AbstractDefaultWireFormat
N
- NULL_VALUE - Static variable in class org.activemq.io.impl.DefaultWireFormat
O
- objectMessageReader - Variable in class org.activemq.io.impl.AbstractDefaultWireFormat
- objectMessageWriter - Variable in class org.activemq.io.impl.AbstractDefaultWireFormat
- org.activemq.io.impl - package org.activemq.io.impl
P
- PacketReader - interface org.activemq.io.impl.PacketReader.
- Allows instances implementing Packet to read from a DataOutputStream
- PacketWriter - interface org.activemq.io.impl.PacketWriter.
- Allows instances implementing Packet to written to a DataOutput
- ProducerInfoReader - class org.activemq.io.impl.ProducerInfoReader.
- Reads a ProducerInfo object from a Stream
- ProducerInfoReader() - Constructor for class org.activemq.io.impl.ProducerInfoReader
- ProducerInfoReaderTest - class org.activemq.io.impl.ProducerInfoReaderTest.
- To change the template for this generated type comment go to Window - Preferences - Java - Code Generation - Code and Comments
- ProducerInfoReaderTest(String) - Constructor for class org.activemq.io.impl.ProducerInfoReaderTest
- Constructor for ProducerInfoReaderTest.
- ProducerInfoWriter - class org.activemq.io.impl.ProducerInfoWriter.
- Writes a ProducerInfo object to a Stream
- ProducerInfoWriter() - Constructor for class org.activemq.io.impl.ProducerInfoWriter
- persistent - Variable in class org.activemq.io.impl.MessageAckReaderTest
- prefetchNumber - Variable in class org.activemq.io.impl.ConsumerInfoReaderTest
- producerInfoReader - Variable in class org.activemq.io.impl.AbstractDefaultWireFormat
- producerInfoWriter - Variable in class org.activemq.io.impl.AbstractDefaultWireFormat
- properties - Variable in class org.activemq.io.impl.ActiveMQMessageReaderTest
R
- ReceiptReader - class org.activemq.io.impl.ReceiptReader.
- Reads a ConsumerInfo object from a Stream
- ReceiptReader() - Constructor for class org.activemq.io.impl.ReceiptReader
- ReceiptReaderTest - class org.activemq.io.impl.ReceiptReaderTest.
- To change the template for this generated type comment go to Window - Preferences - Java - Code Generation - Code and Comments
- ReceiptReaderTest() - Constructor for class org.activemq.io.impl.ReceiptReaderTest
- ReceiptWriter - class org.activemq.io.impl.ReceiptWriter.
- Writes a ConsumerInfo object to a Stream
- ReceiptWriter() - Constructor for class org.activemq.io.impl.ReceiptWriter
- ResponseReceiptReader - class org.activemq.io.impl.ResponseReceiptReader.
- Reads a ConsumerInfo object from a Stream
- ResponseReceiptReader() - Constructor for class org.activemq.io.impl.ResponseReceiptReader
- ResponseReceiptWriter - class org.activemq.io.impl.ResponseReceiptWriter.
- Writes a ConsumerInfo object to a Stream
- ResponseReceiptWriter() - Constructor for class org.activemq.io.impl.ResponseReceiptWriter
- readDestination(DataInput) - Method in class org.activemq.io.impl.AbstractPacketMarshaller
- Reads a destination from the input stream
- readMutex - Variable in class org.activemq.io.impl.DefaultWireFormat
- readObject(DataInput) - Method in class org.activemq.io.impl.AbstractPacketReader
- ;
- readPacket(DataInput, PacketReader) - Method in class org.activemq.io.impl.AbstractDefaultWireFormat
- readPacket(int, DataInput) - Method in class org.activemq.io.impl.AbstractDefaultWireFormat
- readPacket(DataInput, PacketReader) - Method in class org.activemq.io.impl.DefaultWireFormat
- readPacket(DataInput, PacketReader) - Method in class org.activemq.io.impl.StatelessDefaultWireFormat
- readPacket(org.activeio.Packet) - Method in class org.activemq.io.impl.StatelessDefaultWireFormat
- readPacketFromByteArray(byte[]) - Method in class org.activemq.io.impl.AbstractPacketReader
- Deserailizes a Packet from a byte array
- readPacketFromByteArray(byte[]) - Method in interface org.activemq.io.impl.PacketReader
- Deserailizes a Packet from a byte array
- readResolve() - Method in class org.activemq.io.impl.DefaultWireFormat
- readResolve() - Method in class org.activemq.io.impl.StatelessDefaultWireFormat
- readUTF(DataInput) - Method in class org.activemq.io.impl.AbstractPacketReader
- pointless method - but mirrors writer
- readValueCacheArray - Variable in class org.activemq.io.impl.DefaultWireFormat
- readers - Variable in class org.activemq.io.impl.AbstractDefaultWireFormat
- receiptReader - Variable in class org.activemq.io.impl.AbstractDefaultWireFormat
- receiptWriter - Variable in class org.activemq.io.impl.AbstractDefaultWireFormat
- reponseReceiptReader - Variable in class org.activemq.io.impl.AbstractDefaultWireFormat
- reponseReceiptWriter - Variable in class org.activemq.io.impl.AbstractDefaultWireFormat
S
- SessionInfoReader - class org.activemq.io.impl.SessionInfoReader.
- Reads a ConsumerInfo object from a Stream
- SessionInfoReader() - Constructor for class org.activemq.io.impl.SessionInfoReader
- SessionInfoWriter - class org.activemq.io.impl.SessionInfoWriter.
- Writes a ConsumerInfo object to a Stream
- SessionInfoWriter() - Constructor for class org.activemq.io.impl.SessionInfoWriter
- StatelessDefaultWireFormat - class org.activemq.io.impl.StatelessDefaultWireFormat.
- Provides a stateless implementation of AbstractDefaultWireFormat.
- StatelessDefaultWireFormat() - Constructor for class org.activemq.io.impl.StatelessDefaultWireFormat
- selector - Variable in class org.activemq.io.impl.ConsumerInfoReaderTest
- serialVersionUID - Static variable in class org.activemq.io.impl.