Package | Description |
---|---|
org.apache.activemq |
The core JMS client API implementation classes.
|
org.apache.activemq.command |
Command objects used via the Command Pattern to communicate among nodes
|
org.apache.activemq.openwire | |
org.apache.activemq.state | |
org.apache.activemq.transport.fanout |
Fan-out Transport implementation which ensures that a message is sent to multiple destinations such as to ensure multiple brokers received a message for non-durable topic delivery to improve redundancy
|
org.apache.activemq.transport.multicast |
A Multicast based Transport implementation.
|
org.apache.activemq.transport.reliable |
The Reliable transport deals with out of order commands as well as dealing with checking for missed commands and possibly re-requesting the replay of dropped commands.
|
org.apache.activemq.transport.udp |
UDP based Transport implementation.
|
Modifier and Type | Method and Description |
---|---|
void |
ActiveMQConnection.asyncSendPacket(Command command)
send a Packet through the Connection - for internal use only
|
void |
ActiveMQSession.asyncSendPacket(Command command)
Send the asynchronus command.
|
Response |
ActiveMQConnection.syncSendPacket(Command command)
Send a packet through a Connection - for internal use only
|
Response |
ActiveMQSession.syncSendPacket(Command command)
Send the synchronus command.
|
void |
ActiveMQConnection.syncSendPacket(Command command,
AsyncCallback onComplete)
Send a packet through a Connection - for internal use only
|
Response |
ActiveMQConnection.syncSendPacket(Command command,
int timeout) |
Modifier and Type | Class and Description |
---|---|
class |
ActiveMQBlobMessage
An implementation of
BlobMessage for out of band BLOB transfer |
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 |
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 |
class |
BaseCommand |
class |
BrokerInfo
When a client connects to a broker, the broker send the client a BrokerInfo
so that the client knows which broker node he's talking to and also any peers
that the node has in his cluster.
|
class |
ConnectionControl
Used to start and stop transports as well as terminating clients.
|
class |
ConnectionError |
class |
ConnectionInfo |
class |
ConsumerControl
Used to start and stop transports as well as terminating clients.
|
class |
ConsumerInfo |
class |
ControlCommand
Used to start and stop transports as well as terminating clients.
|
class |
DataArrayResponse |
class |
DataResponse |
class |
DestinationInfo
Used to create and destroy destinations on the broker.
|
class |
ExceptionResponse |
class |
FlushCommand
An indication to the transport layer that a flush is required.
|
class |
IntegerResponse |
class |
KeepAliveInfo |
class |
LastPartialCommand
Represents the end marker of a stream of
PartialCommand instances. |
class |
Message
Represents an ActiveMQ message
|
class |
MessageAck |
class |
MessageDispatch |
class |
MessageDispatchNotification |
class |
MessagePull
Used to pull messages on demand.
|
class |
PartialCommand
Represents a partial command; a large command that has been split up into
pieces.
|
class |
ProducerAck
A ProducerAck command is sent by a broker to a producer to let it know it has
received and processed messages that it has produced.
|
class |
ProducerInfo |
class |
RemoveInfo
Removes a consumer, producer, session or connection.
|
class |
RemoveSubscriptionInfo |
class |
ReplayCommand
A general purpose replay command for some kind of producer where ranges of
messages are asked to be replayed.
|
class |
Response |
class |
SessionInfo |
class |
ShutdownInfo |
class |
TransactionInfo |
class |
WireFormatInfo |
Modifier and Type | Field and Description |
---|---|
static Command |
FlushCommand.COMMAND |
Modifier and Type | Method and Description |
---|---|
void |
LastPartialCommand.configure(Command completeCommand)
Lets copy across any transient fields from this command
to the complete command when it is unmarshalled on the other end
|
Modifier and Type | Method and Description |
---|---|
int |
CommandIdComparator.compare(Command c1,
Command c2) |
Modifier and Type | Class and Description |
---|---|
class |
Tracked |
Modifier and Type | Method and Description |
---|---|
List<Command> |
TransactionState.getCommands() |
Modifier and Type | Method and Description |
---|---|
void |
TransactionState.addCommand(Command operation) |
void |
ResponseHandler.onResponse(Command command) |
void |
Tracked.onResponses(Command command) |
Tracked |
ConnectionStateTracker.track(Command command)
Entry point for all tracked commands in the tracker.
|
void |
ConnectionStateTracker.trackBack(Command command)
Completes the two phase tracking operation for a command that is sent on the wire.
|
Modifier and Type | Method and Description |
---|---|
protected void |
FanoutTransport.transportListenerOnCommand(Command command) |
Modifier and Type | Method and Description |
---|---|
void |
MulticastDatagramHeaderMarshaller.writeHeader(Command command,
ByteBuffer writeBuffer) |
Modifier and Type | Method and Description |
---|---|
protected void |
ReliableTransport.onMissingResponse(Command command,
FutureResponse response)
Deprecated.
Lets attempt to replay the request as a command may have disappeared
|
Modifier and Type | Method and Description |
---|---|
Command |
CommandDatagramChannel.read() |
Command |
CommandDatagramSocket.read() |
Command |
CommandChannel.read() |
Modifier and Type | Method and Description |
---|---|
protected Transport |
UdpTransportServer.createTransport(Command command,
DatagramEndpoint endpoint)
Deprecated.
|
protected void |
UdpTransportServer.processInboundConnection(Command command)
Deprecated.
|
void |
CommandChannelSupport.write(Command command) |
void |
CommandDatagramChannel.write(Command command,
SocketAddress address) |
void |
CommandDatagramSocket.write(Command command,
SocketAddress address) |
void |
CommandChannel.write(Command command,
SocketAddress address) |
void |
DatagramHeaderMarshaller.writeHeader(Command command,
ByteBuffer writeBuffer) |
void |
DatagramHeaderMarshaller.writeHeader(Command command,
DataOutputStream dataOut) |
Copyright © 2005–2016 FuseSource, Corp.. All rights reserved.