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.region | |
org.apache.activemq.command |
Command objects used via the Command Pattern to communicate among nodes
|
org.apache.activemq.state |
Modifier and Type | Method and Description |
---|---|
ConsumerId |
ActiveMQMessageConsumer.getConsumerId() |
protected ConsumerId |
ActiveMQSession.getNextConsumerId() |
Modifier and Type | Method and Description |
---|---|
void |
ActiveMQConnection.addDispatcher(ConsumerId consumerId,
ActiveMQDispatcher dispatcher) |
protected void |
ActiveMQSession.close(ConsumerId id) |
boolean |
ActiveMQConnection.hasDispatcher(ConsumerId consumerId) |
void |
ActiveMQConnection.removeDispatcher(ConsumerId consumerId) |
protected void |
ActiveMQSession.setPrefetchSize(ConsumerId id,
int prefetch) |
Constructor and Description |
---|
ActiveMQMessageConsumer(ActiveMQSession session,
ConsumerId consumerId,
ActiveMQDestination dest,
String name,
String selector,
int prefetch,
int maximumPendingMessageCount,
boolean noLocal,
boolean browser,
boolean dispatchAsync,
MessageListener messageListener)
Create a MessageConsumer
|
ActiveMQQueueBrowser(ActiveMQSession session,
ConsumerId consumerId,
ActiveMQDestination destination,
String selector,
boolean dispatchAsync)
Constructor for an ActiveMQQueueBrowser - used internally
|
ActiveMQQueueReceiver(ActiveMQSession theSession,
ConsumerId consumerId,
ActiveMQDestination destination,
String selector,
int prefetch,
int maximumPendingMessageCount,
boolean asyncDispatch) |
ActiveMQTopicSubscriber(ActiveMQSession theSession,
ConsumerId consumerId,
ActiveMQDestination dest,
String name,
String selector,
int prefetch,
int maximumPendingMessageCount,
boolean noLocalValue,
boolean browserValue,
boolean asyncDispatch) |
AdvisoryConsumer(ActiveMQConnection connection,
ConsumerId consumerId) |
Modifier and Type | Method and Description |
---|---|
ConsumerId |
ConsumerEvent.getConsumerId() |
Constructor and Description |
---|
ConsumerEvent(ConsumerEventSource source,
Destination destination,
ConsumerId consumerId,
int consumerCount) |
ConsumerStoppedEvent(ConsumerEventSource source,
ActiveMQDestination destination,
ConsumerId consumerId,
int count) |
Modifier and Type | Method and Description |
---|---|
ConsumerId |
MessageReference.getTargetConsumerId() |
Modifier and Type | Field and Description |
---|---|
protected ConsumerId |
MessageDispatchNotification.consumerId |
protected ConsumerId |
ConsumerInfo.consumerId |
protected ConsumerId |
MessagePull.consumerId |
protected ConsumerId |
MessageAck.consumerId |
protected ConsumerId |
ConsumerControl.consumerId |
protected ConsumerId |
MessageDispatch.consumerId |
protected ConsumerId |
Message.targetConsumerId |
Modifier and Type | Field and Description |
---|---|
protected List<ConsumerId> |
ConsumerInfo.networkConsumerIds |
Modifier and Type | Method and Description |
---|---|
ConsumerId |
MessageDispatchNotification.getConsumerId() |
ConsumerId |
ConsumerInfo.getConsumerId()
Is used to uniquely identify the consumer to the broker.
|
ConsumerId |
MessagePull.getConsumerId() |
ConsumerId |
MessageAck.getConsumerId() |
ConsumerId |
ConsumerControl.getConsumerId() |
ConsumerId |
MessageDispatch.getConsumerId() |
ConsumerId[] |
ConsumerInfo.getNetworkConsumerPath()
Tracks the original subscription id that causes a subscription to
percolate through a network when networkTTL > 1.
|
ConsumerId |
Message.getTargetConsumerId()
Can be used to route the message to a specific consumer.
|
Modifier and Type | Method and Description |
---|---|
List<ConsumerId> |
ConsumerInfo.getNetworkConsumerIds() |
Modifier and Type | Method and Description |
---|---|
void |
ConsumerInfo.addNetworkConsumerId(ConsumerId networkConsumerId) |
void |
ConsumerInfo.removeNetworkConsumerId(ConsumerId networkConsumerId) |
void |
MessageDispatchNotification.setConsumerId(ConsumerId consumerId) |
void |
ConsumerInfo.setConsumerId(ConsumerId consumerId) |
void |
MessagePull.setConsumerId(ConsumerId consumerId) |
void |
MessageAck.setConsumerId(ConsumerId consumerId) |
void |
ConsumerControl.setConsumerId(ConsumerId consumerId) |
void |
MessageDispatch.setConsumerId(ConsumerId consumerId) |
void |
ConsumerInfo.setNetworkConsumerPath(ConsumerId[] consumerPath) |
void |
Message.setTargetConsumerId(ConsumerId targetConsumerId) |
Constructor and Description |
---|
ConnectionId(ConsumerId id) |
ConsumerId(ConsumerId id) |
ConsumerInfo(ConsumerId consumerId) |
SessionId(ConsumerId id) |
Modifier and Type | Method and Description |
---|---|
Set<ConsumerId> |
SessionState.getConsumerIds() |
Map<ConsumerId,ConsumerInfo> |
ConnectionState.getRecoveringPullConsumers() |
Modifier and Type | Method and Description |
---|---|
ConsumerState |
SessionState.getConsumerState(ConsumerId consumerId) |
Response |
ConnectionStateTracker.processRemoveConsumer(ConsumerId id,
long lastDeliveredSequenceId) |
Response |
CommandVisitorAdapter.processRemoveConsumer(ConsumerId id,
long lastDeliveredSequenceId) |
Response |
CommandVisitor.processRemoveConsumer(ConsumerId id,
long lastDeliveredSequenceId) |
ConsumerState |
SessionState.removeConsumer(ConsumerId id) |
Copyright © 2005–2016 FuseSource, Corp.. All rights reserved.