Uses of Interface
org.activemq.message.Packet

Packages that use Packet
org.activemq The core JMS client implementation classes 
org.activemq.advisories Helper classes for listening to advisory messages. 
org.activemq.broker.impl The default implementation of the JMS Broker 
org.activemq.io   
org.activemq.io.impl   
org.activemq.message Message implementations 
org.activemq.store.journal Message persistence using a high performance transaction log via the Journal interface. 
org.activemq.transport The transport abstraction layer for sending and receiving Packets over a network 
org.activemq.transport.activeio An implementation of the transport layer using activeio channels see http://activeio.org 
org.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.activemq.transport.jabber A transport using Jabber (XMPP) 
org.activemq.transport.multicast An implementation of the transport layer using multicast 
org.activemq.transport.reliable   
org.activemq.transport.stomp An implementation of the Stomp protocol which is a simple wire protocol for writing clients for ActiveMQ in different languages like Ruby, Python, PHP, C etc. 
org.activemq.transport.tcp An implementation of the transport layer using TCP/IP sockets 
org.activemq.transport.udp An implementation of the transport layer using UDP 
org.activemq.transport.vm An implementation of the transport layer using intra-JVM communication 
 

Uses of Packet in org.activemq
 

Methods in org.activemq with parameters of type Packet
 void ActiveMQConnection.asyncSendPacket(Packet packet)
          send a Packet through the Connection - for internal use only
 void ActiveMQConnection.asyncSendPacket(Packet packet, boolean doSendWhileReconnecting)
          send a Packet through the Connection - for internal use only
 void ActiveMQConnection.consume(Packet packet)
          Implementation of the PacketListener interface - consume a packet
 void ActiveMQConnection.syncSendPacket(Packet packet)
          send a Packet through a Connection - for internal use only
 void ActiveMQConnection.syncSendPacket(Packet packet, int timeout)
          Send a packet through a Connection - for internal use only
 Receipt ActiveMQConnection.syncSendRequest(Packet packet)
           
 

Uses of Packet in org.activemq.advisories
 

Classes in org.activemq.advisories that implement Packet
 class TempDestinationAdvisoryEvent
          This event is raised when a MessageTempDestination starts/stops *
 

Uses of Packet in org.activemq.broker.impl
 

Classes in org.activemq.broker.impl that implement Packet
 class LocalBrokerInfo
          Information about a connected Broker
 

Methods in org.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.activemq.io
 

Methods in org.activemq.io that return Packet
 Packet WireFormat.fromBytes(byte[] bytes)
          Reads the packet from the given byte[]
 Packet AbstractWireFormat.fromBytes(byte[] bytes)
          Reads the packet from the given byte[]
 Packet WireFormat.fromBytes(byte[] bytes, int offset, int length)
          Reads the packet from the given byte[]
 Packet AbstractWireFormat.fromBytes(byte[] bytes, int offset, int length)
          Reads the packet from the given byte[]
abstract  Packet TextWireFormat.fromString(String text)
          Converts the String into a Packet
 Packet WireFormat.readPacket(DataInput in)
          Reads a packet from the given input stream
 Packet AbstractWireFormat.readPacket(DataInput dataIn)
           
 Packet WireFormat.readPacket(int firstByte, 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(String channelID, DatagramPacket dpacket)
          Read a packet from a Datagram packet from the given channelID.
 Packet AbstractWireFormat.readPacket(String channelID, DatagramPacket dpacket)
          Read a packet from a Datagram packet from the given channelID.
 Packet WireFormat.writePacket(Packet packet, DataOutput out)
          Writes the packet to the given output stream
 

Methods in org.activemq.io with parameters of type Packet
 byte[] WireFormat.toBytes(Packet packet)
          A helper method which converts a packet into a byte array
 byte[] AbstractWireFormat.toBytes(Packet packet)
          A helper method which converts a packet into a byte array
abstract  String TextWireFormat.toString(Packet packet)
          Converts the packet into a String
 Packet WireFormat.writePacket(Packet packet, DataOutput out)
          Writes the packet to the given output stream
 DatagramPacket WireFormat.writePacket(String channelID, Packet packet)
          Writes the given package to a new datagram
 DatagramPacket AbstractWireFormat.writePacket(String channelID, Packet packet)
          Writes the given package to a new datagram
 

Uses of Packet in org.activemq.io.impl
 

Methods in org.activemq.io.impl that return Packet
 Packet PacketReader.createPacket()
           
 Packet ActiveMQBytesMessageReader.createPacket()
           
 Packet ActiveMQMessageReader.createPacket()
           
 Packet ActiveMQMapMessageReader.createPacket()
           
 Packet ActiveMQObjectMessageReader.createPacket()
           
 Packet ActiveMQStreamMessageReader.createPacket()
           
 Packet ActiveMQTextMessageReader.createPacket()
           
 Packet BrokerAdminCommandReader.createPacket()
           
 Packet BrokerInfoReader.createPacket()
           
 Packet CachedValueReader.createPacket()
           
 Packet CapacityInfoReader.createPacket()
           
 Packet CapacityInfoRequestReader.createPacket()
           
 Packet CleanupConnectionInfoReader.createPacket()
           
 Packet ConnectionInfoReader.createPacket()
           
 Packet ConsumerInfoReader.createPacket()
           
 Packet DurableUnsubscribeReader.createPacket()
           
 Packet IntResponseReceiptReader.createPacket()
           
 Packet ReceiptReader.createPacket()
           
 Packet KeepAliveReader.createPacket()
           
 Packet MessageAckReader.createPacket()
           
 Packet ProducerInfoReader.createPacket()
           
 Packet ResponseReceiptReader.createPacket()
           
 Packet SessionInfoReader.createPacket()
           
 Packet TransactionInfoReader.createPacket()
           
 Packet WireFormatInfoReader.createPacket()
           
 Packet XATransactionInfoReader.createPacket()
           
protected abstract  Packet AbstractDefaultWireFormat.readPacket(DataInput dataIn, PacketReader reader)
           
protected  Packet DefaultWireFormat.readPacket(DataInput dataIn, PacketReader reader)
           
protected  Packet StatelessDefaultWireFormat.readPacket(DataInput dataIn, PacketReader reader)
           
 Packet AbstractDefaultWireFormat.readPacket(int firstByte, DataInput dataIn)
           
 Packet StatelessDefaultWireFormat.readPacket(org.activeio.Packet dataIn)
           
 Packet PacketReader.readPacketFromByteArray(byte[] data)
          Deserailizes a Packet from a byte array
 Packet AbstractPacketReader.readPacketFromByteArray(byte[] data)
          Deserailizes a Packet from a byte array
abstract  Packet AbstractDefaultWireFormat.writePacket(Packet packet, DataOutput dataOut)
           
 Packet DefaultWireFormat.writePacket(Packet packet, DataOutput dataOut)
           
 Packet StatelessDefaultWireFormat.writePacket(Packet packet, DataOutput dataOut)
           
 

Methods in org.activemq.io.impl with parameters of type Packet
 void PacketReader.buildPacket(Packet packet, DataInput dataIn)
          build a Packet instance from the data input stream
 void AbstractPacketReader.buildPacket(Packet p, DataInput dataIn)
          build a Packet instance from the data input stream
 void ActiveMQMessageReader.buildPacket(Packet packet, DataInput dataIn)
          build a Packet instance from the data input stream
 void BrokerAdminCommandReader.buildPacket(Packet packet, DataInput dataIn)
          build a Packet instance from the data input stream
 void BrokerInfoReader.buildPacket(Packet packet, DataInput dataIn)
          build a Packet instance from the data input stream
 void CachedValueReader.buildPacket(Packet packet, DataInput dataIn)
          build a Packet instance from the data input stream
 void CapacityInfoReader.buildPacket(Packet packet, DataInput dataIn)
          build a Packet instance from the data input stream
 void CapacityInfoRequestReader.buildPacket(Packet packet, DataInput dataIn)
          build a Packet instance from the data input stream
 void CleanupConnectionInfoReader.buildPacket(Packet packet, DataInput dataIn)
          build a Packet instance from the data input stream
 void ConnectionInfoReader.buildPacket(Packet packet, DataInput dataIn)
          build a Packet instance from the data input stream
 void ConsumerInfoReader.buildPacket(Packet packet, DataInput dataIn)
          build a Packet instance from the data input stream
 void DurableUnsubscribeReader.buildPacket(Packet packet, DataInput dataIn)
          build a Packet instance from the data input stream
 void IntResponseReceiptReader.buildPacket(Packet packet, DataInput dataIn)
          build a Packet instance from the data input stream
 void ReceiptReader.buildPacket(Packet packet, DataInput dataIn)
          build a Packet instance from the data input stream
 void KeepAliveReader.buildPacket(Packet packet, DataInput dataIn)
          build a Packet instance from the data input stream
 void MessageAckReader.buildPacket(Packet packet, DataInput dataIn)
          build a Packet instance from the data input stream
 void ProducerInfoReader.buildPacket(Packet packet, DataInput dataIn)
          build a Packet instance from the data input stream
 void ResponseReceiptReader.buildPacket(Packet packet, DataInput dataIn)
          build a Packet instance from the data input stream
 void SessionInfoReader.buildPacket(Packet packet, DataInput dataIn)
          build a Packet instance from the data input stream
 void TransactionInfoReader.buildPacket(Packet packet, DataInput dataIn)
          build a Packet instance from the data input stream
 void WireFormatInfoReader.buildPacket(Packet packet, DataInput dataIn)
          build a Packet instance from the data input stream
 void XATransactionInfoReader.buildPacket(Packet packet, DataInput dataIn)
          build a Packet instance from the data input stream
 boolean PacketWriter.canWrite(Packet packet)
           
 boolean AbstractPacketMarshaller.canWrite(Packet packet)
           
 boolean AbstractPacketWriter.canWrite(Packet packet)
           
protected  PacketWriter AbstractDefaultWireFormat.getWriter(Packet packet)
           
abstract  byte[] AbstractDefaultWireFormat.toBytes(Packet packet)
           
 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
 byte[] StatelessDefaultWireFormat.toBytes(Packet packet)
          A helper method which converts a packet into a byte array Overrides the WireFormat to make use of the internal BytesOutputStream
abstract  Packet AbstractDefaultWireFormat.writePacket(Packet packet, DataOutput dataOut)
           
 void PacketWriter.writePacket(Packet packet, DataOutput dataOut)
          Write a Packet instance to data output stream
 void AbstractPacketMarshaller.writePacket(Packet p, DataOutput dataOut)
          Write a Packet instance to data output stream
 void AbstractPacketWriter.writePacket(Packet p, DataOutput dataOut)
          Write a Packet instance to data output stream
 void ActiveMQMessageWriter.writePacket(Packet packet, DataOutput dataOut)
          Write a Packet instance to data output stream
 void BrokerAdminCommandWriter.writePacket(Packet packet, DataOutput dataOut)
          Write a Packet instance to data output stream
 void BrokerInfoWriter.writePacket(Packet packet, DataOutput dataOut)
          Write a Packet instance to data output stream
 void CachedValueWriter.writePacket(Packet packet, DataOutput dataOut)
          Write a Packet instance to data output stream
 void CapacityInfoRequestWriter.writePacket(Packet packet, DataOutput dataOut)
          Write a Packet instance to data output stream
 void CapacityInfoWriter.writePacket(Packet packet, DataOutput dataOut)
          Write a Packet instance to data output stream
 void CleanupConnectionInfoWriter.writePacket(Packet packet, DataOutput dataOut)
          Write a Packet instance to data output stream
 void ConnectionInfoWriter.writePacket(Packet packet, DataOutput dataOut)
          Write a Packet instance to data output stream
 void ConsumerInfoWriter.writePacket(Packet packet, DataOutput dataOut)
          Write a Packet instance to data output stream
 Packet DefaultWireFormat.writePacket(Packet packet, DataOutput dataOut)
           
 void DurableUnsubscribeWriter.writePacket(Packet packet, DataOutput dataOut)
          Write a Packet instance to data output stream
 void IntResponseReceiptWriter.writePacket(Packet packet, DataOutput dataOut)
          Write a Packet instance to data output stream
 void ReceiptWriter.writePacket(Packet packet, DataOutput dataOut)
          Write a Packet instance to data output stream
 void KeepAliveWriter.writePacket(Packet packet, DataOutput dataOut)
          Write a Packet instance to data output stream
 void MessageAckWriter.writePacket(Packet packet, DataOutput dataOut)
          Write a Packet instance to data output stream
 void ProducerInfoWriter.writePacket(Packet packet, DataOutput dataOut)
          Write a Packet instance to data output stream
 void ResponseReceiptWriter.writePacket(Packet packet, DataOutput dataOut)
          Write a Packet instance to data output stream
 void SessionInfoWriter.writePacket(Packet packet, DataOutput dataOut)
          Write a Packet instance to data output stream
 Packet StatelessDefaultWireFormat.writePacket(Packet packet, DataOutput dataOut)
           
 void TransactionInfoWriter.writePacket(Packet packet, DataOutput dataOut)
          Write a Packet instance to data output stream
 void WireFormatInfoWriter.writePacket(Packet packet, DataOutput dataOut)
          Write a Packet instance to data output stream
 void XATransactionInfoWriter.writePacket(Packet packet, DataOutput dataOut)
          Write a Packet instance to data output stream
 org.activeio.Packet StatelessDefaultWireFormat.writePacket(Packet packet, org.activeio.adapter.PacketByteArrayOutputStream paos)
          Write a Packet to a PacketByteArrayOutputStream
 byte[] PacketWriter.writePacketToByteArray(Packet packet)
          Serializes a Packet int a byte array
 byte[] AbstractPacketMarshaller.writePacketToByteArray(Packet packet)
          Serializes a Packet int a byte array
 byte[] AbstractPacketWriter.writePacketToByteArray(Packet packet)
          Serializes a Packet int a byte array
 

Uses of Packet in org.activemq.message
 

Classes in org.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 BrokerAdminCommand
          Describes a Message consumer
 class BrokerInfo
          Information about a connected Broker
 class CachedValue
          Sent in receipt of a Packet
 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 CleanupConnectionInfo
          Denotes an object that can be serialized/deserailized using a Packet Reader/Writer
 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 KeepAlive
          Keep-alive packet which holds not information and is only intended to keep connections from being idle.
 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 response 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 WireFormatInfo
          Describes a Connection
 class XATransactionInfo
          Provides a infomation about an XA Transaction
 

Methods in org.activemq.message that return Packet
 Packet PacketFacade.getPacket()
           
 

Methods in org.activemq.message with parameters of type Packet
 void PacketListener.consume(Packet packet)
          Consume a Packet
 

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

Uses of Packet in org.activemq.store.journal
 

Methods in org.activemq.store.journal that return Packet
 Packet JournalPersistenceAdapter.readPacket(org.activeio.journal.RecordLocation location)
           
 

Methods in org.activemq.store.journal with parameters of type Packet
protected  JMSException JournalPersistenceAdapter.createWriteException(Packet packet, Exception e)
           
 org.activeio.journal.RecordLocation JournalPersistenceAdapter.writePacket(String destination, Packet packet, boolean sync)
           
 

Uses of Packet in org.activemq.transport
 

Methods in org.activemq.transport that return Packet
protected  Packet TransportChannelSupport.doAsyncSend(Packet packet)
          send a Packet to the raw underlying transport This method is here to allow specific implementations to override this method
 

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

Uses of Packet in org.activemq.transport.activeio
 

Methods in org.activemq.transport.activeio that return Packet
protected  Packet ActiveIOTransportChannel.doAsyncSend(Packet packet)
           
 

Methods in org.activemq.transport.activeio with parameters of type Packet
 void ActiveIOTransportChannel.asyncSend(Packet packet)
           
protected  Packet ActiveIOTransportChannel.doAsyncSend(Packet packet)
           
 

Uses of Packet in org.activemq.transport.composite
 

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

Uses of Packet in org.activemq.transport.jabber
 

Methods in org.activemq.transport.jabber that return Packet
protected  Packet JabberWireFormat.createConnectionInfo()
           
protected  Packet JabberWireFormat.createConsumerPacket()
           
protected  Packet JabberWireFormat.readMessage(javax.xml.stream.XMLStreamReader reader)
           
 Packet JabberWireFormat.readPacket(int firstByte, DataInput in)
           
 Packet JabberWireFormat.writePacket(Packet packet, DataOutput out)
           
 

Methods in org.activemq.transport.jabber with parameters of type Packet
 Packet JabberWireFormat.writePacket(Packet packet, DataOutput out)
           
 

Uses of Packet in org.activemq.transport.multicast
 

Methods in org.activemq.transport.multicast with parameters of type Packet
 void MulticastDiscoveryAgent.consume(Packet packet)
          Consume multicast packets
 void MulticastTester.consume(Packet packet)
           
 

Uses of Packet in org.activemq.transport.reliable
 

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

Uses of Packet in org.activemq.transport.stomp
 

Classes in org.activemq.transport.stomp that implement Packet
 class FlushPacket
          Dummy Marker packet to let the transport layer know that it should flush the wireformat.
 

Methods in org.activemq.transport.stomp that return Packet
 Packet StompWireFormat.fromBytes(byte[] bytes)
          Reads the packet from the given byte[]
 Packet StompWireFormat.fromBytes(byte[] bytes, int offset, int length)
          Reads the packet from the given byte[]
 Packet StompWireFormat.readPacket(DataInput in)
           
 Packet StompWireFormat.readPacket(int firstByte, 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 StompWireFormat.readPacket(String channelID, DatagramPacket dpacket)
          Read a packet from a Datagram packet from the given channelID.
 Packet StompWireFormat.writePacket(Packet packet, DataOutput out)
           
 

Methods in org.activemq.transport.stomp with parameters of type Packet
protected  void StompTransportChannel.doConsumePacket(Packet packet)
           
 void StompWireFormat.enqueuePacket(Packet ack)
           
 byte[] StompWireFormat.toBytes(Packet packet)
          A helper method which converts a packet into a byte array
 Packet StompWireFormat.writePacket(Packet packet, DataOutput out)
           
 DatagramPacket StompWireFormat.writePacket(String channelID, Packet packet)
          Writes the given package to a new datagram
 

Uses of Packet in org.activemq.transport.tcp
 

Methods in org.activemq.transport.tcp that return Packet
protected  Packet TcpTransportChannel.doAsyncSend(Packet packet)
          Actually performs the async send of a packet
 

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

Uses of Packet in org.activemq.transport.udp
 

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

Uses of Packet in org.activemq.transport.vm
 

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



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