|
||||||||||
PREV NEXT | FRAMES NO FRAMES |
Packages that use Command | |
---|---|
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.broker.ft | Helper classes for implementing fault tolerance |
org.apache.activemq.command | Command objects used via the Command Pattern to communicate among nodes |
org.apache.activemq.kaha | fast message persistence implementation |
org.apache.activemq.network | Support for federated networks of brokers. |
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.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. |
Uses of Command in org.apache.activemq |
---|
Methods in org.apache.activemq with parameters of type Command | |
---|---|
void |
ActiveMQSession.asyncSendPacket(Command command)
Send the asynchronus command. |
void |
ActiveMQConnection.asyncSendPacket(Command command)
send a Packet through the Connection - for internal use only |
Response |
ActiveMQSession.syncSendPacket(Command command)
Send the synchronus command. |
Response |
ActiveMQConnection.syncSendPacket(Command command)
Send a packet through a Connection - for internal use only |
Response |
ActiveMQConnection.syncSendPacket(Command command,
int timeout)
Send a packet through a Connection - for internal use only |
Uses of Command in org.apache.activemq.advisory |
---|
Methods in org.apache.activemq.advisory with parameters of type Command | |
---|---|
protected void |
AdvisoryBroker.fireAdvisory(ConnectionContext context,
ActiveMQTopic topic,
Command command)
|
protected void |
AdvisoryBroker.fireAdvisory(ConnectionContext context,
ActiveMQTopic topic,
Command command,
ConsumerId targetConsumerId)
|
protected 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 | |
---|---|
protected java.util.List<Command> |
TransportConnection.dispatchQueue
|
Methods in org.apache.activemq.broker with parameters of type Command | |
---|---|
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.broker.ft |
---|
Methods in org.apache.activemq.broker.ft with parameters of type Command | |
---|---|
protected void |
MasterBroker.sendAsyncToSlave(Command command)
|
protected void |
MasterBroker.sendSyncToSlave(Command command)
|
protected void |
MasterConnector.serviceRemoteCommand(Command command)
|
Uses of Command in org.apache.activemq.command |
---|
Classes in org.apache.activemq.command that implement Command | |
---|---|
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
|
Fields in org.apache.activemq.command declared as Command | |
---|---|
static Command |
FlushCommand.COMMAND
|
Methods in org.apache.activemq.command with parameters of type Command | |
---|---|
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.kaha |
---|
Classes in org.apache.activemq.kaha that implement Command | |
---|---|
class |
MessageAckWithLocation
|
Uses of Command in org.apache.activemq.network |
---|
Methods in org.apache.activemq.network with parameters of type Command | |
---|---|
protected BrokerId |
CompositeDemandForwardingBridge.getFromBrokerId(Command command)
Returns the broker ID that the command came from |
protected void |
DemandForwardingBridge.serviceLocalBrokerInfo(Command command)
|
protected abstract void |
DemandForwardingBridgeSupport.serviceLocalBrokerInfo(Command command)
|
protected void |
CompositeDemandForwardingBridge.serviceLocalBrokerInfo(Command command)
|
protected void |
DemandForwardingBridgeSupport.serviceLocalCommand(Command command)
|
protected void |
ForwardingBridge.serviceLocalCommand(Command command)
|
protected void |
DemandForwardingBridge.serviceRemoteBrokerInfo(Command command)
|
protected abstract void |
DemandForwardingBridgeSupport.serviceRemoteBrokerInfo(Command command)
|
protected void |
CompositeDemandForwardingBridge.serviceRemoteBrokerInfo(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 | |
---|---|
int |
CommandIdComparator.compare(Command c1,
Command c2)
|
Uses of Command in org.apache.activemq.state |
---|
Classes in org.apache.activemq.state that implement Command | |
---|---|
class |
Tracked
|
Methods in org.apache.activemq.state that return types with arguments of type Command | |
---|---|
java.util.List<Command> |
TransactionState.getCommands()
|
Methods in org.apache.activemq.state with parameters of type Command | |
---|---|
void |
TransactionState.addCommand(Command operation)
|
void |
ResponseHandler.onResponse(Command command)
|
void |
Tracked.onResponses(Command command)
|
Tracked |
ConnectionStateTracker.track(Command command)
|
void |
ConnectionStateTracker.trackBack(Command command)
|
Uses of Command in org.apache.activemq.transport.fanout |
---|
Methods in org.apache.activemq.transport.fanout with parameters of type Command | |
---|---|
protected void |
FanoutTransport.transportListenerOnCommand(Command command)
|
Uses of Command in org.apache.activemq.transport.multicast |
---|
Methods in org.apache.activemq.transport.multicast with parameters of type Command | |
---|---|
void |
MulticastDatagramHeaderMarshaller.writeHeader(Command command,
java.nio.ByteBuffer writeBuffer)
|
Uses of Command in org.apache.activemq.transport.reliable |
---|
Methods in org.apache.activemq.transport.reliable with parameters of type Command | |
---|---|
protected void |
ReliableTransport.onMissingResponse(Command command,
FutureResponse response)
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 | |
---|---|
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 | |
---|---|
void |
ProtocolConverter.onActiveMQCommand(Command command)
Dispatch a ActiveMQ command |
void |
StompTransportFilter.sendToActiveMQ(Command command)
|
void |
StompTransport.sendToActiveMQ(Command command)
|
protected void |
ProtocolConverter.sendToActiveMQ(Command command,
org.apache.activemq.transport.stomp.ResponseHandler handler)
|
Uses of Command in org.apache.activemq.transport.udp |
---|
Methods in org.apache.activemq.transport.udp that return Command | |
---|---|
Command |
CommandDatagramSocket.read()
|
Command |
CommandChannel.read()
|
Command |
CommandDatagramChannel.read()
|
Methods in org.apache.activemq.transport.udp with parameters of type Command | |
---|---|
protected Transport |
UdpTransportServer.createTransport(Command command,
DatagramEndpoint endpoint)
|
protected void |
UdpTransportServer.processInboundConnection(Command command)
|
void |
CommandChannelSupport.write(Command command)
|
void |
CommandDatagramSocket.write(Command command,
java.net.SocketAddress address)
|
void |
CommandChannel.write(Command command,
java.net.SocketAddress address)
|
void |
CommandDatagramChannel.write(Command command,
java.net.SocketAddress address)
|
void |
DatagramHeaderMarshaller.writeHeader(Command command,
java.nio.ByteBuffer writeBuffer)
|
void |
DatagramHeaderMarshaller.writeHeader(Command command,
java.io.DataOutputStream dataOut)
|
|
||||||||||
PREV NEXT | FRAMES NO FRAMES |