Package | Description |
---|---|
org.apache.activemq.command |
Command objects used via the Command Pattern to communicate among nodes
|
org.apache.activemq.filter |
Filter implementations for wildcards & JMS selectors
|
org.apache.activemq.openwire | |
org.apache.activemq.openwire.v1 | |
org.apache.activemq.openwire.v10 | |
org.apache.activemq.openwire.v9 | |
org.apache.activemq.state |
Modifier and Type | Interface and Description |
---|---|
interface |
Command
The Command Pattern so that we can send and receive commands on the different
transports
|
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 |
ActiveMQDestination |
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 |
ActiveMQQueue |
class |
ActiveMQStreamMessage
A
StreamMessage object is used to send a stream of primitive
types in the Java programming language. |
class |
ActiveMQTempDestination |
class |
ActiveMQTempQueue |
class |
ActiveMQTempTopic |
class |
ActiveMQTextMessage |
class |
ActiveMQTopic |
class |
BaseCommand |
class |
BrokerId |
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 |
ConnectionId |
class |
ConnectionInfo |
class |
ConsumerControl
Used to start and stop transports as well as terminating clients.
|
class |
ConsumerId |
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 |
DiscoveryEvent
Represents a discovery event containing the details of the service
|
class |
ExceptionResponse |
class |
FlushCommand
An indication to the transport layer that a flush is required.
|
class |
IntegerResponse |
class |
JournalQueueAck |
class |
JournalTopicAck |
class |
JournalTrace |
class |
JournalTransaction |
class |
KeepAliveInfo |
class |
LastPartialCommand
Represents the end marker of a stream of
PartialCommand instances. |
class |
LocalTransactionId |
class |
Message
Represents an ActiveMQ message
|
class |
MessageAck |
class |
MessageDispatch |
class |
MessageDispatchNotification |
class |
MessageId |
class |
MessagePull
Used to pull messages on demand.
|
class |
NetworkBridgeFilter |
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 |
ProducerId |
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 |
SessionId |
class |
SessionInfo |
class |
ShutdownInfo |
class |
SubscriptionInfo
Used to represent a durable subscription.
|
class |
TransactionId |
class |
TransactionInfo |
class |
WireFormatInfo |
class |
XATransactionId |
Modifier and Type | Field and Description |
---|---|
protected DataStructure |
Message.dataStructure |
protected DataStructure |
RemoveInfo.objectId |
Modifier and Type | Method and Description |
---|---|
DataStructure[] |
DataArrayResponse.getData() |
DataStructure |
DataResponse.getData() |
DataStructure |
Message.getDataStructure() |
DataStructure |
RemoveInfo.getObjectId() |
Modifier and Type | Method and Description |
---|---|
void |
DataResponse.setData(DataStructure data) |
void |
DataArrayResponse.setData(DataStructure[] data) |
void |
Message.setDataStructure(DataStructure data) |
void |
RemoveInfo.setObjectId(DataStructure objectId) |
Constructor and Description |
---|
DataArrayResponse(DataStructure[] data) |
DataResponse(DataStructure data) |
RemoveInfo(DataStructure objectId) |
Modifier and Type | Class and Description |
---|---|
class |
AnyDestination |
Modifier and Type | Method and Description |
---|---|
DataStructure |
DataStreamMarshaller.createObject() |
DataStructure |
OpenWireFormat.getFromUnmarshallCache(short index) |
DataStructure |
OpenWireFormat.looseUnmarshalNestedObject(DataInput dis) |
DataStructure |
OpenWireFormat.tightUnmarshalNestedObject(DataInput dis,
BooleanStream bs) |
Modifier and Type | Method and Description |
---|---|
Short |
OpenWireFormat.addToMarshallCache(DataStructure o) |
Short |
OpenWireFormat.getMarshallCacheIndex(DataStructure o) |
void |
OpenWireFormat.looseMarshalNestedObject(DataStructure o,
DataOutput dataOut) |
void |
OpenWireFormat.setInUnmarshallCache(short index,
DataStructure o) |
int |
OpenWireFormat.tightMarshalNestedObject1(DataStructure o,
BooleanStream bs) |
void |
OpenWireFormat.tightMarshalNestedObject2(DataStructure o,
DataOutput ds,
BooleanStream bs) |
Modifier and Type | Method and Description |
---|---|
DataStructure |
RemoveInfoMarshaller.createObject() |
DataStructure |
ActiveMQStreamMessageMarshaller.createObject() |
DataStructure |
ConnectionInfoMarshaller.createObject() |
DataStructure |
SessionInfoMarshaller.createObject() |
DataStructure |
ProducerIdMarshaller.createObject() |
DataStructure |
ConsumerInfoMarshaller.createObject() |
DataStructure |
ActiveMQTopicMarshaller.createObject() |
DataStructure |
ActiveMQTempQueueMarshaller.createObject() |
DataStructure |
ActiveMQTextMessageMarshaller.createObject() |
DataStructure |
XATransactionIdMarshaller.createObject() |
DataStructure |
SessionIdMarshaller.createObject() |
DataStructure |
ReplayCommandMarshaller.createObject() |
DataStructure |
ShutdownInfoMarshaller.createObject() |
DataStructure |
ResponseMarshaller.createObject() |
DataStructure |
ConsumerControlMarshaller.createObject() |
DataStructure |
NetworkBridgeFilterMarshaller.createObject() |
DataStructure |
JournalTopicAckMarshaller.createObject() |
DataStructure |
DataResponseMarshaller.createObject() |
DataStructure |
PartialCommandMarshaller.createObject() |
DataStructure |
ConnectionErrorMarshaller.createObject() |
DataStructure |
ProducerInfoMarshaller.createObject() |
DataStructure |
JournalTraceMarshaller.createObject() |
DataStructure |
ActiveMQObjectMessageMarshaller.createObject() |
DataStructure |
DiscoveryEventMarshaller.createObject() |
DataStructure |
KeepAliveInfoMarshaller.createObject() |
DataStructure |
BrokerInfoMarshaller.createObject() |
DataStructure |
DestinationInfoMarshaller.createObject() |
DataStructure |
ActiveMQBytesMessageMarshaller.createObject() |
DataStructure |
JournalQueueAckMarshaller.createObject() |
DataStructure |
JournalTransactionMarshaller.createObject() |
DataStructure |
ActiveMQMapMessageMarshaller.createObject() |
DataStructure |
ControlCommandMarshaller.createObject() |
DataStructure |
MessageDispatchMarshaller.createObject() |
DataStructure |
ConsumerIdMarshaller.createObject() |
DataStructure |
WireFormatInfoMarshaller.createObject() |
DataStructure |
LastPartialCommandMarshaller.createObject() |
DataStructure |
MessageDispatchNotificationMarshaller.createObject() |
DataStructure |
MessageAckMarshaller.createObject() |
DataStructure |
ConnectionControlMarshaller.createObject() |
DataStructure |
FlushCommandMarshaller.createObject() |
DataStructure |
TransactionInfoMarshaller.createObject() |
DataStructure |
ActiveMQQueueMarshaller.createObject() |
abstract DataStructure |
BaseDataStreamMarshaller.createObject() |
DataStructure |
ExceptionResponseMarshaller.createObject() |
DataStructure |
DataArrayResponseMarshaller.createObject() |
DataStructure |
ConnectionIdMarshaller.createObject() |
DataStructure |
SubscriptionInfoMarshaller.createObject() |
DataStructure |
MessageIdMarshaller.createObject() |
DataStructure |
ActiveMQMessageMarshaller.createObject() |
DataStructure |
RemoveSubscriptionInfoMarshaller.createObject() |
DataStructure |
IntegerResponseMarshaller.createObject() |
DataStructure |
LocalTransactionIdMarshaller.createObject() |
DataStructure |
BrokerIdMarshaller.createObject() |
DataStructure |
ActiveMQTempTopicMarshaller.createObject() |
protected DataStructure |
BaseDataStreamMarshaller.looseUnmarsalCachedObject(OpenWireFormat wireFormat,
DataInput dataIn) |
protected DataStructure |
BaseDataStreamMarshaller.looseUnmarsalNestedObject(OpenWireFormat wireFormat,
DataInput dataIn) |
protected DataStructure |
BaseDataStreamMarshaller.tightUnmarsalCachedObject(OpenWireFormat wireFormat,
DataInput dataIn,
BooleanStream bs) |
protected DataStructure |
BaseDataStreamMarshaller.tightUnmarsalNestedObject(OpenWireFormat wireFormat,
DataInput dataIn,
BooleanStream bs) |
Modifier and Type | Method and Description |
---|---|
protected void |
BaseDataStreamMarshaller.looseMarshalCachedObject(OpenWireFormat wireFormat,
DataStructure o,
DataOutput dataOut) |
protected void |
BaseDataStreamMarshaller.looseMarshalNestedObject(OpenWireFormat wireFormat,
DataStructure o,
DataOutput dataOut) |
protected void |
BaseDataStreamMarshaller.looseMarshalObjectArray(OpenWireFormat wireFormat,
DataStructure[] objects,
DataOutput dataOut) |
protected int |
BaseDataStreamMarshaller.tightMarshalCachedObject1(OpenWireFormat wireFormat,
DataStructure o,
BooleanStream bs) |
protected void |
BaseDataStreamMarshaller.tightMarshalCachedObject2(OpenWireFormat wireFormat,
DataStructure o,
DataOutput dataOut,
BooleanStream bs) |
protected int |
BaseDataStreamMarshaller.tightMarshalNestedObject1(OpenWireFormat wireFormat,
DataStructure o,
BooleanStream bs) |
protected void |
BaseDataStreamMarshaller.tightMarshalNestedObject2(OpenWireFormat wireFormat,
DataStructure o,
DataOutput dataOut,
BooleanStream bs) |
protected int |
BaseDataStreamMarshaller.tightMarshalObjectArray1(OpenWireFormat wireFormat,
DataStructure[] objects,
BooleanStream bs) |
protected void |
BaseDataStreamMarshaller.tightMarshalObjectArray2(OpenWireFormat wireFormat,
DataStructure[] objects,
DataOutput dataOut,
BooleanStream bs) |
Modifier and Type | Method and Description |
---|---|
DataStructure |
RemoveInfoMarshaller.createObject() |
DataStructure |
ActiveMQStreamMessageMarshaller.createObject() |
DataStructure |
ConnectionInfoMarshaller.createObject() |
DataStructure |
SessionInfoMarshaller.createObject() |
DataStructure |
ProducerIdMarshaller.createObject() |
DataStructure |
ConsumerInfoMarshaller.createObject() |
DataStructure |
ActiveMQTopicMarshaller.createObject() |
DataStructure |
ActiveMQTempQueueMarshaller.createObject() |
DataStructure |
ActiveMQTextMessageMarshaller.createObject() |
DataStructure |
XATransactionIdMarshaller.createObject() |
DataStructure |
SessionIdMarshaller.createObject() |
DataStructure |
ReplayCommandMarshaller.createObject() |
DataStructure |
ShutdownInfoMarshaller.createObject() |
DataStructure |
ResponseMarshaller.createObject() |
DataStructure |
ConsumerControlMarshaller.createObject() |
DataStructure |
NetworkBridgeFilterMarshaller.createObject() |
DataStructure |
JournalTopicAckMarshaller.createObject() |
DataStructure |
DataResponseMarshaller.createObject() |
DataStructure |
PartialCommandMarshaller.createObject() |
DataStructure |
ConnectionErrorMarshaller.createObject() |
DataStructure |
ProducerInfoMarshaller.createObject() |
DataStructure |
JournalTraceMarshaller.createObject() |
DataStructure |
ActiveMQObjectMessageMarshaller.createObject() |
DataStructure |
DiscoveryEventMarshaller.createObject() |
DataStructure |
KeepAliveInfoMarshaller.createObject() |
DataStructure |
BrokerInfoMarshaller.createObject() |
DataStructure |
DestinationInfoMarshaller.createObject() |
DataStructure |
ActiveMQBytesMessageMarshaller.createObject() |
DataStructure |
JournalQueueAckMarshaller.createObject() |
DataStructure |
JournalTransactionMarshaller.createObject() |
DataStructure |
ActiveMQMapMessageMarshaller.createObject() |
DataStructure |
ControlCommandMarshaller.createObject() |
DataStructure |
MessageDispatchMarshaller.createObject() |
DataStructure |
ConsumerIdMarshaller.createObject() |
DataStructure |
WireFormatInfoMarshaller.createObject() |
DataStructure |
LastPartialCommandMarshaller.createObject() |
DataStructure |
MessageDispatchNotificationMarshaller.createObject() |
DataStructure |
MessageAckMarshaller.createObject() |
DataStructure |
ConnectionControlMarshaller.createObject() |
DataStructure |
FlushCommandMarshaller.createObject() |
DataStructure |
TransactionInfoMarshaller.createObject() |
DataStructure |
ActiveMQQueueMarshaller.createObject() |
abstract DataStructure |
BaseDataStreamMarshaller.createObject() |
DataStructure |
ExceptionResponseMarshaller.createObject() |
DataStructure |
DataArrayResponseMarshaller.createObject() |
DataStructure |
ConnectionIdMarshaller.createObject() |
DataStructure |
MessagePullMarshaller.createObject() |
DataStructure |
SubscriptionInfoMarshaller.createObject() |
DataStructure |
ProducerAckMarshaller.createObject() |
DataStructure |
MessageIdMarshaller.createObject() |
DataStructure |
ActiveMQMessageMarshaller.createObject() |
DataStructure |
RemoveSubscriptionInfoMarshaller.createObject() |
DataStructure |
IntegerResponseMarshaller.createObject() |
DataStructure |
ActiveMQBlobMessageMarshaller.createObject() |
DataStructure |
LocalTransactionIdMarshaller.createObject() |
DataStructure |
BrokerIdMarshaller.createObject() |
DataStructure |
ActiveMQTempTopicMarshaller.createObject() |
protected DataStructure |
BaseDataStreamMarshaller.looseUnmarsalCachedObject(OpenWireFormat wireFormat,
DataInput dataIn) |
protected DataStructure |
BaseDataStreamMarshaller.looseUnmarsalNestedObject(OpenWireFormat wireFormat,
DataInput dataIn) |
protected DataStructure |
BaseDataStreamMarshaller.tightUnmarsalCachedObject(OpenWireFormat wireFormat,
DataInput dataIn,
BooleanStream bs) |
protected DataStructure |
BaseDataStreamMarshaller.tightUnmarsalNestedObject(OpenWireFormat wireFormat,
DataInput dataIn,
BooleanStream bs) |
Modifier and Type | Method and Description |
---|---|
protected void |
BaseDataStreamMarshaller.looseMarshalCachedObject(OpenWireFormat wireFormat,
DataStructure o,
DataOutput dataOut) |
protected void |
BaseDataStreamMarshaller.looseMarshalNestedObject(OpenWireFormat wireFormat,
DataStructure o,
DataOutput dataOut) |
protected void |
BaseDataStreamMarshaller.looseMarshalObjectArray(OpenWireFormat wireFormat,
DataStructure[] objects,
DataOutput dataOut) |
protected int |
BaseDataStreamMarshaller.tightMarshalCachedObject1(OpenWireFormat wireFormat,
DataStructure o,
BooleanStream bs) |
protected void |
BaseDataStreamMarshaller.tightMarshalCachedObject2(OpenWireFormat wireFormat,
DataStructure o,
DataOutput dataOut,
BooleanStream bs) |
protected int |
BaseDataStreamMarshaller.tightMarshalNestedObject1(OpenWireFormat wireFormat,
DataStructure o,
BooleanStream bs) |
protected void |
BaseDataStreamMarshaller.tightMarshalNestedObject2(OpenWireFormat wireFormat,
DataStructure o,
DataOutput dataOut,
BooleanStream bs) |
protected int |
BaseDataStreamMarshaller.tightMarshalObjectArray1(OpenWireFormat wireFormat,
DataStructure[] objects,
BooleanStream bs) |
protected void |
BaseDataStreamMarshaller.tightMarshalObjectArray2(OpenWireFormat wireFormat,
DataStructure[] objects,
DataOutput dataOut,
BooleanStream bs) |
Modifier and Type | Method and Description |
---|---|
DataStructure |
RemoveInfoMarshaller.createObject() |
DataStructure |
ActiveMQStreamMessageMarshaller.createObject() |
DataStructure |
ConnectionInfoMarshaller.createObject() |
DataStructure |
SessionInfoMarshaller.createObject() |
DataStructure |
ProducerIdMarshaller.createObject() |
DataStructure |
ConsumerInfoMarshaller.createObject() |
DataStructure |
ActiveMQTopicMarshaller.createObject() |
DataStructure |
ActiveMQTempQueueMarshaller.createObject() |
DataStructure |
ActiveMQTextMessageMarshaller.createObject() |
DataStructure |
XATransactionIdMarshaller.createObject() |
DataStructure |
SessionIdMarshaller.createObject() |
DataStructure |
ReplayCommandMarshaller.createObject() |
DataStructure |
ShutdownInfoMarshaller.createObject() |
DataStructure |
ResponseMarshaller.createObject() |
DataStructure |
ConsumerControlMarshaller.createObject() |
DataStructure |
NetworkBridgeFilterMarshaller.createObject() |
DataStructure |
JournalTopicAckMarshaller.createObject() |
DataStructure |
DataResponseMarshaller.createObject() |
DataStructure |
PartialCommandMarshaller.createObject() |
DataStructure |
ConnectionErrorMarshaller.createObject() |
DataStructure |
ProducerInfoMarshaller.createObject() |
DataStructure |
JournalTraceMarshaller.createObject() |
DataStructure |
ActiveMQObjectMessageMarshaller.createObject() |
DataStructure |
DiscoveryEventMarshaller.createObject() |
DataStructure |
KeepAliveInfoMarshaller.createObject() |
DataStructure |
BrokerInfoMarshaller.createObject() |
DataStructure |
DestinationInfoMarshaller.createObject() |
DataStructure |
ActiveMQBytesMessageMarshaller.createObject() |
DataStructure |
JournalQueueAckMarshaller.createObject() |
DataStructure |
JournalTransactionMarshaller.createObject() |
DataStructure |
ActiveMQMapMessageMarshaller.createObject() |
DataStructure |
ControlCommandMarshaller.createObject() |
DataStructure |
MessageDispatchMarshaller.createObject() |
DataStructure |
ConsumerIdMarshaller.createObject() |
DataStructure |
WireFormatInfoMarshaller.createObject() |
DataStructure |
LastPartialCommandMarshaller.createObject() |
DataStructure |
MessageDispatchNotificationMarshaller.createObject() |
DataStructure |
MessageAckMarshaller.createObject() |
DataStructure |
ConnectionControlMarshaller.createObject() |
DataStructure |
FlushCommandMarshaller.createObject() |
DataStructure |
TransactionInfoMarshaller.createObject() |
DataStructure |
ActiveMQQueueMarshaller.createObject() |
abstract DataStructure |
BaseDataStreamMarshaller.createObject() |
DataStructure |
ExceptionResponseMarshaller.createObject() |
DataStructure |
DataArrayResponseMarshaller.createObject() |
DataStructure |
ConnectionIdMarshaller.createObject() |
DataStructure |
MessagePullMarshaller.createObject() |
DataStructure |
SubscriptionInfoMarshaller.createObject() |
DataStructure |
ProducerAckMarshaller.createObject() |
DataStructure |
MessageIdMarshaller.createObject() |
DataStructure |
ActiveMQMessageMarshaller.createObject() |
DataStructure |
RemoveSubscriptionInfoMarshaller.createObject() |
DataStructure |
IntegerResponseMarshaller.createObject() |
DataStructure |
ActiveMQBlobMessageMarshaller.createObject() |
DataStructure |
LocalTransactionIdMarshaller.createObject() |
DataStructure |
BrokerIdMarshaller.createObject() |
DataStructure |
ActiveMQTempTopicMarshaller.createObject() |
protected DataStructure |
BaseDataStreamMarshaller.looseUnmarsalCachedObject(OpenWireFormat wireFormat,
DataInput dataIn) |
protected DataStructure |
BaseDataStreamMarshaller.looseUnmarsalNestedObject(OpenWireFormat wireFormat,
DataInput dataIn) |
protected DataStructure |
BaseDataStreamMarshaller.tightUnmarsalCachedObject(OpenWireFormat wireFormat,
DataInput dataIn,
BooleanStream bs) |
protected DataStructure |
BaseDataStreamMarshaller.tightUnmarsalNestedObject(OpenWireFormat wireFormat,
DataInput dataIn,
BooleanStream bs) |
Modifier and Type | Method and Description |
---|---|
protected void |
BaseDataStreamMarshaller.looseMarshalCachedObject(OpenWireFormat wireFormat,
DataStructure o,
DataOutput dataOut) |
protected void |
BaseDataStreamMarshaller.looseMarshalNestedObject(OpenWireFormat wireFormat,
DataStructure o,
DataOutput dataOut) |
protected void |
BaseDataStreamMarshaller.looseMarshalObjectArray(OpenWireFormat wireFormat,
DataStructure[] objects,
DataOutput dataOut) |
protected int |
BaseDataStreamMarshaller.tightMarshalCachedObject1(OpenWireFormat wireFormat,
DataStructure o,
BooleanStream bs) |
protected void |
BaseDataStreamMarshaller.tightMarshalCachedObject2(OpenWireFormat wireFormat,
DataStructure o,
DataOutput dataOut,
BooleanStream bs) |
protected int |
BaseDataStreamMarshaller.tightMarshalNestedObject1(OpenWireFormat wireFormat,
DataStructure o,
BooleanStream bs) |
protected void |
BaseDataStreamMarshaller.tightMarshalNestedObject2(OpenWireFormat wireFormat,
DataStructure o,
DataOutput dataOut,
BooleanStream bs) |
protected int |
BaseDataStreamMarshaller.tightMarshalObjectArray1(OpenWireFormat wireFormat,
DataStructure[] objects,
BooleanStream bs) |
protected void |
BaseDataStreamMarshaller.tightMarshalObjectArray2(OpenWireFormat wireFormat,
DataStructure[] objects,
DataOutput dataOut,
BooleanStream bs) |
Modifier and Type | Class and Description |
---|---|
class |
Tracked |
Copyright © 2005–2016 FuseSource, Corp.. All rights reserved.