Overview | Package | Class | Use | Tree | Deprecated | Index | Help
PREV NEXT | FRAMES NO FRAMES

## Uses of Interface
org.codehaus.activemq.message.Packet

Packages that use Packet
org.codehaus.activemq | The core JMS client implementation classes
org.codehaus.activemq.broker.impl | The default implementation of the JMS Broker
org.codehaus.activemq.message | Message implementations
org.codehaus.activemq.message.util |
org.codehaus.activemq.service.impl | Default implementations of the services
org.codehaus.activemq.store.howl | Message persistence using a high performance transaction log via implemented using Howl whichi is used for short term persistence with longer term storage being used at checkpoints.
org.codehaus.activemq.transport | The transport abstraction layer for sending and receiving Packets over a network
org.codehaus.activemq.transport.composite | A Composite Pattern implementation of TransportChannel allowing a client to connect randomly to one of a number of possible destinations, cycling through them until a connection is established.
org.codehaus.activemq.transport.ember | An implementation of the transport layer using EmberIO for efficient NIO
org.codehaus.activemq.transport.gnet | An implementation of the transport layer using the Geronimo networking layer.
org.codehaus.activemq.transport.jabber |
org.codehaus.activemq.transport.jgroups | An implementation of the transport layer using JGroups
org.codehaus.activemq.transport.jrms | An implementation of the transport layer using Sun's reliable multicast library
org.codehaus.activemq.transport.reliable |
org.codehaus.activemq.transport.tcp | An implementation of the transport layer using TCP/IP sockets
org.codehaus.activemq.transport.udp | An implementation of the transport layer using UDP
org.codehaus.activemq.transport.vm | An implementation of the transport layer using intra-JVM communication

Uses of Packet in org.codehaus.activemq

Methods in org.codehaus.activemq with parameters of type Packet
`boolean` | `ActiveMQMessageAudit.isDuplicate(Packet packet)` checks whether this messageId has been seen before
`void` | `ActiveMQConnection.consume(Packet packet)` Implementation of the PacketListener interface - consume a packet
`(package private) void` | `ActiveMQConnection.asyncSendPacket(Packet packet)`
`(package private) void` | `ActiveMQConnection.syncSendPacket(Packet packet)`
`(package private) void` | `ActiveMQConnection.syncSendPacket(Packet packet, int timeout)`
`(package private) Receipt` | `ActiveMQConnection.syncSendRequest(Packet packet)`

Uses of Packet in org.codehaus.activemq.broker.impl

Methods in org.codehaus.activemq.broker.impl with parameters of type Packet
`void` | `BrokerClientImpl.consume(Packet packet)` Consume a Packet from the underlying TransportChannel for processing
`protected void` | `BrokerClientImpl.send(Packet packet)`

Uses of Packet in org.codehaus.activemq.message

Classes in org.codehaus.activemq.message that implement Packet
`class` | `AbstractPacket` Abstract class for a transportable Packet
`class` | `ActiveMQBytesMessage` A `BytesMessage` object is used to send a message containing a stream of uninterpreted bytes.
`class` | `ActiveMQMapMessage` A `MapMessage` object is used to send a set of name-value pairs.
`class` | `ActiveMQMessage` The `Message` interface is the root interface of all JMS messages.
`class` | `ActiveMQObjectMessage` An `ObjectMessage` object is used to send a message that contains a serializable object in the Java programming language ("Java object").
`class` | `ActiveMQStreamMessage` A `StreamMessage` object is used to send a stream of primitive types in the Java programming language.
`class` | `ActiveMQTextMessage` A `TextMessage` object is used to send a message containing a `java.lang.String`.
`class` | `BrokerInfo` Information about a connected Broker
`class` | `CapacityInfo` Infomation about the Capacity for more messages for a Connection/Broker
`class` | `CapacityInfoRequest` Request nfomation about the Capacity for more messages for a Connection/Broker
`class` | `ConnectionInfo` Describes a Connection
`class` | `ConsumerInfo` Describes a Message consumer
`class` | `DurableUnsubscribe` Command to remove a Durable Subscription
`class` | `IntResponseReceipt` A receipt that also carries a reponse object.
`class` | `MessageAck` Denotes an object that can be serialized/deserailized using a PacketReader/PacketWriter
`class` | `ProducerInfo` Denotes life cycle infomation for a Producer of messages
`class` | `Receipt` Sent in receipt of a Packet
`class` | `ResponseReceipt` A receipt that also carries a reponse object.
`class` | `SessionInfo` Denotes an object that can be serialized/deserailized using a Packet Reader/Writer
`class` | `TransactionInfo` Provides a infomation about a Transaction
`class` | `XATransactionInfo` Provides a infomation about an XA Transaction

Methods in org.codehaus.activemq.message that return Packet
`Packet` | `XATransactionInfoReader.createPacket()`
`abstract Packet` | `WireFormat.readPacket(java.io.DataInput in)` Reads a packet from the given input stream
`abstract Packet` | `WireFormat.readPacket(int firstByte, java.io.DataInput in)` A helper method for working with sockets where the first byte is read first, then the rest of the message is read.
`Packet` | `WireFormat.readPacket(java.lang.String channelID, java.net.DatagramPacket dpacket)` Read a packet from a Datagram packet from the given channelID.
`Packet` | `WireFormat.fromBytes(byte[] bytes, int offset, int length)` Reads the packet from the given byte[]
`Packet` | `WireFormat.fromBytes(byte[] bytes)` Reads the packet from the given byte[]
`Packet` | `TransactionInfoReader.createPacket()`
`Packet` | `SessionInfoReader.createPacket()`
`Packet` | `ResponseReceiptReader.createPacket()`
`Packet` | `ReceiptReader.createPacket()`
`Packet` | `ProducerInfoReader.createPacket()`
`Packet` | `PacketReader.createPacket()`
`Packet` | `PacketReader.readPacketFromByteArray(byte[] data)` Deserailizes a Packet from a byte array
`Packet` | `PacketFacade.getPacket()`
`Packet` | `MessageAckReader.createPacket()`
`Packet` | `IntResponseReceiptReader.createPacket()`
`Packet` | `DurableUnsubscribeReader.createPacket()`
`Packet` | `DefaultWireFormat.readPacket(java.io.DataInput in)`
`Packet` | `DefaultWireFormat.readPacket(int firstByte, java.io.DataInput dataIn)`
`protected Packet` | `DefaultWireFormat.readPacket(java.io.DataInput dataIn, PacketReader reader)`
`Packet` | `ConsumerInfoReader.createPacket()`
`Packet` | `ConnectionInfoReader.createPacket()`
`Packet` | `CapacityInfoRequestReader.createPacket()`
`Packet` | `CapacityInfoReader.createPacket()`
`Packet` | `BrokerInfoReader.createPacket()`
`Packet` | `ActiveMQTextMessageReader.createPacket()`
`Packet` | `ActiveMQStreamMessageReader.createPacket()`
`Packet` | `ActiveMQObjectMessageReader.createPacket()`
`Packet` | `ActiveMQMessageReader.createPacket()`
`Packet` | `ActiveMQMapMessageReader.createPacket()`
`Packet` | `ActiveMQBytesMessageReader.createPacket()`
`Packet` | `AbstractPacketReader.readPacketFromByteArray(byte[] data)` Deserailizes a Packet from a byte array

Methods in org.codehaus.activemq.message with parameters of type Packet
`void` | `XATransactionInfoWriter.writePacket(Packet packet, java.io.DataOutput dataOut)` Write a Packet instance to data output stream
`void` | `XATransactionInfoReader.buildPacket(Packet packet, java.io.DataInput dataIn)` build a Packet instance from the data input stream
`abstract void` | `WireFormat.writePacket(Packet packet, java.io.DataOutput out)` Writes the packet to the given output stream
`java.net.DatagramPacket` | `WireFormat.writePacket(java.lang.String channelID, Packet packet)` Writes the given package to a new datagram
`byte[]` | `WireFormat.toBytes(Packet packet)` A helper method which converts a packet into a byte array
`void` | `TransactionInfoWriter.writePacket(Packet packet, java.io.DataOutput dataOut)` Write a Packet instance to data output stream
`void` | `TransactionInfoReader.buildPacket(Packet packet, java.io.DataInput dataIn)` build a Packet instance from the data input stream
`void` | `SessionInfoWriter.writePacket(Packet packet, java.io.DataOutput dataOut)` Write a Packet instance to data output stream
`void` | `SessionInfoReader.buildPacket(Packet packet, java.io.DataInput dataIn)` build a Packet instance from the data input stream
`void` | `ResponseReceiptWriter.writePacket(Packet packet, java.io.DataOutput dataOut)` Write a Packet instance to data output stream
`void` | `ResponseReceiptReader.buildPacket(Packet packet, java.io.DataInput dataIn)` build a Packet instance from the data input stream
`void` | `ReceiptWriter.writePacket(Packet packet, java.io.DataOutput dataOut)` Write a Packet instance to data output stream
`void` | `ReceiptReader.buildPacket(Packet packet, java.io.DataInput dataIn)` build a Packet instance from the data input stream
`void` | `ProducerInfoWriter.writePacket(Packet packet, java.io.DataOutput dataOut)` Write a Packet instance to data output stream
`void` | `ProducerInfoReader.buildPacket(Packet packet, java.io.DataInput dataIn)` build a Packet instance from the data input stream
`boolean` | `PacketWriter.canWrite(Packet packet)`
`void` | `PacketWriter.writePacket(Packet packet, java.io.DataOutput dataOut)` Write a Packet instance to data output stream
`byte[]` | `PacketWriter.writePacketToByteArray(Packet packet)` Serializes a Packet int a byte array
`void` | `PacketReader.buildPacket(Packet packet, java.io.DataInput dataIn)` build a Packet instance from the data input stream
`void` | `PacketListener.consume(Packet packet)` Consume a Packet
`void` | `MessageAckWriter.writePacket(Packet packet, java.io.DataOutput dataOut)` Write a Packet instance to data output stream
`void` | `MessageAckReader.buildPacket(Packet packet, java.io.DataInput dataIn)` build a Packet instance from the data input stream
`void` | `IntResponseReceiptWriter.writePacket(Packet packet, java.io.DataOutput dataOut)` Write a Packet instance to data output stream
`void` | `IntResponseReceiptReader.buildPacket(Packet packet, java.io.DataInput dataIn)` build a Packet instance from the data input stream
`void` | `DurableUnsubscribeWriter.writePacket(Packet packet, java.io.DataOutput dataOut)` Write a Packet instance to data output stream
`void` | `DurableUnsubscribeReader.buildPacket(Packet packet, java.io.DataInput dataIn)` build a Packet instance from the data input stream
`void` | `DefaultWireFormat.writePacket(Packet packet, java.io.DataOutput dataOut)` Write a Packet to a DataOutput
`byte[]` | `DefaultWireFormat.toBytes(Packet packet)` A helper method which converts a packet into a byte array Overrides the WireFormat to make use of the internal BytesOutputStream
`protected void` | `DefaultWireFormat.writePacket(Packet packet, java.io.DataOutput dataOut, PacketWriter writer)`
`void` | `ConsumerInfoWriter.writePacket(Packet packet, java.io.DataOutput dataOut)` Write a Packet instance to data output stream
`void` | `ConsumerInfoReader.buildPacket(Packet packet, java.io.DataInput dataIn)` build a Packet instance from the data input stream
`void` | `ConnectionInfoWriter.writePacket(Packet packet, java.io.DataOutput dataOut)` Write a Packet instance to data output stream
`void` | `ConnectionInfoReader.buildPacket(Packet packet, java.io.DataInput dataIn)` build a Packet instance from the data input stream
`void` | `CapacityInfoWriter.writePacket(Packet packet, java.io.DataOutput dataOut)` Write a Packet instance to data output stream
`void` | `CapacityInfoRequestWriter.writePacket(Packet packet, java.io.DataOutput dataOut)` Write a Packet instance to data output stream
`void` | `CapacityInfoRequestReader.buildPacket(Packet packet, java.io.DataInput dataIn)` build a Packet instance from the data input stream
`void` | `CapacityInfoReader.buildPacket(Packet packet, java.io.DataInput dataIn)` build a Packet instance from the data input stream
`void` | `BrokerInfoWriter.writePacket(Packet packet, java.io.DataOutput dataOut)` Write a Packet instance to data output stream
`void` | `BrokerInfoReader.buildPacket(Packet packet, java.io.DataInput dataIn)` build a Packet instance from the data input stream
`void` | `ActiveMQMessageWriter.writePacket(Packet packet, java.io.DataOutput dataOut)` Write a Packet instance to data output stream
`void` | `ActiveMQMessageReader.buildPacket(Packet packet, java.io.DataInput dataIn)` build a Packet instance from the data input stream
`boolean` | `AbstractPacketWriter.canWrite(Packet packet)`
`byte[]` | `AbstractPacketWriter.writePacketToByteArray(Packet packet)` Serializes a Packet int a byte array
`void` | `AbstractPacketWriter.writePacket(Packet packet, java.io.DataOutput dataOut)` Write a Packet instance to data output stream
`void` | `AbstractPacketReader.buildPacket(Packet packet, java.io.DataInput dataIn)` build a Packet instance from the data input stream

Constructors in org.codehaus.activemq.message with parameters of type Packet
`PacketFacade(Packet packet)`

Uses of Packet in org.codehaus.activemq.message.util

Methods in org.codehaus.activemq.message.util that return Packet
`Packet` | `SpooledBoundedPacketQueue.dequeue()`
`Packet` | `SpooledBoundedPacketQueue.dequeue(long timeInMillis)`
`Packet` | `SpooledBoundedPacketQueue.dequeueNoWait()`
`Packet` | `MemoryBoundedQueue.dequeue()`
`Packet` | `MemoryBoundedQueue.dequeue(long timeInMillis)` Dequeues a Packet from the head of the queue
`Packet` | `MemoryBoundedQueue.dequeueNoWait()` dequeues a Packet from the head of the queue
`Packet` | `MemoryBoundedQueue.get(int index)` retrieve a Packet at an indexed position in the queue
`Packet` | `BoundedPacketQueue.dequeue()`
`Packet` | `BoundedPacketQueue.dequeue(long timeInMillis)` Dequeues a Packet from the head of the queue
`Packet` | `BoundedPacketQueue.dequeueNoWait()` dequeues a Packet from the head of the queue

Methods in org.codehaus.activemq.message.util with parameters of type Packet
`void` | `SpooledBoundedPacketQueue.enqueue(Packet packet)` Place a Packet at the head of the Queue
`void` | `SpooledBoundedPacketQueue.enqueueNoBlock(Packet packet)` Enqueue a Packet without checking usage limits
`(package private) int` | `MemoryBoundedQueueManager.incrementMemoryUsed(Packet obj)`
`(package private) int` | `MemoryBoundedQueueManager.decrementMemoryUsed(Packet obj)`
`void` | `MemoryBoundedQueue.enqueueNoBlock(Packet packet)` Enqueue a Packet without checking memory usage limits
`void` | `MemoryBoundedQueue.enqueue(Packet packet)` Enqueue a Packet to this queue
`void` | `MemoryBoundedQueue.enqueueFirstNoBlock(Packet packet)` Enqueue a packet to the head of the queue with total disregard for memory constraints
`void` | `MemoryBoundedQueue.enqueueFirst(Packet packet)` Enqueue a Packet to the head of the queue
`boolean` | `MemoryBoundedQueue.remove(Packet packet)` Remove a packet from the queue
`void` | `BoundedPacketQueue.enqueueNoBlock(Packet packet)` Enqueue a Packet without checking usage limits
`void` | `BoundedPacketQueue.enqueue(Packet packet)` Enqueue a Packet to this queue

Uses of Packet in org.codehaus.activemq.service.impl

Methods in org.codehaus.activemq.service.impl that return Packet
`Packet` | `PacketTransactionTask.getPacket()`
`protected static Packet` | `PacketTransactionTask.readPacket(java.io.ObjectInput in)`

Methods in org.codehaus.activemq.service.impl with parameters of type Packet
`static TransactionTask` | `PacketTransactionTask.createTask(Packet packet)`
`protected static void` | `PacketTransactionTask.writePacket(Packet packet, java.io.ObjectOutput out)`

Constructors in org.codehaus.activemq.service.impl with parameters of type Packet
`PacketTransactionTask(BrokerClient brokerClient, Packet packet)`

Uses of Packet in org.codehaus.activemq.store.howl

Methods in org.codehaus.activemq.store.howl with parameters of type Packet
`protected void` | `HowlMessageStore.writePacket(Packet packet)` Writes a message to the transaction log using the current sync mode
`protected JMSException` | `HowlMessageStore.createWriteException(Packet packet, java.lang.Exception e)`

Uses of Packet in org.codehaus.activemq.transport

Methods in org.codehaus.activemq.transport with parameters of type Packet
`Receipt` | `TransportChannel.send(Packet packet)` synchronously send a Packet
`Receipt` | `TransportChannel.send(Packet packet, int timeout)` Synchrnously send a Packet
`void` | `TransportChannel.asyncSend(Packet packet)` Asynchronously send a Packet
`Receipt` | `AbstractTransportChannel.send(Packet packet)` synchronously send a Packet
`Receipt` | `AbstractTransportChannel.send(Packet packet, int timeout)` Synchronously send a Packet
`protected void` | `AbstractTransportChannel.doConsumePacket(Packet packet)` consume a packet from the channel
`protected boolean` | `AbstractTransportChannel.doHandleReceipt(Packet packet)`
`protected void` | `AbstractTransportChannel.doAsyncSend(Packet packet)` send a Packet to the raw underlying transport This method is here to allow specific implementations to override this method

Uses of Packet in org.codehaus.activemq.transport.composite

Methods in org.codehaus.activemq.transport.composite with parameters of type Packet
`Receipt` | `CompositeTransportChannel.send(Packet packet)`
`Receipt` | `CompositeTransportChannel.send(Packet packet, int timeout)`
`void` | `CompositeTransportChannel.asyncSend(Packet packet)`

Uses of Packet in org.codehaus.activemq.transport.ember

Methods in org.codehaus.activemq.transport.ember with parameters of type Packet
`void` | `EmberTransportChannel.asyncSend(Packet packet)` Asynchronously send a Packet

Uses of Packet in org.codehaus.activemq.transport.gnet

Methods in org.codehaus.activemq.transport.gnet that return Packet
`protected Packet` | `GTransportChannel.toPacket(org.apache.geronimo.network.protocol.UpPacket packet)`

Methods in org.codehaus.activemq.transport.gnet with parameters of type Packet
`void` | `GTransportChannel.asyncSend(Packet packet)` Asynchronously send a Packet
`protected org.apache.geronimo.network.protocol.PlainDownPacket` | `GTransportChannel.toPlainDownPacket(Packet mqpacket)`

Uses of Packet in org.codehaus.activemq.transport.jabber

Methods in org.codehaus.activemq.transport.jabber that return Packet
`Packet` | `JabberWireFormat.readPacket(java.io.DataInput in)`
`Packet` | `JabberWireFormat.readPacket(int firstByte, java.io.DataInput in)`

Methods in org.codehaus.activemq.transport.jabber with parameters of type Packet
`void` | `JabberWireFormat.writePacket(Packet packet, java.io.DataOutput out)`

Uses of Packet in org.codehaus.activemq.transport.jgroups

Methods in org.codehaus.activemq.transport.jgroups with parameters of type Packet
`void` | `JGroupsTransportChannel.asyncSend(Packet packet)` Asynchronously send a Packet
`protected void` | `JGroupsTransportChannel.writePacket(Packet packet)` writes the packet to the channel

Uses of Packet in org.codehaus.activemq.transport.jrms

Methods in org.codehaus.activemq.transport.jrms with parameters of type Packet
`void` | `JRMSTransportChannel.asyncSend(Packet packet)` Asynchronously send a Packet
`protected java.net.DatagramPacket` | `JRMSTransportChannel.createDatagramPacket(Packet packet)`

Uses of Packet in org.codehaus.activemq.transport.reliable

Methods in org.codehaus.activemq.transport.reliable with parameters of type Packet
`Receipt` | `ReliableTransportChannel.send(Packet packet, int timeout)`
`void` | `ReliableTransportChannel.asyncSend(Packet packet)`
`void` | `ReliableTransportChannel.consume(Packet packet)` consume a packet from the enbedded channel

Uses of Packet in org.codehaus.activemq.transport.tcp

Methods in org.codehaus.activemq.transport.tcp with parameters of type Packet
`void` | `TcpTransportChannel.asyncSend(Packet packet)` Asynchronously send a Packet
`protected void` | `TcpTransportChannel.doAsyncSend(Packet packet)` Actually performs the async send of a packet

Uses of Packet in org.codehaus.activemq.transport.udp

Methods in org.codehaus.activemq.transport.udp with parameters of type Packet
`void` | `UdpTransportChannel.asyncSend(Packet packet)` Asynchronously send a Packet
`protected java.net.DatagramPacket` | `UdpTransportChannel.createDatagramPacket(Packet packet)`

Uses of Packet in org.codehaus.activemq.transport.vm

Methods in org.codehaus.activemq.transport.vm with parameters of type Packet
`void` | `VmTransportChannel.asyncSend(Packet packet)` Asynchronously send a Packet

Overview | Package | Class | Use | Tree | Deprecated | Index | Help
PREV NEXT | FRAMES NO FRAMES

Copyright © 2004 Protique, Ltd.. All Rights Reserved.