Uses of Interface
org.apache.activemq.command.Command
-
Packages that use Command Package Description org.apache.activemq The core JMS client API implementation classes.org.apache.activemq.advisory Support for JMS Advisory messages as well as some helper listeners to listen to the clients, producers and consumers available.org.apache.activemq.broker The core classes for the ActiveMQ Message Broker and its connectors.org.apache.activemq.command Command objects used via the Command Pattern to communicate among nodesorg.apache.activemq.network Support for federated networks of brokers.org.apache.activemq.openwire org.apache.activemq.state org.apache.activemq.transport.amqp A Broker side implementation of the AMQP 3.1 protocol - see http://amqp.org/org.apache.activemq.transport.amqp.protocol 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 redundancyorg.apache.activemq.transport.mqtt A Broker side implementation of the MQTT 3.1 protocol - see http://mqtt.org/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.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.apache.activemq.transport.udp UDP based Transport implementation.org.apache.activemq.transport.ws -
-
Uses of Command in org.apache.activemq
Methods in org.apache.activemq with parameters of type Command Modifier and Type Method Description void
ActiveMQConnection. asyncSendPacket(Command command)
send a Packet through the Connection - for internal use onlyvoid
ActiveMQSession. asyncSendPacket(Command command)
Send the asynchronous command.Response
ActiveMQConnection. syncSendPacket(Command command)
Send a packet through a Connection - for internal use onlyResponse
ActiveMQConnection. syncSendPacket(Command command, int timeout)
void
ActiveMQConnection. syncSendPacket(Command command, AsyncCallback onComplete)
Send a packet through a Connection - for internal use onlyResponse
ActiveMQSession. syncSendPacket(Command command)
Send the synchronous command. -
Uses of Command in org.apache.activemq.advisory
Methods in org.apache.activemq.advisory with parameters of type Command Modifier and Type Method Description protected void
AdvisoryBroker. fireAdvisory(ConnectionContext context, ActiveMQTopic topic, Command command)
protected void
AdvisoryBroker. fireAdvisory(ConnectionContext context, ActiveMQTopic topic, Command command, ConsumerId targetConsumerId)
void
AdvisoryBroker. fireAdvisory(ConnectionContext context, ActiveMQTopic topic, Command command, ConsumerId targetConsumerId, ActiveMQMessage advisoryMessage)
protected void
AdvisoryBroker. fireConsumerAdvisory(ConnectionContext context, ActiveMQDestination consumerDestination, ActiveMQTopic topic, Command command)
protected void
AdvisoryBroker. fireConsumerAdvisory(ConnectionContext context, ActiveMQDestination consumerDestination, ActiveMQTopic topic, Command command, ConsumerId targetConsumerId)
protected void
AdvisoryBroker. fireProducerAdvisory(ConnectionContext context, ActiveMQDestination producerDestination, ActiveMQTopic topic, Command command)
protected void
AdvisoryBroker. fireProducerAdvisory(ConnectionContext context, ActiveMQDestination producerDestination, ActiveMQTopic topic, Command command, ConsumerId targetConsumerId)
-
Uses of Command in org.apache.activemq.broker
Fields in org.apache.activemq.broker with type parameters of type Command Modifier and Type Field Description protected List<Command>
TransportConnection. dispatchQueue
Methods in org.apache.activemq.broker with parameters of type Command Modifier and Type Method Description protected void
TransportConnection. dispatch(Command command)
void
Connection. dispatchAsync(Command command)
Sends a message to the client.void
TransportConnection. dispatchAsync(Command message)
void
Connection. dispatchSync(Command message)
Sends a message to the client.void
TransportConnection. dispatchSync(Command message)
protected void
TransportConnection. processDispatch(Command command)
Response
Connection. service(Command command)
Services a client command and submits it to the broker.Response
TransportConnection. service(Command command)
-
Uses of Command in org.apache.activemq.command
Classes in org.apache.activemq.command that implement Command Modifier and Type Class Description class
ActiveMQBlobMessage
An implementation ofBlobMessage
for out of band BLOB transferclass
ActiveMQBytesMessage
ABytesMessage
object is used to send a message containing a stream of uninterpreted bytes.class
ActiveMQMapMessage
AMapMessage
object is used to send a set of name-value pairs.class
ActiveMQMessage
class
ActiveMQObjectMessage
AnObjectMessage
object is used to send a message that contains a serializable object in the Java programming language ("Java object").class
ActiveMQStreamMessage
AStreamMessage
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
BrokerSubscriptionInfo
Used to represent the durable subscriptions contained by the broker This is used to synchronize durable subs on bridge creationclass
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 ofPartialCommand
instances.class
Message
Represents an ActiveMQ messageclass
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
Fields in org.apache.activemq.command declared as Command Modifier and Type Field Description static Command
FlushCommand. COMMAND
Methods in org.apache.activemq.command with parameters of type Command Modifier and Type Method 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 -
Uses of Command in org.apache.activemq.network
Methods in org.apache.activemq.network with parameters of type Command Modifier and Type Method Description protected void
CompositeDemandForwardingBridge. serviceLocalBrokerInfo(Command command)
protected void
DemandForwardingBridgeSupport. serviceLocalCommand(Command command)
protected void
ForwardingBridge. serviceLocalCommand(Command command)
protected void
DemandForwardingBridgeSupport. serviceRemoteCommand(Command command)
protected void
ForwardingBridge. serviceRemoteCommand(Command command)
-
Uses of Command in org.apache.activemq.openwire
Methods in org.apache.activemq.openwire with parameters of type Command Modifier and Type Method Description int
CommandIdComparator. compare(Command c1, Command c2)
-
Uses of Command in org.apache.activemq.state
Classes in org.apache.activemq.state that implement Command Modifier and Type Class Description class
Tracked
Methods in org.apache.activemq.state that return types with arguments of type Command Modifier and Type Method Description List<Command>
TransactionState. getCommands()
Methods in org.apache.activemq.state with parameters of type Command Modifier and Type Method 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. -
Uses of Command in org.apache.activemq.transport.amqp
Methods in org.apache.activemq.transport.amqp with parameters of type Command Modifier and Type Method Description void
AmqpProtocolConverter. onActiveMQCommand(Command command)
Incoming Command object from ActiveMQ.void
AmqpProtocolDiscriminator. onActiveMQCommand(Command command)
void
AmqpTransport. sendToActiveMQ(Command command)
void
AmqpTransportFilter. sendToActiveMQ(Command command)
-
Uses of Command in org.apache.activemq.transport.amqp.protocol
Methods in org.apache.activemq.transport.amqp.protocol with parameters of type Command Modifier and Type Method Description void
AmqpConnection. onActiveMQCommand(Command command)
protected void
AmqpAbstractLink. sendToActiveMQ(Command command)
Shortcut method to hand off an ActiveMQ Command to the broker and assign a ResponseHandler to deal with any reply from the broker.protected void
AmqpAbstractLink. sendToActiveMQ(Command command, ResponseHandler handler)
Shortcut method to hand off an ActiveMQ Command to the broker and assign a ResponseHandler to deal with any reply from the broker. -
Uses of Command in org.apache.activemq.transport.fanout
Methods in org.apache.activemq.transport.fanout with parameters of type Command Modifier and Type Method Description protected void
FanoutTransport. transportListenerOnCommand(Command command)
-
Uses of Command in org.apache.activemq.transport.mqtt
Methods in org.apache.activemq.transport.mqtt with parameters of type Command Modifier and Type Method Description void
MQTTProtocolConverter. onActiveMQCommand(Command command)
Dispatch an ActiveMQ commandvoid
MQTTProtocolConverter. sendToActiveMQ(Command command, ResponseHandler handler)
void
MQTTTransport. sendToActiveMQ(Command command)
void
MQTTTransportFilter. sendToActiveMQ(Command command)
-
Uses of Command in org.apache.activemq.transport.multicast
Methods in org.apache.activemq.transport.multicast with parameters of type Command Modifier and Type Method Description void
MulticastDatagramHeaderMarshaller. writeHeader(Command command, ByteBuffer writeBuffer)
-
Uses of Command in org.apache.activemq.transport.reliable
Methods in org.apache.activemq.transport.reliable with parameters of type Command Modifier and Type Method Description protected void
ReliableTransport. onMissingResponse(Command command, FutureResponse response)
Deprecated.Lets attempt to replay the request as a command may have disappeared -
Uses of Command in org.apache.activemq.transport.stomp
Classes in org.apache.activemq.transport.stomp that implement Command Modifier and Type Class Description class
StompFrame
Represents all the data in a STOMP frame.class
StompFrameError
Command indicating that an invalid Stomp Frame was received.Methods in org.apache.activemq.transport.stomp with parameters of type Command Modifier and Type Method Description void
ProtocolConverter. onActiveMQCommand(Command command)
Dispatch a ActiveMQ commandprotected void
ProtocolConverter. sendToActiveMQ(Command command, org.apache.activemq.transport.stomp.ResponseHandler handler)
void
StompTransport. sendToActiveMQ(Command command)
void
StompTransportFilter. sendToActiveMQ(Command command)
-
Uses of Command in org.apache.activemq.transport.udp
Methods in org.apache.activemq.transport.udp that return Command Modifier and Type Method Description Command
CommandChannel. read()
Command
CommandDatagramChannel. read()
Command
CommandDatagramSocket. read()
Methods in org.apache.activemq.transport.udp with parameters of type Command Modifier and Type Method Description protected Transport
UdpTransportServer. createTransport(Command command, DatagramEndpoint endpoint)
Deprecated.protected void
UdpTransportServer. processInboundConnection(Command command)
Deprecated.void
CommandChannel. write(Command command, SocketAddress address)
void
CommandChannelSupport. write(Command command)
void
CommandDatagramChannel. write(Command command, SocketAddress address)
void
CommandDatagramSocket. write(Command command, SocketAddress address)
void
DatagramHeaderMarshaller. writeHeader(Command command, DataOutputStream dataOut)
void
DatagramHeaderMarshaller. writeHeader(Command command, ByteBuffer writeBuffer)
-
Uses of Command in org.apache.activemq.transport.ws
Methods in org.apache.activemq.transport.ws with parameters of type Command Modifier and Type Method Description void
AbstractMQTTSocket. sendToActiveMQ(Command command)
void
AbstractStompSocket. sendToActiveMQ(Command command)
-