|
||||||||||
PREV NEXT | FRAMES NO FRAMES |
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 |
|
||||||||||
PREV NEXT | FRAMES NO FRAMES |