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 Destination
AdvisoryBroker. addDestination(ConnectionContext context, ActiveMQDestination destination, boolean create)
Methods in org.apache.activemq.advisory with parameters of type Destination Modifier and Type Method Description void
AdvisoryBroker. isFull(ConnectionContext context, Destination destination, Usage<?> usage)
void
AdvisoryBroker. 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 Destination
BrokerBroadcaster. addDestination(ConnectionContext context, ActiveMQDestination destination, boolean createIfTemporary)
Destination
BrokerFilter. addDestination(ConnectionContext context, ActiveMQDestination destination, boolean createIfTemporary)
Destination
EmptyBroker. addDestination(ConnectionContext context, ActiveMQDestination destination, boolean flag)
Destination
ErrorBroker. addDestination(ConnectionContext context, ActiveMQDestination destination, boolean flag)
Destination
BrokerService. getDestination(ActiveMQDestination destination)
Looks up and lazily creates if necessary the destination for the given JMS nameDestination
ConsumerBrokerExchange. getRegionDestination()
Destination
ProducerBrokerExchange. getRegionDestination()
Methods in org.apache.activemq.broker with parameters of type Destination Modifier and Type Method Description void
ProducerBrokerExchange. incrementTimeBlocked(Destination destination, long timeBlocked)
void
Broker. isFull(ConnectionContext context, Destination destination, Usage<?> usage)
Called when a Usage reaches a limitvoid
BrokerFilter. isFull(ConnectionContext context, Destination destination, Usage<?> usage)
void
EmptyBroker. isFull(ConnectionContext context, Destination destination, Usage<?> usage)
void
ErrorBroker. isFull(ConnectionContext context, Destination destination, Usage<?> usage)
void
ConsumerBrokerExchange. setRegionDestination(Destination regionDestination)
void
ProducerBrokerExchange. setRegionDestination(Destination regionDestination)
void
Broker. slowConsumer(ConnectionContext context, Destination destination, Subscription subs)
Called when there is a slow consumervoid
BrokerFilter. slowConsumer(ConnectionContext context, Destination destination, Subscription subs)
void
EmptyBroker. slowConsumer(ConnectionContext context, Destination destination, Subscription subs)
void
ErrorBroker. 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 Destination
DestinationView. destination
Methods in org.apache.activemq.broker.jmx that return Destination Modifier and Type Method Description protected Destination
ManagedQueueRegion. createDestination(ConnectionContext context, ActiveMQDestination destination)
protected Destination
ManagedTempQueueRegion. createDestination(ConnectionContext context, ActiveMQDestination destination)
protected Destination
ManagedTempTopicRegion. createDestination(ConnectionContext context, ActiveMQDestination destination)
protected Destination
ManagedTopicRegion. createDestination(ConnectionContext context, ActiveMQDestination destination)
Methods in org.apache.activemq.broker.jmx with parameters of type Destination Modifier and Type Method Description void
ManagedRegionBroker. 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 class
BaseDestination
class
DestinationFilter
class
Queue
The Queue is a List of MessageEntry objects that are dispatched to matching subscriptions.class
TempQueue
The Queue is a List of MessageEntry objects that are dispatched to matching subscriptions.class
TempTopic
The Topic is a destination that sends a copy of a message to every active Subscription registered.class
Topic
The 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 Destination
DestinationFilter. next
Fields in org.apache.activemq.broker.region with type parameters of type Destination Modifier and Type Field Description protected Map<ActiveMQDestination,Destination>
AbstractRegion. destinations
protected CopyOnWriteArrayList<Destination>
AbstractSubscription. destinations
Methods in org.apache.activemq.broker.region that return Destination Modifier and Type Method Description Destination
AbstractRegion. addDestination(ConnectionContext context, ActiveMQDestination destination, boolean createIfTemporary)
Destination
Region. addDestination(ConnectionContext context, ActiveMQDestination destination, boolean createIfTemporary)
Used to create a destination.Destination
RegionBroker. addDestination(ConnectionContext context, ActiveMQDestination destination, boolean createIfTemp)
protected Destination
AbstractRegion. createDestination(ConnectionContext context, ActiveMQDestination destination)
protected Destination
AbstractTempRegion. createDestination(ConnectionContext context, ActiveMQDestination destination)
abstract Destination
DestinationFactory. createDestination(ConnectionContext context, ActiveMQDestination destination, DestinationStatistics destinationStatistics)
Create destination implementation.Destination
DestinationFactoryImpl. createDestination(ConnectionContext context, ActiveMQDestination destination, DestinationStatistics destinationStatistics)
Destination
DestinationFilter. getNext()
Destination
NullMessageReference. getRegionDestination()
Destination
CompositeDestinationInterceptor. intercept(Destination destination)
Destination
DestinationInterceptor. intercept(Destination destination)
protected Destination
AbstractRegion. 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 void
AbstractSubscription. add(ConnectionContext context, Destination destination)
void
DurableTopicSubscription. add(ConnectionContext context, Destination destination)
void
PrefetchSubscription. add(ConnectionContext context, Destination destination)
void
Subscription. add(ConnectionContext context, Destination destination)
The subscription will be receiving messages from the destination.void
AbstractSubscription. addDestination(Destination destination)
Add a destinationprotected List<Subscription>
AbstractRegion. addSubscriptionsForDestination(ConnectionContext context, Destination dest)
protected List<Subscription>
TopicRegion. addSubscriptionsForDestination(ConnectionContext context, Destination dest)
protected void
AbstractRegion. dispose(ConnectionContext context, Destination dest)
protected void
AbstractTempRegion. dispose(ConnectionContext context, Destination dest)
Destination
CompositeDestinationInterceptor. intercept(Destination destination)
Destination
DestinationInterceptor. intercept(Destination destination)
List<MessageReference>
AbstractSubscription. remove(ConnectionContext context, Destination destination)
void
CompositeDestinationInterceptor. remove(Destination destination)
void
DestinationInterceptor. 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.void
AbstractSubscription. removeDestination(Destination destination)
Remove a destinationabstract void
DestinationFactory. removeDestination(Destination dest)
void
DestinationFactoryImpl. 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 Destination
AbstractStoreCursor. regionDestination
Methods in org.apache.activemq.broker.region.cursors with parameters of type Destination Modifier and Type Method Description void
AbstractPendingMessageCursor. add(ConnectionContext context, Destination destination)
void
PendingMessageCursor. add(ConnectionContext context, Destination destination)
Add a destinationvoid
StoreDurableSubscriberCursor. add(ConnectionContext context, Destination destination)
Add a destinationboolean
AbstractPendingMessageCursor. isEmpty(Destination destination)
boolean
PendingMessageCursor. isEmpty(Destination destination)
check if a Destination is Empty for this cursorboolean
StoreDurableSubscriberCursor. 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 void
CachedMessageGroupMap. setDestination(Destination destination)
void
MessageGroupHashBucket. setDestination(Destination destination)
void
MessageGroupMap. setDestination(Destination destination)
void
SimpleMessageGroupMap. 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 void
AbortSlowAckConsumerStrategy. addDestination(Destination destination)
void
AbortSlowConsumerStrategy. addDestination(Destination destination)
void
SlowConsumerStrategy. addDestination(Destination destination)
For Strategies that need to examine assigned destination for slow consumers periodically the destination is assigned here.protected void
QueryBasedSubscriptionRecoveryPolicy. 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 class
CompositeDestinationFilter
Represents a compositeDestination
where send()s are replicated to each Destination instance.class
MappedQueueFilter
Creates a mapped Queue that can recover messages from subscription recovery policy of its Virtual Topic.class
SelectorAwareVirtualTopicInterceptor
class
VirtualTopicInterceptor
A Destination which implements Virtual TopicMethods in org.apache.activemq.broker.region.virtual that return Destination Modifier and Type Method Description protected Destination
VirtualDestinationInterceptor. createCompositeDestination(Destination destination, List<Destination> destinations)
protected Destination
MirroredQueue. getMirrorDestination(Destination destination)
Destination
CompositeDestination. intercept(Destination destination)
Destination
MirroredQueue. intercept(Destination destination)
Destination
VirtualDestination. intercept(Destination destination)
Creates a virtual destination from the physical destinationDestination
VirtualDestinationInterceptor. intercept(Destination destination)
Destination
VirtualTopic. intercept(Destination destination)
Destination
CompositeQueue. interceptMappedDestination(Destination destination)
Destination
CompositeTopic. interceptMappedDestination(Destination destination)
Destination
VirtualDestination. interceptMappedDestination(Destination destination)
Creates a mapped destinationDestination
VirtualTopic. interceptMappedDestination(Destination destination)
Methods in org.apache.activemq.broker.region.virtual with parameters of type Destination Modifier and Type Method Description protected Destination
VirtualDestinationInterceptor. createCompositeDestination(Destination destination, List<Destination> destinations)
protected Destination
MirroredQueue. getMirrorDestination(Destination destination)
Destination
CompositeDestination. intercept(Destination destination)
Destination
MirroredQueue. intercept(Destination destination)
Destination
VirtualDestination. intercept(Destination destination)
Creates a virtual destination from the physical destinationDestination
VirtualDestinationInterceptor. intercept(Destination destination)
Destination
VirtualTopic. intercept(Destination destination)
Destination
CompositeQueue. interceptMappedDestination(Destination destination)
Destination
CompositeTopic. interceptMappedDestination(Destination destination)
Destination
VirtualDestination. interceptMappedDestination(Destination destination)
Creates a mapped destinationDestination
VirtualTopic. interceptMappedDestination(Destination destination)
void
CompositeDestination. remove(Destination destination)
void
MirroredQueue. remove(Destination destination)
void
VirtualDestinationInterceptor. remove(Destination destination)
void
VirtualTopic. remove(Destination destination)
protected boolean
SelectorAwareVirtualTopicInterceptor. 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 boolean
VirtualTopicInterceptor. 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 Destination
VirtualDestinationInterceptor. 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 Destination
DestinationPathSeparatorBroker. addDestination(ConnectionContext context, ActiveMQDestination destination, boolean createIfTemporary)
Destination
DestinationsPlugin. addDestination(ConnectionContext context, ActiveMQDestination destination, boolean createIfTemporary)
Destination
LoggingBrokerPlugin. addDestination(ConnectionContext context, ActiveMQDestination destination, boolean create)
Methods in org.apache.activemq.broker.util with parameters of type Destination Modifier and Type Method Description void
LoggingBrokerPlugin. isFull(ConnectionContext context, Destination destination, Usage<?> usage)
void
LoggingBrokerPlugin. 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 Destination
DestinationDotFileInterceptor. 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 Destination
EmbeddedActiveMQBroker. 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 Destination
AbstractRuntimeConfigurationBroker. 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 class
AuthorizationDestinationFilter
Authorizes addSubscription calls.Methods in org.apache.activemq.security that return Destination Modifier and Type Method Description Destination
AuthorizationBroker. addDestination(ConnectionContext context, ActiveMQDestination destination, boolean create)
Destination
AuthorizationDestinationInterceptor. intercept(Destination destination)
Methods in org.apache.activemq.security with parameters of type Destination Modifier and Type Method Description Destination
AuthorizationDestinationInterceptor. intercept(Destination destination)
void
AuthorizationDestinationInterceptor. 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 Destination
AuthorizationFilter. 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 boolean
MessageDatabase. matchType(Destination destination, KahaDestination.DestinationType type)
Determine whether this Destination matches the DestinationType
-