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.store.journal Message persistence using a high performance transaction log via the Journal interface. 
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.http A transport using the HTTP protocol to allow ActiveMQ to tunnel through firewalls. 
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  
org.codehaus.activemq.transport.xstream   
 

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
 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.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.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 WireFormatInfo
          Describes a Connection
 class XATransactionInfo
          Provides a infomation about an XA Transaction
 

Methods in org.codehaus.activemq.message that return Packet
 Packet WireFormatInfoReader.createPacket()
           
 Packet XATransactionInfoReader.createPacket()
           
 Packet TransactionInfoReader.createPacket()
           
abstract  Packet TextWireFormat.fromString(String text)
          Converts the String into a Packet
 Packet SessionInfoReader.createPacket()
           
 Packet ResponseReceiptReader.createPacket()
           
 Packet ProducerInfoReader.createPacket()
           
 Packet MessageAckReader.createPacket()
           
 Packet ReceiptReader.createPacket()
           
 Packet IntResponseReceiptReader.createPacket()
           
 Packet DurableUnsubscribeReader.createPacket()
           
 Packet DefaultWireFormat.readPacket(DataInput in)
           
 Packet DefaultWireFormat.readPacket(int firstByte, DataInput dataIn)
           
protected  Packet DefaultWireFormat.readPacket(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 ActiveMQMapMessageReader.createPacket()
           
 Packet PacketFacade.getPacket()
           
 Packet ActiveMQMessageReader.createPacket()
           
 Packet ActiveMQBytesMessageReader.createPacket()
           
 Packet PacketReader.createPacket()
           
 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 WireFormat.readPacket(DataInput in)
          Reads a packet from the given input stream
abstract  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 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[]
 

Methods in org.codehaus.activemq.message with parameters of type Packet
 void WireFormatInfoWriter.writePacket(Packet packet, DataOutput dataOut)
          Write a Packet instance to data output stream
 void WireFormatInfoReader.buildPacket(Packet packet, DataInput dataIn)
          build a Packet instance from the data input stream
 void XATransactionInfoWriter.writePacket(Packet packet, DataOutput dataOut)
          Write a Packet instance to data output stream
 void XATransactionInfoReader.buildPacket(Packet packet, DataInput dataIn)
          build a Packet instance from the data input stream
 void TransactionInfoWriter.writePacket(Packet packet, DataOutput dataOut)
          Write a Packet instance to data output stream
 void TransactionInfoReader.buildPacket(Packet packet, DataInput dataIn)
          build a Packet instance from the data input stream
abstract  String TextWireFormat.toString(Packet packet)
          Converts the packet into a String
 void SessionInfoWriter.writePacket(Packet packet, DataOutput dataOut)
          Write a Packet instance to data output stream
 void SessionInfoReader.buildPacket(Packet packet, DataInput dataIn)
          build a Packet instance from the data input stream
 void ResponseReceiptWriter.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 ResponseReceiptReader.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 MessageAckWriter.writePacket(Packet packet, DataOutput dataOut)
          Write a Packet instance to data output stream
 void MessageAckReader.buildPacket(Packet packet, DataInput dataIn)
          build a Packet instance from the data input stream
 void ReceiptWriter.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 ReceiptReader.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 DurableUnsubscribeWriter.writePacket(Packet packet, DataOutput dataOut)
          Write a Packet instance to data output stream
 void DurableUnsubscribeReader.buildPacket(Packet packet, DataInput dataIn)
          build a Packet instance from the data input stream
 void DefaultWireFormat.writePacket(Packet packet, 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, DataOutput dataOut, PacketWriter writer)
           
 void ConsumerInfoWriter.writePacket(Packet packet, DataOutput dataOut)
          Write a Packet instance to data output stream
 void ConsumerInfoReader.buildPacket(Packet packet, DataInput dataIn)
          build a Packet instance from the data input stream
 void ConnectionInfoWriter.writePacket(Packet packet, DataOutput dataOut)
          Write a Packet instance to data output stream
 void ConnectionInfoReader.buildPacket(Packet packet, DataInput dataIn)
          build a Packet instance from the data input stream
 void CapacityInfoWriter.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 CapacityInfoRequestReader.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 BrokerInfoWriter.writePacket(Packet packet, DataOutput dataOut)
          Write a Packet instance to data output stream
 void BrokerInfoReader.buildPacket(Packet packet, DataInput dataIn)
          build a Packet instance from the data input stream
 void ActiveMQMessageWriter.writePacket(Packet packet, DataOutput dataOut)
          Write a Packet instance to data output stream
 boolean PacketWriter.canWrite(Packet packet)
           
 void PacketWriter.writePacket(Packet packet, DataOutput dataOut)
          Write a Packet instance to data output stream
 byte[] PacketWriter.writePacketToByteArray(Packet packet)
          Serializes a Packet int a byte array
 boolean AbstractPacketWriter.canWrite(Packet packet)
           
 byte[] AbstractPacketWriter.writePacketToByteArray(Packet packet)
          Serializes a Packet int a byte array
 void AbstractPacketWriter.writePacket(Packet p, DataOutput dataOut)
          Write a Packet instance to data output stream
 void ActiveMQMessageReader.buildPacket(Packet packet, DataInput dataIn)
          build a Packet instance from the data input stream
 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 PacketListener.consume(Packet packet)
          Consume a Packet
abstract  void 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
 byte[] WireFormat.toBytes(Packet packet)
          A helper method which converts a packet into a byte array
 

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 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
 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.remove(String id)
          Remove a Packet by it's id
 Packet MemoryBoundedQueue.get(int index)
          retrieve a Packet at an indexed position in 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
 void BoundedPacketQueue.enqueueNoBlock(Packet packet)
          Enqueue a Packet without checking usage limits
 void BoundedPacketQueue.enqueue(Packet packet)
          Enqueue a Packet to this queue
 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
(package private)  int MemoryBoundedQueueManager.incrementMemoryUsed(Packet obj)
           
(package private)  int MemoryBoundedQueueManager.decrementMemoryUsed(Packet obj)
           
 

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(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, 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, Exception e)
           
 

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

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

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

Uses of Packet in org.codehaus.activemq.transport
 

Methods in org.codehaus.activemq.transport with parameters of type Packet
 Receipt TransportChannelSupport.send(Packet packet)
          synchronously send a Packet
 Receipt TransportChannelSupport.send(Packet packet, int timeout)
          Synchronously send a Packet
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)
           
protected  void TransportChannelSupport.doAsyncSend(Packet packet)
          send a Packet to the raw underlying transport This method is here to allow specific implementations to override this method
 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
 

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.http
 

Methods in org.codehaus.activemq.transport.http with parameters of type Packet
 void HttpTransportChannel.asyncSend(Packet packet)
           
 void HttpServerTransportChannel.asyncSend(Packet packet)
           
 void HttpClientTransportChannel.asyncSend(Packet packet)
           
 

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

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

Methods in org.codehaus.activemq.transport.jabber with parameters of type Packet
 void JabberWireFormat.writePacket(Packet packet, 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  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  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
 

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

Methods in org.codehaus.activemq.transport.xstream that return Packet
 Packet XStreamWireFormat.readPacket(DataInput in)
           
 Packet XStreamWireFormat.readPacket(int firstByte, DataInput in)
           
 Packet XStreamWireFormat.fromString(String xml)
           
 

Methods in org.codehaus.activemq.transport.xstream with parameters of type Packet
 void XStreamWireFormat.writePacket(Packet packet, DataOutput out)
           
 String XStreamWireFormat.toString(Packet packet)
           
 



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