|
|||||||||||
PREV NEXT | FRAMES NO FRAMES |
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.io | |
org.codehaus.activemq.io.impl | |
org.codehaus.activemq.message | Message implementations |
org.codehaus.activemq.message.util | |
org.codehaus.activemq.service.impl | Default implementations of the services |
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.multicast | An implementation of the transport layer using multicast |
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 | |
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)
|
boolean |
ActiveMQMessageAudit.isDuplicate(Packet packet)
checks whether this messageId has been seen before |
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.io |
Methods in org.codehaus.activemq.io that return Packet | |
Packet |
AbstractWireFormat.readPacket(String channelID,
DatagramPacket dpacket)
Read a packet from a Datagram packet from the given channelID. |
Packet |
AbstractWireFormat.fromBytes(byte[] bytes,
int offset,
int length)
Reads the packet from the given byte[] |
Packet |
AbstractWireFormat.fromBytes(byte[] bytes)
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 |
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.io with parameters of type Packet | |
DatagramPacket |
AbstractWireFormat.writePacket(String channelID,
Packet packet)
Writes the given package to a new datagram |
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 |
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 |
Uses of Packet in org.codehaus.activemq.io.impl |
Methods in org.codehaus.activemq.io.impl that return Packet | |
Packet |
IntResponseReceiptReader.createPacket()
|
Packet |
XATransactionInfoReader.createPacket()
|
Packet |
KeepAliveReader.createPacket()
|
Packet |
DurableUnsubscribeReader.createPacket()
|
Packet |
BrokerInfoReader.createPacket()
|
Packet |
ConsumerInfoReader.createPacket()
|
Packet |
DefaultWireFormat.readPacket(DataInput in)
|
Packet |
DefaultWireFormat.readPacket(int firstByte,
DataInput dataIn)
|
protected Packet |
DefaultWireFormat.readPacket(DataInput dataIn,
PacketReader reader)
|
Packet |
CapacityInfoRequestReader.createPacket()
|
Packet |
AbstractPacketReader.readPacketFromByteArray(byte[] data)
Deserailizes a Packet from a byte array |
Packet |
ActiveMQMapMessageReader.createPacket()
|
Packet |
ActiveMQObjectMessageReader.createPacket()
|
Packet |
ActiveMQMessageReader.createPacket()
|
Packet |
CapacityInfoReader.createPacket()
|
Packet |
WireFormatInfoReader.createPacket()
|
Packet |
TransactionInfoReader.createPacket()
|
Packet |
ActiveMQStreamMessageReader.createPacket()
|
Packet |
ConnectionInfoReader.createPacket()
|
Packet |
BrokerAdminCommandReader.createPacket()
|
Packet |
ReceiptReader.createPacket()
|
Packet |
ActiveMQTextMessageReader.createPacket()
|
Packet |
ProducerInfoReader.createPacket()
|
Packet |
ActiveMQBytesMessageReader.createPacket()
|
Packet |
MessageAckReader.createPacket()
|
Packet |
SessionInfoReader.createPacket()
|
Packet |
PacketReader.createPacket()
|
Packet |
PacketReader.readPacketFromByteArray(byte[] data)
Deserailizes a Packet from a byte array |
Packet |
ResponseReceiptReader.createPacket()
|
Methods in org.codehaus.activemq.io.impl with parameters of type Packet | |
void |
MessageAckWriter.writePacket(Packet packet,
DataOutput dataOut)
Write a Packet instance to data output stream |
void |
IntResponseReceiptReader.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 |
void |
ReceiptWriter.writePacket(Packet packet,
DataOutput dataOut)
Write a Packet instance to data output stream |
void |
KeepAliveReader.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 |
WireFormatInfoWriter.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 |
BrokerInfoReader.buildPacket(Packet packet,
DataInput dataIn)
build a Packet instance from the data input stream |
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 |
TransactionInfoWriter.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 |
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 |
BrokerInfoWriter.writePacket(Packet packet,
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 |
CapacityInfoRequestReader.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 |
IntResponseReceiptWriter.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 |
XATransactionInfoWriter.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 |
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 |
KeepAliveWriter.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 |
void |
ActiveMQMessageReader.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 |
WireFormatInfoReader.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 |
BrokerAdminCommandWriter.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 |
BrokerAdminCommandReader.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 |
CapacityInfoWriter.writePacket(Packet packet,
DataOutput dataOut)
Write a Packet instance to data output stream |
void |
ProducerInfoReader.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 |
SessionInfoWriter.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 |
SessionInfoReader.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 |
ResponseReceiptReader.buildPacket(Packet packet,
DataInput dataIn)
build a Packet instance from the data input stream |
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 |
BrokerAdminCommand
Describes a Message consumer |
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 |
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 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 |
PacketFacade.getPacket()
|
Methods in org.codehaus.activemq.message with parameters of type Packet | |
void |
PacketListener.consume(Packet packet)
Consume a Packet |
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 |
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 |
Packet |
SpooledBoundedPacketQueue.dequeue()
|
Packet |
SpooledBoundedPacketQueue.dequeue(long timeInMillis)
|
Packet |
SpooledBoundedPacketQueue.dequeueNoWait()
|
Methods in org.codehaus.activemq.message.util with parameters of type Packet | |
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 |
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 |
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.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 |
ReceiptHolder |
TransportChannel.asyncSendWithReceipt(Packet packet)
Asynchronously send a Packet with receipt. |
Receipt |
TransportChannelSupport.send(Packet packet)
synchronously send a Packet |
Receipt |
TransportChannelSupport.send(Packet packet,
int timeout)
Synchronously send a Packet |
ReceiptHolder |
TransportChannelSupport.asyncSendWithReceipt(Packet packet)
Asynchronously send a Packet with receipt. |
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 |
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)
|
ReceiptHolder |
CompositeTransportChannel.asyncSendWithReceipt(Packet packet)
|
Uses of Packet in org.codehaus.activemq.transport.multicast |
Methods in org.codehaus.activemq.transport.multicast with parameters of type Packet | |
void |
MulticastDiscoveryAgent.consume(Packet packet)
Consume multicast packets |
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)
|
ReceiptHolder |
ReliableTransportChannel.asyncSendWithReceipt(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 |
|
|||||||||||
PREV NEXT | FRAMES NO FRAMES |