Uses of Interface
org.apache.activemq.broker.region.Destination
-
Packages that use Destination Package Description 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.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.region.cursors Cursors used to page persistent messages into the broker from the storeorg.apache.activemq.broker.region.group Classes to implement the Message Groups feature.org.apache.activemq.broker.region.policy The policies which can be associated with a particular destination or wildcard.org.apache.activemq.broker.region.virtual Implementation classes for Virtual Destinationsorg.apache.activemq.broker.util Some utility Broker Pluginsorg.apache.activemq.broker.view Broker Plugins for visualising the current systemorg.apache.activemq.junit org.apache.activemq.plugin org.apache.activemq.security Plugable Security Adapter framework along with default implementations such as the JAAS implementation.org.apache.activemq.shiro.authz org.apache.activemq.store.kahadb -
-
Uses of Destination in org.apache.activemq.advisory
Methods in org.apache.activemq.advisory that return Destination Modifier and Type Method Description DestinationAdvisoryBroker. addDestination(ConnectionContext context, ActiveMQDestination destination, boolean create)Methods in org.apache.activemq.advisory with parameters of type Destination Modifier and Type Method Description voidAdvisoryBroker. isFull(ConnectionContext context, Destination destination, Usage<?> usage)voidAdvisoryBroker. slowConsumer(ConnectionContext context, Destination destination, Subscription subs) -
Uses of Destination in org.apache.activemq.broker
Methods in org.apache.activemq.broker that return Destination Modifier and Type Method Description DestinationBrokerBroadcaster. addDestination(ConnectionContext context, ActiveMQDestination destination, boolean createIfTemporary)DestinationBrokerFilter. addDestination(ConnectionContext context, ActiveMQDestination destination, boolean createIfTemporary)DestinationEmptyBroker. addDestination(ConnectionContext context, ActiveMQDestination destination, boolean flag)DestinationErrorBroker. addDestination(ConnectionContext context, ActiveMQDestination destination, boolean flag)DestinationBrokerService. getDestination(ActiveMQDestination destination)Looks up and lazily creates if necessary the destination for the given JMS nameDestinationConsumerBrokerExchange. getRegionDestination()DestinationProducerBrokerExchange. getRegionDestination()Methods in org.apache.activemq.broker with parameters of type Destination Modifier and Type Method Description voidProducerBrokerExchange. incrementTimeBlocked(Destination destination, long timeBlocked)voidBroker. isFull(ConnectionContext context, Destination destination, Usage<?> usage)Called when a Usage reaches a limitvoidBrokerFilter. isFull(ConnectionContext context, Destination destination, Usage<?> usage)voidEmptyBroker. isFull(ConnectionContext context, Destination destination, Usage<?> usage)voidErrorBroker. isFull(ConnectionContext context, Destination destination, Usage<?> usage)voidConsumerBrokerExchange. setRegionDestination(Destination regionDestination)voidProducerBrokerExchange. setRegionDestination(Destination regionDestination)voidBroker. slowConsumer(ConnectionContext context, Destination destination, Subscription subs)Called when there is a slow consumervoidBrokerFilter. slowConsumer(ConnectionContext context, Destination destination, Subscription subs)voidEmptyBroker. slowConsumer(ConnectionContext context, Destination destination, Subscription subs)voidErrorBroker. slowConsumer(ConnectionContext context, Destination destination, Subscription subs) -
Uses of Destination in org.apache.activemq.broker.jmx
Fields in org.apache.activemq.broker.jmx declared as Destination Modifier and Type Field Description protected DestinationDestinationView. destinationMethods in org.apache.activemq.broker.jmx that return Destination Modifier and Type Method Description protected DestinationManagedQueueRegion. createDestination(ConnectionContext context, ActiveMQDestination destination)protected DestinationManagedTempQueueRegion. createDestination(ConnectionContext context, ActiveMQDestination destination)protected DestinationManagedTempTopicRegion. createDestination(ConnectionContext context, ActiveMQDestination destination)protected DestinationManagedTopicRegion. createDestination(ConnectionContext context, ActiveMQDestination destination)Methods in org.apache.activemq.broker.jmx with parameters of type Destination Modifier and Type Method Description voidManagedRegionBroker. register(ActiveMQDestination destName, Destination destination)Constructors in org.apache.activemq.broker.jmx with parameters of type Destination Constructor Description DestinationView(ManagedRegionBroker broker, Destination destination) -
Uses of Destination in org.apache.activemq.broker.region
Classes in org.apache.activemq.broker.region that implement Destination Modifier and Type Class Description classBaseDestinationclassDestinationFilterclassQueueThe Queue is a List of MessageEntry objects that are dispatched to matching subscriptions.classTempQueueThe Queue is a List of MessageEntry objects that are dispatched to matching subscriptions.classTempTopicThe Topic is a destination that sends a copy of a message to every active Subscription registered.classTopicThe Topic is a destination that sends a copy of a message to every active Subscription registered.Fields in org.apache.activemq.broker.region declared as Destination Modifier and Type Field Description protected DestinationDestinationFilter. nextFields in org.apache.activemq.broker.region with type parameters of type Destination Modifier and Type Field Description protected Map<ActiveMQDestination,Destination>AbstractRegion. destinationsprotected CopyOnWriteArrayList<Destination>AbstractSubscription. destinationsMethods in org.apache.activemq.broker.region that return Destination Modifier and Type Method Description DestinationAbstractRegion. addDestination(ConnectionContext context, ActiveMQDestination destination, boolean createIfTemporary)DestinationRegion. addDestination(ConnectionContext context, ActiveMQDestination destination, boolean createIfTemporary)Used to create a destination.DestinationRegionBroker. addDestination(ConnectionContext context, ActiveMQDestination destination, boolean createIfTemp)protected DestinationAbstractRegion. createDestination(ConnectionContext context, ActiveMQDestination destination)protected DestinationAbstractTempRegion. createDestination(ConnectionContext context, ActiveMQDestination destination)abstract DestinationDestinationFactory. createDestination(ConnectionContext context, ActiveMQDestination destination, DestinationStatistics destinationStatistics)Create destination implementation.DestinationDestinationFactoryImpl. createDestination(ConnectionContext context, ActiveMQDestination destination, DestinationStatistics destinationStatistics)DestinationDestinationFilter. getNext()DestinationNullMessageReference. getRegionDestination()DestinationCompositeDestinationInterceptor. intercept(Destination destination)DestinationDestinationInterceptor. intercept(Destination destination)protected DestinationAbstractRegion. lookup(ConnectionContext context, ActiveMQDestination destination, boolean createTemporary)Methods in org.apache.activemq.broker.region that return types with arguments of type Destination Modifier and Type Method Description Map<ActiveMQDestination,Destination>AbstractRegion. getDestinationMap()Map<ActiveMQDestination,Destination>Region. getDestinationMap()Returns a reference to the concurrent hash map that holds known destinations, do not modifyMap<ActiveMQDestination,Destination>RegionBroker. getDestinationMap()Map<ActiveMQDestination,Destination>RegionBroker. getDestinationMap(ActiveMQDestination destination)Set<Destination>AbstractRegion. getDestinations(ActiveMQDestination destination)Provide an exact or wildcard lookup of destinations in the regionCopyOnWriteArrayList<Destination>AbstractSubscription. getDestinations()Set<Destination>Region. getDestinations(ActiveMQDestination destination)Provide an exact or wildcard lookup of destinations in the regionSet<Destination>RegionBroker. getDestinations(ActiveMQDestination destination)Methods in org.apache.activemq.broker.region with parameters of type Destination Modifier and Type Method Description voidAbstractSubscription. add(ConnectionContext context, Destination destination)voidDurableTopicSubscription. add(ConnectionContext context, Destination destination)voidPrefetchSubscription. add(ConnectionContext context, Destination destination)voidSubscription. add(ConnectionContext context, Destination destination)The subscription will be receiving messages from the destination.voidAbstractSubscription. addDestination(Destination destination)Add a destinationprotected List<Subscription>AbstractRegion. addSubscriptionsForDestination(ConnectionContext context, Destination dest)protected List<Subscription>TopicRegion. addSubscriptionsForDestination(ConnectionContext context, Destination dest)protected voidAbstractRegion. dispose(ConnectionContext context, Destination dest)protected voidAbstractTempRegion. dispose(ConnectionContext context, Destination dest)DestinationCompositeDestinationInterceptor. intercept(Destination destination)DestinationDestinationInterceptor. intercept(Destination destination)List<MessageReference>AbstractSubscription. remove(ConnectionContext context, Destination destination)voidCompositeDestinationInterceptor. remove(Destination destination)voidDestinationInterceptor. remove(Destination destination)List<MessageReference>PrefetchSubscription. remove(ConnectionContext context, Destination destination)List<MessageReference>PrefetchSubscription. remove(ConnectionContext context, Destination destination, List<MessageReference> dispatched)List<MessageReference>QueueBrowserSubscription. remove(ConnectionContext context, Destination destination)List<MessageReference>Subscription. remove(ConnectionContext context, Destination destination)The subscription will be no longer be receiving messages from the destination.voidAbstractSubscription. removeDestination(Destination destination)Remove a destinationabstract voidDestinationFactory. removeDestination(Destination dest)voidDestinationFactoryImpl. removeDestination(Destination dest)Constructors in org.apache.activemq.broker.region with parameters of type Destination Constructor Description DestinationFilter(Destination next) -
Uses of Destination in org.apache.activemq.broker.region.cursors
Fields in org.apache.activemq.broker.region.cursors declared as Destination Modifier and Type Field Description protected DestinationAbstractStoreCursor. regionDestinationMethods in org.apache.activemq.broker.region.cursors with parameters of type Destination Modifier and Type Method Description voidAbstractPendingMessageCursor. add(ConnectionContext context, Destination destination)voidPendingMessageCursor. add(ConnectionContext context, Destination destination)Add a destinationvoidStoreDurableSubscriberCursor. add(ConnectionContext context, Destination destination)Add a destinationbooleanAbstractPendingMessageCursor. isEmpty(Destination destination)booleanPendingMessageCursor. isEmpty(Destination destination)check if a Destination is Empty for this cursorbooleanStoreDurableSubscriberCursor. isEmpty(Destination destination)List<MessageReference>AbstractPendingMessageCursor. remove(ConnectionContext context, Destination destination)List<MessageReference>PendingMessageCursor. remove(ConnectionContext context, Destination destination)remove a destinationList<MessageReference>StoreDurableSubscriberCursor. remove(ConnectionContext context, Destination destination)remove a destinationList<MessageReference>VMPendingMessageCursor. remove(ConnectionContext context, Destination destination)Constructors in org.apache.activemq.broker.region.cursors with parameters of type Destination Constructor Description AbstractStoreCursor(Destination destination) -
Uses of Destination in org.apache.activemq.broker.region.group
Methods in org.apache.activemq.broker.region.group with parameters of type Destination Modifier and Type Method Description voidCachedMessageGroupMap. setDestination(Destination destination)voidMessageGroupHashBucket. setDestination(Destination destination)voidMessageGroupMap. setDestination(Destination destination)voidSimpleMessageGroupMap. setDestination(Destination destination) -
Uses of Destination in org.apache.activemq.broker.region.policy
Methods in org.apache.activemq.broker.region.policy with parameters of type Destination Modifier and Type Method Description voidAbortSlowAckConsumerStrategy. addDestination(Destination destination)voidAbortSlowConsumerStrategy. addDestination(Destination destination)voidSlowConsumerStrategy. addDestination(Destination destination)For Strategies that need to examine assigned destination for slow consumers periodically the destination is assigned here.protected voidQueryBasedSubscriptionRecoveryPolicy. dispatchInitialMessage(Message message, Destination regionDestination, ConnectionContext context, SubscriptionRecovery sub) -
Uses of Destination in org.apache.activemq.broker.region.virtual
Classes in org.apache.activemq.broker.region.virtual that implement Destination Modifier and Type Class Description classCompositeDestinationFilterRepresents a compositeDestinationwhere send()s are replicated to each Destination instance.classMappedQueueFilterCreates a mapped Queue that can recover messages from subscription recovery policy of its Virtual Topic.classSelectorAwareVirtualTopicInterceptorclassVirtualTopicInterceptorA Destination which implements Virtual TopicMethods in org.apache.activemq.broker.region.virtual that return Destination Modifier and Type Method Description protected DestinationVirtualDestinationInterceptor. createCompositeDestination(Destination destination, List<Destination> destinations)protected DestinationMirroredQueue. getMirrorDestination(Destination destination)DestinationCompositeDestination. intercept(Destination destination)DestinationMirroredQueue. intercept(Destination destination)DestinationVirtualDestination. intercept(Destination destination)Creates a virtual destination from the physical destinationDestinationVirtualDestinationInterceptor. intercept(Destination destination)DestinationVirtualTopic. intercept(Destination destination)DestinationCompositeQueue. interceptMappedDestination(Destination destination)DestinationCompositeTopic. interceptMappedDestination(Destination destination)DestinationVirtualDestination. interceptMappedDestination(Destination destination)Creates a mapped destinationDestinationVirtualTopic. interceptMappedDestination(Destination destination)Methods in org.apache.activemq.broker.region.virtual with parameters of type Destination Modifier and Type Method Description protected DestinationVirtualDestinationInterceptor. createCompositeDestination(Destination destination, List<Destination> destinations)protected DestinationMirroredQueue. getMirrorDestination(Destination destination)DestinationCompositeDestination. intercept(Destination destination)DestinationMirroredQueue. intercept(Destination destination)DestinationVirtualDestination. intercept(Destination destination)Creates a virtual destination from the physical destinationDestinationVirtualDestinationInterceptor. intercept(Destination destination)DestinationVirtualTopic. intercept(Destination destination)DestinationCompositeQueue. interceptMappedDestination(Destination destination)DestinationCompositeTopic. interceptMappedDestination(Destination destination)DestinationVirtualDestination. interceptMappedDestination(Destination destination)Creates a mapped destinationDestinationVirtualTopic. interceptMappedDestination(Destination destination)voidCompositeDestination. remove(Destination destination)voidMirroredQueue. remove(Destination destination)voidVirtualDestinationInterceptor. remove(Destination destination)voidVirtualTopic. remove(Destination destination)protected booleanSelectorAwareVirtualTopicInterceptor. shouldDispatch(Broker broker, Message message, Destination dest)Respect the selectors of the subscriptions to ensure only matched messages are dispatched to the virtual queues, hence there is no build up of unmatched messages on these destinationsprotected booleanVirtualTopicInterceptor. shouldDispatch(Broker broker, Message message, Destination dest)Method parameters in org.apache.activemq.broker.region.virtual with type arguments of type Destination Modifier and Type Method Description protected DestinationVirtualDestinationInterceptor. createCompositeDestination(Destination destination, List<Destination> destinations)Constructors in org.apache.activemq.broker.region.virtual with parameters of type Destination Constructor Description CompositeDestinationFilter(Destination next, Collection forwardDestinations, boolean forwardOnly, boolean sendWhenNotMatched, boolean concurrentSend)MappedQueueFilter(ActiveMQDestination virtualDestination, Destination destination)SelectorAwareVirtualTopicInterceptor(Destination next, VirtualTopic virtualTopic)VirtualTopicInterceptor(Destination next, VirtualTopic virtualTopic) -
Uses of Destination in org.apache.activemq.broker.util
Methods in org.apache.activemq.broker.util that return Destination Modifier and Type Method Description DestinationDestinationPathSeparatorBroker. addDestination(ConnectionContext context, ActiveMQDestination destination, boolean createIfTemporary)DestinationDestinationsPlugin. addDestination(ConnectionContext context, ActiveMQDestination destination, boolean createIfTemporary)DestinationLoggingBrokerPlugin. addDestination(ConnectionContext context, ActiveMQDestination destination, boolean create)Methods in org.apache.activemq.broker.util with parameters of type Destination Modifier and Type Method Description voidLoggingBrokerPlugin. isFull(ConnectionContext context, Destination destination, Usage<?> usage)voidLoggingBrokerPlugin. slowConsumer(ConnectionContext context, Destination destination, Subscription subs) -
Uses of Destination in org.apache.activemq.broker.view
Methods in org.apache.activemq.broker.view that return Destination Modifier and Type Method Description DestinationDestinationDotFileInterceptor. addDestination(ConnectionContext context, ActiveMQDestination destination, boolean create) -
Uses of Destination in org.apache.activemq.junit
Methods in org.apache.activemq.junit that return Destination Modifier and Type Method Description DestinationEmbeddedActiveMQBroker. getDestination(String destinationName)Get the ActiveMQ destination -
Uses of Destination in org.apache.activemq.plugin
Methods in org.apache.activemq.plugin that return Destination Modifier and Type Method Description DestinationAbstractRuntimeConfigurationBroker. addDestination(ConnectionContext context, ActiveMQDestination destination, boolean createIfTemporary) -
Uses of Destination in org.apache.activemq.security
Classes in org.apache.activemq.security that implement Destination Modifier and Type Class Description classAuthorizationDestinationFilterAuthorizes addSubscription calls.Methods in org.apache.activemq.security that return Destination Modifier and Type Method Description DestinationAuthorizationBroker. addDestination(ConnectionContext context, ActiveMQDestination destination, boolean create)DestinationAuthorizationDestinationInterceptor. intercept(Destination destination)Methods in org.apache.activemq.security with parameters of type Destination Modifier and Type Method Description DestinationAuthorizationDestinationInterceptor. intercept(Destination destination)voidAuthorizationDestinationInterceptor. remove(Destination destination)Constructors in org.apache.activemq.security with parameters of type Destination Constructor Description AuthorizationDestinationFilter(Destination destination, AuthorizationBroker broker) -
Uses of Destination in org.apache.activemq.shiro.authz
Methods in org.apache.activemq.shiro.authz that return Destination Modifier and Type Method Description DestinationAuthorizationFilter. addDestination(ConnectionContext context, ActiveMQDestination destination, boolean create) -
Uses of Destination in org.apache.activemq.store.kahadb
Methods in org.apache.activemq.store.kahadb with parameters of type Destination Modifier and Type Method Description protected booleanMessageDatabase. matchType(Destination destination, KahaDestination.DestinationType type)Determine whether this Destination matches the DestinationType
-