|
||||||||||
PREV NEXT | FRAMES NO FRAMES |
Packages that use ConsumerId | |
---|---|
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.region | Region abstraction and implementations in the Broker. |
org.apache.activemq.broker.region.group | Classes to implement the Message Groups feature. |
org.apache.activemq.command | Command objects used via the Command Pattern to communicate among nodes |
org.apache.activemq.network | Support for federated networks of brokers. |
org.apache.activemq.state |
Uses of ConsumerId in org.apache.activemq |
---|
Methods in org.apache.activemq that return ConsumerId | |
---|---|
ConsumerId |
ActiveMQMessageConsumer.getConsumerId()
|
protected ConsumerId |
ActiveMQSession.getNextConsumerId()
|
Methods in org.apache.activemq with parameters of type ConsumerId | |
---|---|
void |
ActiveMQConnection.addDispatcher(ConsumerId consumerId,
ActiveMQDispatcher dispatcher)
|
protected void |
ActiveMQSession.close(ConsumerId id)
|
void |
ActiveMQConnection.removeDispatcher(ConsumerId consumerId)
|
protected void |
ActiveMQSession.setPrefetchSize(ConsumerId id,
int prefetch)
|
Constructors in org.apache.activemq with parameters of type ConsumerId | |
---|---|
ActiveMQInputStream(ActiveMQConnection connection,
ConsumerId consumerId,
ActiveMQDestination dest,
java.lang.String selector,
boolean noLocal,
java.lang.String name,
int prefetch,
long timeout)
|
|
ActiveMQMessageConsumer(ActiveMQSession session,
ConsumerId consumerId,
ActiveMQDestination dest,
java.lang.String name,
java.lang.String selector,
int prefetch,
int maximumPendingMessageCount,
boolean noLocal,
boolean browser,
boolean dispatchAsync,
javax.jms.MessageListener messageListener)
Create a MessageConsumer |
|
ActiveMQQueueBrowser(ActiveMQSession session,
ConsumerId consumerId,
ActiveMQDestination destination,
java.lang.String selector,
boolean dispatchAsync)
Constructor for an ActiveMQQueueBrowser - used internally |
|
ActiveMQQueueReceiver(ActiveMQSession theSession,
ConsumerId consumerId,
ActiveMQDestination destination,
java.lang.String selector,
int prefetch,
int maximumPendingMessageCount,
boolean asyncDispatch)
|
|
ActiveMQTopicSubscriber(ActiveMQSession theSession,
ConsumerId consumerId,
ActiveMQDestination dest,
java.lang.String name,
java.lang.String selector,
int prefetch,
int maximumPendingMessageCount,
boolean noLocalValue,
boolean browserValue,
boolean asyncDispatch)
|
|
AdvisoryConsumer(ActiveMQConnection connection,
ConsumerId consumerId)
|
Uses of ConsumerId in org.apache.activemq.advisory |
---|
Fields in org.apache.activemq.advisory with type parameters of type ConsumerId | |
---|---|
protected java.util.concurrent.ConcurrentHashMap<ConsumerId,ConsumerInfo> |
AdvisoryBroker.consumers
|
Methods in org.apache.activemq.advisory that return ConsumerId | |
---|---|
ConsumerId |
ConsumerEvent.getConsumerId()
|
Methods in org.apache.activemq.advisory that return types with arguments of type ConsumerId | |
---|---|
java.util.Map<ConsumerId,ConsumerInfo> |
AdvisoryBroker.getAdvisoryConsumers()
|
Methods in org.apache.activemq.advisory with parameters of type ConsumerId | |
---|---|
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,
ConsumerId targetConsumerId)
|
protected void |
AdvisoryBroker.fireProducerAdvisory(ConnectionContext context,
ActiveMQDestination producerDestination,
ActiveMQTopic topic,
Command command,
ConsumerId targetConsumerId)
|
Constructors in org.apache.activemq.advisory with parameters of type ConsumerId | |
---|---|
ConsumerEvent(ConsumerEventSource source,
javax.jms.Destination destination,
ConsumerId consumerId,
int consumerCount)
|
|
ConsumerStoppedEvent(ConsumerEventSource source,
ActiveMQDestination destination,
ConsumerId consumerId,
int count)
|
Uses of ConsumerId in org.apache.activemq.broker |
---|
Methods in org.apache.activemq.broker with parameters of type ConsumerId | |
---|---|
TransportConnectionState |
MapTransportConnectionStateRegister.lookupConnectionState(ConsumerId id)
|
protected TransportConnectionState |
TransportConnection.lookupConnectionState(ConsumerId id)
|
TransportConnectionState |
SingleTransportConnectionStateRegister.lookupConnectionState(ConsumerId id)
|
TransportConnectionState |
TransportConnectionStateRegister.lookupConnectionState(ConsumerId id)
|
Response |
TransportConnection.processRemoveConsumer(ConsumerId id,
long lastDeliveredSequenceId)
|
Uses of ConsumerId in org.apache.activemq.broker.region |
---|
Fields in org.apache.activemq.broker.region with type parameters of type ConsumerId | |
---|---|
protected java.util.Map<ConsumerId,java.lang.Object> |
AbstractRegion.consumerChangeMutexMap
|
protected java.util.Map<ConsumerId,Subscription> |
AbstractRegion.subscriptions
|
Methods in org.apache.activemq.broker.region that return ConsumerId | |
---|---|
ConsumerId |
MessageReference.getTargetConsumerId()
|
ConsumerId |
IndirectMessageReference.getTargetConsumerId()
|
Methods in org.apache.activemq.broker.region that return types with arguments of type ConsumerId | |
---|---|
java.util.Map<ConsumerId,Subscription> |
AbstractRegion.getSubscriptions()
|
Uses of ConsumerId in org.apache.activemq.broker.region.group |
---|
Methods in org.apache.activemq.broker.region.group that return ConsumerId | |
---|---|
ConsumerId |
MessageGroupHashBucket.get(java.lang.String groupId)
|
ConsumerId |
MessageGroupMap.get(java.lang.String groupId)
|
ConsumerId |
SimpleMessageGroupMap.get(java.lang.String groupId)
|
ConsumerId |
MessageGroupHashBucket.removeGroup(java.lang.String groupId)
|
ConsumerId |
MessageGroupMap.removeGroup(java.lang.String groupId)
|
ConsumerId |
SimpleMessageGroupMap.removeGroup(java.lang.String groupId)
|
Methods in org.apache.activemq.broker.region.group with parameters of type ConsumerId | |
---|---|
void |
MessageGroupHashBucket.put(java.lang.String groupId,
ConsumerId consumerId)
|
void |
MessageGroupMap.put(java.lang.String groupId,
ConsumerId consumerId)
|
void |
SimpleMessageGroupMap.put(java.lang.String groupId,
ConsumerId consumerId)
|
MessageGroupSet |
MessageGroupHashBucket.removeConsumer(ConsumerId consumerId)
|
MessageGroupSet |
MessageGroupMap.removeConsumer(ConsumerId consumerId)
|
MessageGroupSet |
SimpleMessageGroupMap.removeConsumer(ConsumerId consumerId)
|
Uses of ConsumerId in org.apache.activemq.command |
---|
Fields in org.apache.activemq.command declared as ConsumerId | |
---|---|
protected ConsumerId |
ConsumerControl.consumerId
|
protected ConsumerId |
MessageAck.consumerId
|
protected ConsumerId |
ConsumerInfo.consumerId
|
protected ConsumerId |
MessageDispatchNotification.consumerId
|
protected ConsumerId |
MessageDispatch.consumerId
|
protected ConsumerId |
MessagePull.consumerId
|
protected ConsumerId |
Message.targetConsumerId
|
Fields in org.apache.activemq.command with type parameters of type ConsumerId | |
---|---|
protected java.util.List<ConsumerId> |
ConsumerInfo.networkConsumerIds
|
Methods in org.apache.activemq.command that return ConsumerId | |
---|---|
ConsumerId |
ConsumerControl.getConsumerId()
|
ConsumerId |
MessageAck.getConsumerId()
|
ConsumerId |
ConsumerInfo.getConsumerId()
Is used to uniquely identify the consumer to the broker. |
ConsumerId |
MessageDispatchNotification.getConsumerId()
|
ConsumerId |
MessageDispatch.getConsumerId()
|
ConsumerId |
MessagePull.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. |
Methods in org.apache.activemq.command that return types with arguments of type ConsumerId | |
---|---|
java.util.List<ConsumerId> |
ConsumerInfo.getNetworkConsumerIds()
|
Methods in org.apache.activemq.command with parameters of type ConsumerId | |
---|---|
void |
ConsumerInfo.addNetworkConsumerId(ConsumerId networkConsumerId)
|
void |
ConsumerInfo.removeNetworkConsumerId(ConsumerId networkConsumerId)
|
void |
ConsumerControl.setConsumerId(ConsumerId consumerId)
|
void |
MessageAck.setConsumerId(ConsumerId consumerId)
|
void |
ConsumerInfo.setConsumerId(ConsumerId consumerId)
|
void |
MessageDispatchNotification.setConsumerId(ConsumerId consumerId)
|
void |
MessageDispatch.setConsumerId(ConsumerId consumerId)
|
void |
MessagePull.setConsumerId(ConsumerId consumerId)
|
void |
ConsumerInfo.setNetworkConsumerPath(ConsumerId[] consumerPath)
|
void |
Message.setTargetConsumerId(ConsumerId targetConsumerId)
|
Constructors in org.apache.activemq.command with parameters of type ConsumerId | |
---|---|
ConnectionId(ConsumerId id)
|
|
ConsumerId(ConsumerId id)
|
|
ConsumerInfo(ConsumerId consumerId)
|
|
SessionId(ConsumerId id)
|
Uses of ConsumerId in org.apache.activemq.network |
---|
Fields in org.apache.activemq.network with type parameters of type ConsumerId | |
---|---|
protected java.util.concurrent.ConcurrentHashMap<ConsumerId,DemandSubscription> |
DemandForwardingBridgeSupport.subscriptionMapByLocalId
|
protected java.util.concurrent.ConcurrentHashMap<ConsumerId,DemandSubscription> |
DemandForwardingBridgeSupport.subscriptionMapByRemoteId
|
Methods in org.apache.activemq.network that return types with arguments of type ConsumerId | |
---|---|
java.util.concurrent.ConcurrentHashMap<ConsumerId,DemandSubscription> |
DemandForwardingBridgeSupport.getLocalSubscriptionMap()
|
Methods in org.apache.activemq.network with parameters of type ConsumerId | |
---|---|
boolean |
DemandSubscription.add(ConsumerId id)
Increment the consumers associated with this subscription |
boolean |
DemandSubscription.remove(ConsumerId id)
Increment the consumers associated with this subscription |
protected void |
DemandForwardingBridgeSupport.removeDemandSubscription(ConsumerId id)
|
protected void |
ConduitBridge.removeDemandSubscription(ConsumerId id)
|
boolean |
NetworkConnector.removeDemandSubscription(ConsumerId consumerId)
|
protected boolean |
DemandForwardingBridgeSupport.removeDemandSubscriptionByLocalId(ConsumerId consumerId)
|
Uses of ConsumerId in org.apache.activemq.state |
---|
Methods in org.apache.activemq.state that return types with arguments of type ConsumerId | |
---|---|
java.util.Set<ConsumerId> |
SessionState.getConsumerIds()
|
java.util.Map<ConsumerId,ConsumerInfo> |
ConnectionState.getRecoveringPullConsumers()
|
Methods in org.apache.activemq.state with parameters of type ConsumerId | |
---|---|
ConsumerState |
SessionState.getConsumerState(ConsumerId consumerId)
|
Response |
ConnectionStateTracker.processRemoveConsumer(ConsumerId id,
long lastDeliveredSequenceId)
|
Response |
CommandVisitor.processRemoveConsumer(ConsumerId id,
long lastDeliveredSequenceId)
|
Response |
CommandVisitorAdapter.processRemoveConsumer(ConsumerId id,
long lastDeliveredSequenceId)
|
ConsumerState |
SessionState.removeConsumer(ConsumerId id)
|
|
||||||||||
PREV NEXT | FRAMES NO FRAMES |