Uses of Class
org.apache.activemq.command.ConsumerId

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, String selector, boolean noLocal, String name, int prefetch, long timeout)
           
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)
           
 

Uses of ConsumerId in org.apache.activemq.advisory
 

Fields in org.apache.activemq.advisory with type parameters of type ConsumerId
protected  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
 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, 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 TransportConnectionStateRegister.lookupConnectionState(ConsumerId id)
           
protected  TransportConnectionState TransportConnection.lookupConnectionState(ConsumerId id)
           
 TransportConnectionState SingleTransportConnectionStateRegister.lookupConnectionState(ConsumerId id)
           
 TransportConnectionState MapTransportConnectionStateRegister.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  Map<ConsumerId,Object> AbstractRegion.consumerChangeMutexMap
           
protected  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
 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 SimpleMessageGroupMap.get(String groupId)
           
 ConsumerId MessageGroupMap.get(String groupId)
           
 ConsumerId MessageGroupHashBucket.get(String groupId)
           
 ConsumerId SimpleMessageGroupMap.removeGroup(String groupId)
           
 ConsumerId MessageGroupMap.removeGroup(String groupId)
           
 ConsumerId MessageGroupHashBucket.removeGroup(String groupId)
           
 

Methods in org.apache.activemq.broker.region.group with parameters of type ConsumerId
 void SimpleMessageGroupMap.put(String groupId, ConsumerId consumerId)
           
 void MessageGroupMap.put(String groupId, ConsumerId consumerId)
           
 void MessageGroupHashBucket.put(String groupId, ConsumerId consumerId)
           
 MessageGroupSet SimpleMessageGroupMap.removeConsumer(ConsumerId consumerId)
           
 MessageGroupSet MessageGroupMap.removeConsumer(ConsumerId consumerId)
           
 MessageGroupSet MessageGroupHashBucket.removeConsumer(ConsumerId consumerId)
           
 

Uses of ConsumerId in org.apache.activemq.command
 

Fields in org.apache.activemq.command declared as ConsumerId
protected  ConsumerId MessagePull.consumerId
           
protected  ConsumerId MessageDispatchNotification.consumerId
           
protected  ConsumerId MessageDispatch.consumerId
           
protected  ConsumerId MessageAck.consumerId
           
protected  ConsumerId ConsumerInfo.consumerId
           
protected  ConsumerId ConsumerControl.consumerId
           
protected  ConsumerId Message.targetConsumerId
           
 

Fields in org.apache.activemq.command with type parameters of type ConsumerId
protected  List<ConsumerId> ConsumerInfo.networkConsumerIds
           
 

Methods in org.apache.activemq.command that return ConsumerId
 ConsumerId MessagePull.getConsumerId()
           
 ConsumerId MessageDispatchNotification.getConsumerId()
           
 ConsumerId MessageDispatch.getConsumerId()
           
 ConsumerId MessageAck.getConsumerId()
           
 ConsumerId ConsumerInfo.getConsumerId()
          Is used to uniquely identify the consumer to the broker.
 ConsumerId ConsumerControl.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
 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 MessagePull.setConsumerId(ConsumerId consumerId)
           
 void MessageDispatchNotification.setConsumerId(ConsumerId consumerId)
           
 void MessageDispatch.setConsumerId(ConsumerId consumerId)
           
 void MessageAck.setConsumerId(ConsumerId consumerId)
           
 void ConsumerInfo.setConsumerId(ConsumerId consumerId)
           
 void ConsumerControl.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  ConcurrentHashMap<ConsumerId,DemandSubscription> DemandForwardingBridgeSupport.subscriptionMapByLocalId
           
protected  ConcurrentHashMap<ConsumerId,DemandSubscription> DemandForwardingBridgeSupport.subscriptionMapByRemoteId
           
 

Methods in org.apache.activemq.network that return types with arguments of type ConsumerId
 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
 boolean NetworkConnector.removeDemandSubscription(ConsumerId consumerId)
           
protected  void DemandForwardingBridgeSupport.removeDemandSubscription(ConsumerId id)
           
protected  void ConduitBridge.removeDemandSubscription(ConsumerId id)
           
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
 Set<ConsumerId> SessionState.getConsumerIds()
           
 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 CommandVisitorAdapter.processRemoveConsumer(ConsumerId id, long lastDeliveredSequenceId)
           
 Response CommandVisitor.processRemoveConsumer(ConsumerId id, long lastDeliveredSequenceId)
           
 ConsumerState SessionState.removeConsumer(ConsumerId id)
           
 



Copyright © 2005-2012 The Apache Software Foundation. All Rights Reserved.