Uses of Class
org.apache.activemq.network.DemandSubscription

Packages that use DemandSubscription

Package	Description
org.apache.activemq.network	Support for federated networks of brokers.

Uses of DemandSubscription in org.apache.activemq.network

Fields in org.apache.activemq.network with type parameters of type DemandSubscription

Modifier and Type	Field	Description
protected ConcurrentMap<ConsumerId,DemandSubscription>	DemandForwardingBridgeSupport.subscriptionMapByLocalId
protected ConcurrentMap<ConsumerId,DemandSubscription>	DemandForwardingBridgeSupport.subscriptionMapByRemoteId

Methods in org.apache.activemq.network that return DemandSubscription

Modifier and Type	Method	Description
protected DemandSubscription	ConduitBridge.createDemandSubscription(ConsumerInfo info)
protected DemandSubscription	DemandForwardingBridgeSupport.createDemandSubscription(ActiveMQDestination destination, String subscriptionName)
protected DemandSubscription	DemandForwardingBridgeSupport.createDemandSubscription(ConsumerInfo info)
protected DemandSubscription	DurableConduitBridge.createDemandSubscription(ConsumerInfo info)
protected DemandSubscription	DemandForwardingBridgeSupport.doCreateDemandSubscription(ConsumerInfo info)

Methods in org.apache.activemq.network that return types with arguments of type DemandSubscription

Modifier and Type	Method	Description
ConcurrentMap<ConsumerId,DemandSubscription>	DemandForwardingBridgeSupport.getLocalSubscriptionMap()

Methods in org.apache.activemq.network with parameters of type DemandSubscription

Modifier and Type	Method	Description
protected void	DemandForwardingBridgeSupport.addProxyNetworkSubscriptionBrokerPath(DemandSubscription sub, BrokerId[] path, String subName)	Add a durable remote proxy subscription when we can generate via the BrokerId path This is the most common scenario
protected void	DemandForwardingBridgeSupport.addProxyNetworkSubscriptionClientId(DemandSubscription sub, String clientId, String subName)	This scenaior is primarily used for durable sync on broker restarts
protected void	DemandForwardingBridgeSupport.addSubscription(DemandSubscription sub)
protected void	DemandForwardingBridgeSupport.configureDemandSubscription(ConsumerInfo info, DemandSubscription sub)
protected void	DemandForwardingBridgeSupport.removeSubscription(DemandSubscription sub)