|
||||||||||
PREV NEXT | FRAMES NO FRAMES |
Packages that use ConsumerInfo | |
---|---|
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.cluster | |
org.apache.activemq.broker.ft | Helper classes for implementing fault tolerance |
org.apache.activemq.broker.jmx | JMX MBeans for the broker and its core connectors. |
org.apache.activemq.broker.region | Region abstraction and implementations in the Broker. |
org.apache.activemq.broker.util | Some utility Broker Plugins |
org.apache.activemq.broker.view | Broker Plugins for visualising the current system |
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.security | Plugable Security Adapter framework along with default implementations such as the JAAS implementation. |
org.apache.activemq.state | |
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.xmpp |
Uses of ConsumerInfo in org.apache.activemq |
---|
Fields in org.apache.activemq declared as ConsumerInfo | |
---|---|
protected ConsumerInfo |
ActiveMQMessageConsumer.info
|
Constructors in org.apache.activemq with parameters of type ConsumerInfo | |
---|---|
ActiveMQConnectionConsumer(ActiveMQConnection theConnection,
ServerSessionPool theSessionPool,
ConsumerInfo theConsumerInfo)
Create a ConnectionConsumer |
Uses of ConsumerInfo in org.apache.activemq.advisory |
---|
Fields in org.apache.activemq.advisory with type parameters of type ConsumerInfo | |
---|---|
protected ConcurrentHashMap<ConsumerId,ConsumerInfo> |
AdvisoryBroker.consumers
|
Methods in org.apache.activemq.advisory that return ConsumerInfo | |
---|---|
ConsumerInfo |
ConsumerStartedEvent.getConsumerInfo()
|
Methods in org.apache.activemq.advisory that return types with arguments of type ConsumerInfo | |
---|---|
Map<ConsumerId,ConsumerInfo> |
AdvisoryBroker.getAdvisoryConsumers()
|
Methods in org.apache.activemq.advisory with parameters of type ConsumerInfo | |
---|---|
Subscription |
AdvisoryBroker.addConsumer(ConnectionContext context,
ConsumerInfo info)
|
void |
AdvisoryBroker.removeConsumer(ConnectionContext context,
ConsumerInfo info)
|
Constructors in org.apache.activemq.advisory with parameters of type ConsumerInfo | |
---|---|
ConsumerStartedEvent(ConsumerEventSource source,
ActiveMQDestination destination,
ConsumerInfo consumerInfo,
int count)
|
Uses of ConsumerInfo in org.apache.activemq.broker |
---|
Methods in org.apache.activemq.broker with parameters of type ConsumerInfo | |
---|---|
Subscription |
EmptyBroker.addConsumer(ConnectionContext context,
ConsumerInfo info)
|
Subscription |
MutableBrokerFilter.addConsumer(ConnectionContext context,
ConsumerInfo info)
|
Subscription |
BrokerFilter.addConsumer(ConnectionContext context,
ConsumerInfo info)
|
Subscription |
BrokerBroadcaster.addConsumer(ConnectionContext context,
ConsumerInfo info)
|
Subscription |
ErrorBroker.addConsumer(ConnectionContext context,
ConsumerInfo info)
|
Response |
TransportConnection.processAddConsumer(ConsumerInfo info)
|
void |
EmptyBroker.removeConsumer(ConnectionContext context,
ConsumerInfo info)
|
void |
MutableBrokerFilter.removeConsumer(ConnectionContext context,
ConsumerInfo info)
|
void |
BrokerFilter.removeConsumer(ConnectionContext context,
ConsumerInfo info)
|
void |
BrokerBroadcaster.removeConsumer(ConnectionContext context,
ConsumerInfo info)
|
void |
ErrorBroker.removeConsumer(ConnectionContext context,
ConsumerInfo info)
|
Uses of ConsumerInfo in org.apache.activemq.broker.cluster |
---|
Methods in org.apache.activemq.broker.cluster with parameters of type ConsumerInfo | |
---|---|
Subscription |
ConnectionSplitBroker.addConsumer(ConnectionContext context,
ConsumerInfo info)
|
void |
ConnectionSplitBroker.removeConsumer(ConnectionContext context,
ConsumerInfo info)
|
Uses of ConsumerInfo in org.apache.activemq.broker.ft |
---|
Methods in org.apache.activemq.broker.ft with parameters of type ConsumerInfo | |
---|---|
Subscription |
MasterBroker.addConsumer(ConnectionContext context,
ConsumerInfo info)
add a consumer |
void |
MasterBroker.removeConsumer(ConnectionContext context,
ConsumerInfo info)
|
Uses of ConsumerInfo in org.apache.activemq.broker.jmx |
---|
Methods in org.apache.activemq.broker.jmx that return ConsumerInfo | |
---|---|
protected ConsumerInfo |
SubscriptionView.getConsumerInfo()
|
Methods in org.apache.activemq.broker.jmx with parameters of type ConsumerInfo | |
---|---|
protected Subscription |
ManagedTempQueueRegion.createSubscription(ConnectionContext context,
ConsumerInfo info)
|
protected Subscription |
ManagedTopicRegion.createSubscription(ConnectionContext context,
ConsumerInfo info)
|
protected Subscription |
ManagedQueueRegion.createSubscription(ConnectionContext context,
ConsumerInfo info)
|
protected Subscription |
ManagedTempTopicRegion.createSubscription(ConnectionContext context,
ConsumerInfo info)
|
protected void |
ManagedRegionBroker.registerSubscription(ObjectName key,
ConsumerInfo info,
SubscriptionKey subscriptionKey,
SubscriptionView view)
|
Uses of ConsumerInfo in org.apache.activemq.broker.region |
---|
Fields in org.apache.activemq.broker.region declared as ConsumerInfo | |
---|---|
protected ConsumerInfo |
AbstractSubscription.info
|
Methods in org.apache.activemq.broker.region that return ConsumerInfo | |
---|---|
ConsumerInfo |
Subscription.getConsumerInfo()
The ConsumerInfo object that created the subscription. |
ConsumerInfo |
AbstractSubscription.getConsumerInfo()
|
ConsumerInfo |
AbstractSubscription.getInfo()
|
Constructors in org.apache.activemq.broker.region with parameters of type ConsumerInfo | |
---|---|
AbstractSubscription(Broker broker,
ConnectionContext context,
ConsumerInfo info)
|
|
DurableTopicSubscription(Broker broker,
SystemUsage usageManager,
ConnectionContext context,
ConsumerInfo info,
boolean keepDurableSubsActive)
|
|
PrefetchSubscription(Broker broker,
SystemUsage usageManager,
ConnectionContext context,
ConsumerInfo info)
|
|
PrefetchSubscription(Broker broker,
SystemUsage usageManager,
ConnectionContext context,
ConsumerInfo info,
PendingMessageCursor cursor)
|
|
QueueBrowserSubscription(Broker broker,
SystemUsage usageManager,
ConnectionContext context,
ConsumerInfo info)
|
|
QueueSubscription(Broker broker,
SystemUsage usageManager,
ConnectionContext context,
ConsumerInfo info)
|
|
TopicSubscription(Broker broker,
ConnectionContext context,
ConsumerInfo info,
SystemUsage usageManager)
|
Uses of ConsumerInfo in org.apache.activemq.broker.util |
---|
Methods in org.apache.activemq.broker.util with parameters of type ConsumerInfo | |
---|---|
Subscription |
UDPTraceBrokerPlugin.addConsumer(ConnectionContext context,
ConsumerInfo info)
|
Subscription |
LoggingBrokerPlugin.addConsumer(ConnectionContext context,
ConsumerInfo info)
|
void |
UDPTraceBrokerPlugin.removeConsumer(ConnectionContext context,
ConsumerInfo info)
|
void |
LoggingBrokerPlugin.removeConsumer(ConnectionContext context,
ConsumerInfo info)
|
Uses of ConsumerInfo in org.apache.activemq.broker.view |
---|
Methods in org.apache.activemq.broker.view with parameters of type ConsumerInfo | |
---|---|
Subscription |
ConnectionDotFileInterceptor.addConsumer(ConnectionContext context,
ConsumerInfo info)
|
void |
ConnectionDotFileInterceptor.removeConsumer(ConnectionContext context,
ConsumerInfo info)
|
Uses of ConsumerInfo in org.apache.activemq.command |
---|
Methods in org.apache.activemq.command that return ConsumerInfo | |
---|---|
ConsumerInfo |
ConsumerInfo.copy()
|
Methods in org.apache.activemq.command with parameters of type ConsumerInfo | |
---|---|
void |
MessagePull.configure(ConsumerInfo info)
Configures a message pull from the consumer information |
void |
ConsumerInfo.copy(ConsumerInfo info)
|
Uses of ConsumerInfo in org.apache.activemq.network |
---|
Fields in org.apache.activemq.network declared as ConsumerInfo | |
---|---|
protected ConsumerInfo |
DemandForwardingBridgeSupport.demandConsumerInfo
|
Methods in org.apache.activemq.network that return ConsumerInfo | |
---|---|
ConsumerInfo |
DemandSubscription.getLocalInfo()
|
ConsumerInfo |
DemandSubscription.getRemoteInfo()
|
Methods in org.apache.activemq.network with parameters of type ConsumerInfo | |
---|---|
protected boolean |
DemandForwardingBridgeSupport.addConsumerInfo(ConsumerInfo consumerInfo)
|
protected abstract void |
DemandForwardingBridgeSupport.addRemoteBrokerToBrokerPath(ConsumerInfo info)
|
protected void |
DemandForwardingBridge.addRemoteBrokerToBrokerPath(ConsumerInfo info)
|
protected void |
CompositeDemandForwardingBridge.addRemoteBrokerToBrokerPath(ConsumerInfo info)
|
protected boolean |
ConduitBridge.addToAlreadyInterestedConsumers(ConsumerInfo info)
|
protected void |
DemandForwardingBridgeSupport.configureDemandSubscription(ConsumerInfo info,
DemandSubscription sub)
|
protected DemandSubscription |
DemandForwardingBridgeSupport.createDemandSubscription(ConsumerInfo info)
|
protected DemandSubscription |
DurableConduitBridge.createDemandSubscription(ConsumerInfo info)
|
protected DemandSubscription |
ConduitBridge.createDemandSubscription(ConsumerInfo info)
|
protected abstract NetworkBridgeFilter |
DemandForwardingBridgeSupport.createNetworkBridgeFilter(ConsumerInfo info)
|
protected NetworkBridgeFilter |
DemandForwardingBridge.createNetworkBridgeFilter(ConsumerInfo info)
|
protected NetworkBridgeFilter |
CompositeDemandForwardingBridge.createNetworkBridgeFilter(ConsumerInfo info)
|
protected DemandSubscription |
DemandForwardingBridgeSupport.doCreateDemandSubscription(ConsumerInfo info)
|
Uses of ConsumerInfo in org.apache.activemq.security |
---|
Methods in org.apache.activemq.security with parameters of type ConsumerInfo | |
---|---|
Subscription |
AuthorizationBroker.addConsumer(ConnectionContext context,
ConsumerInfo info)
|
Uses of ConsumerInfo in org.apache.activemq.state |
---|
Methods in org.apache.activemq.state that return ConsumerInfo | |
---|---|
ConsumerInfo |
ConsumerState.getInfo()
|
Methods in org.apache.activemq.state with parameters of type ConsumerInfo | |
---|---|
void |
SessionState.addConsumer(ConsumerInfo info)
|
Response |
CommandVisitor.processAddConsumer(ConsumerInfo info)
|
Response |
CommandVisitorAdapter.processAddConsumer(ConsumerInfo info)
|
Response |
ConnectionStateTracker.processAddConsumer(ConsumerInfo info)
|
Constructors in org.apache.activemq.state with parameters of type ConsumerInfo | |
---|---|
ConsumerState(ConsumerInfo info)
|
Uses of ConsumerInfo in org.apache.activemq.transport.stomp |
---|
Methods in org.apache.activemq.transport.stomp that return ConsumerInfo | |
---|---|
ConsumerInfo |
StompSubscription.getConsumerInfo()
|
Constructors in org.apache.activemq.transport.stomp with parameters of type ConsumerInfo | |
---|---|
StompSubscription(ProtocolConverter stompTransport,
String subscriptionId,
ConsumerInfo consumerInfo,
String transformation)
|
Uses of ConsumerInfo in org.apache.activemq.transport.xmpp |
---|
Method parameters in org.apache.activemq.transport.xmpp with type arguments of type ConsumerInfo | |
---|---|
protected void |
ProtocolConverter.subscribe(String to,
ActiveMQDestination destination,
Map<String,ConsumerInfo> consumerMap)
|
|
||||||||||
PREV NEXT | FRAMES NO FRAMES |