|
||||||||||
PREV NEXT | FRAMES NO FRAMES |
Packages that use Destination | |
---|---|
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 store |
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 Destinations |
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.security | Plugable Security Adapter framework along with default implementations such as the JAAS implementation. |
Uses of Destination in org.apache.activemq.advisory |
---|
Methods in org.apache.activemq.advisory that return Destination | |
---|---|
Destination |
AdvisoryBroker.addDestination(ConnectionContext context,
ActiveMQDestination destination,
boolean create)
|
Methods in org.apache.activemq.advisory with parameters of type Destination | |
---|---|
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 | |
---|---|
Destination |
ErrorBroker.addDestination(ConnectionContext context,
ActiveMQDestination destination,
boolean flag)
|
Destination |
BrokerBroadcaster.addDestination(ConnectionContext context,
ActiveMQDestination destination,
boolean createIfTemporary)
|
Destination |
BrokerFilter.addDestination(ConnectionContext context,
ActiveMQDestination destination,
boolean createIfTemporary)
|
Destination |
MutableBrokerFilter.addDestination(ConnectionContext context,
ActiveMQDestination destination,
boolean createIfTemporary)
|
Destination |
EmptyBroker.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 name |
Destination |
ConsumerBrokerExchange.getRegionDestination()
|
Destination |
ProducerBrokerExchange.getRegionDestination()
|
Methods in org.apache.activemq.broker that return types with arguments of type Destination | |
---|---|
java.util.Map<ActiveMQDestination,Destination> |
ErrorBroker.getDestinationMap()
|
java.util.Map<ActiveMQDestination,Destination> |
BrokerFilter.getDestinationMap()
|
java.util.Map<ActiveMQDestination,Destination> |
MutableBrokerFilter.getDestinationMap()
|
java.util.Map<ActiveMQDestination,Destination> |
EmptyBroker.getDestinationMap()
|
java.util.Set<Destination> |
BrokerFilter.getDestinations(ActiveMQDestination destination)
|
Methods in org.apache.activemq.broker with parameters of type Destination | |
---|---|
void |
ErrorBroker.isFull(ConnectionContext context,
Destination destination,
Usage usage)
|
void |
BrokerFilter.isFull(ConnectionContext context,
Destination destination,
Usage usage)
|
void |
MutableBrokerFilter.isFull(ConnectionContext context,
Destination destination,
Usage usage)
|
void |
EmptyBroker.isFull(ConnectionContext context,
Destination destination,
Usage usage)
|
void |
Broker.isFull(ConnectionContext context,
Destination destination,
Usage usage)
Called when a Usage reaches a limit |
void |
ConsumerBrokerExchange.setRegionDestination(Destination regionDestination)
|
void |
ProducerBrokerExchange.setRegionDestination(Destination regionDestination)
|
void |
ErrorBroker.slowConsumer(ConnectionContext context,
Destination destination,
Subscription subs)
|
void |
BrokerFilter.slowConsumer(ConnectionContext context,
Destination destination,
Subscription subs)
|
void |
MutableBrokerFilter.slowConsumer(ConnectionContext context,
Destination dest,
Subscription subs)
|
void |
EmptyBroker.slowConsumer(ConnectionContext context,
Destination destination,
Subscription subs)
|
void |
Broker.slowConsumer(ConnectionContext context,
Destination destination,
Subscription subs)
Called when there is a slow consumer |
Uses of Destination in org.apache.activemq.broker.jmx |
---|
Fields in org.apache.activemq.broker.jmx declared as Destination | |
---|---|
protected Destination |
DestinationView.destination
|
Methods in org.apache.activemq.broker.jmx that return Destination | |
---|---|
protected Destination |
ManagedTempTopicRegion.createDestination(ConnectionContext context,
ActiveMQDestination destination)
|
protected Destination |
ManagedTempQueueRegion.createDestination(ConnectionContext context,
ActiveMQDestination destination)
|
protected Destination |
ManagedQueueRegion.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 | |
---|---|
void |
ManagedRegionBroker.register(ActiveMQDestination destName,
Destination destination)
|
Constructors in org.apache.activemq.broker.jmx with parameters of type Destination | |
---|---|
DestinationView(ManagedRegionBroker broker,
Destination destination)
|
Uses of Destination in org.apache.activemq.broker.region |
---|
Classes in org.apache.activemq.broker.region that implement Destination | |
---|---|
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 with type parameters of type Destination | |
---|---|
protected java.util.Map<ActiveMQDestination,Destination> |
AbstractRegion.destinations
|
protected java.util.concurrent.CopyOnWriteArrayList<Destination> |
AbstractSubscription.destinations
|
Methods in org.apache.activemq.broker.region that return Destination | |
---|---|
Destination |
AbstractRegion.addDestination(ConnectionContext context,
ActiveMQDestination destination,
boolean createIfTemporary)
|
Destination |
RegionBroker.addDestination(ConnectionContext context,
ActiveMQDestination destination,
boolean create)
|
Destination |
Region.addDestination(ConnectionContext context,
ActiveMQDestination destination,
boolean createIfTemporary)
Used to create a destination. |
protected Destination |
AbstractTempRegion.createDestination(ConnectionContext context,
ActiveMQDestination destination)
|
protected Destination |
AbstractRegion.createDestination(ConnectionContext context,
ActiveMQDestination destination)
|
Destination |
DestinationFactoryImpl.createDestination(ConnectionContext context,
ActiveMQDestination destination,
DestinationStatistics destinationStatistics)
|
abstract Destination |
DestinationFactory.createDestination(ConnectionContext context,
ActiveMQDestination destination,
DestinationStatistics destinationStatistics)
Create destination implementation. |
protected Destination |
TempQueueRegion.doCreateDestination(ConnectionContext context,
ActiveMQDestination destination)
|
protected Destination |
TempTopicRegion.doCreateDestination(ConnectionContext context,
ActiveMQDestination destination)
|
protected abstract Destination |
AbstractTempRegion.doCreateDestination(ConnectionContext context,
ActiveMQDestination destination)
|
Destination |
IndirectMessageReference.getRegionDestination()
|
Destination |
MessageReference.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 | |
---|---|
java.util.Map<ActiveMQDestination,Destination> |
AbstractRegion.getDestinationMap()
|
java.util.Map<ActiveMQDestination,Destination> |
RegionBroker.getDestinationMap()
|
java.util.Map<ActiveMQDestination,Destination> |
Region.getDestinationMap()
Returns a copy of the current destinations available in the region |
java.util.Set<Destination> |
AbstractRegion.getDestinations(ActiveMQDestination destination)
Provide an exact or wildcard lookup of destinations in the region |
java.util.Set<Destination> |
RegionBroker.getDestinations(ActiveMQDestination destination)
|
java.util.Set<Destination> |
Region.getDestinations(ActiveMQDestination destination)
Provide an exact or wildcard lookup of destinations in the region |
Methods in org.apache.activemq.broker.region with parameters of type Destination | |
---|---|
void |
PrefetchSubscription.add(ConnectionContext context,
Destination destination)
|
void |
DurableTopicSubscription.add(ConnectionContext context,
Destination destination)
|
void |
AbstractSubscription.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 destination |
protected java.util.List<Subscription> |
AbstractRegion.addSubscriptionsForDestination(ConnectionContext context,
Destination dest)
|
protected java.util.List<Subscription> |
TopicRegion.addSubscriptionsForDestination(ConnectionContext context,
Destination dest)
|
protected void |
AbstractTempRegion.dispose(ConnectionContext context,
Destination dest)
|
protected void |
AbstractRegion.dispose(ConnectionContext context,
Destination dest)
|
Destination |
CompositeDestinationInterceptor.intercept(Destination destination)
|
Destination |
DestinationInterceptor.intercept(Destination destination)
|
java.util.List<MessageReference> |
PrefetchSubscription.remove(ConnectionContext context,
Destination destination)
|
java.util.List<MessageReference> |
AbstractSubscription.remove(ConnectionContext context,
Destination destination)
|
java.util.List<MessageReference> |
Subscription.remove(ConnectionContext context,
Destination destination)
The subscription will be no longer be receiving messages from the destination. |
void |
CompositeDestinationInterceptor.remove(Destination destination)
|
void |
DestinationInterceptor.remove(Destination destination)
|
void |
DestinationFactoryImpl.removeDestination(Destination dest)
|
void |
AbstractSubscription.removeDestination(Destination destination)
Remove a destination |
abstract void |
DestinationFactory.removeDestination(Destination dest)
|
Constructors in org.apache.activemq.broker.region with parameters of type Destination | |
---|---|
DestinationFilter(Destination next)
|
Uses of Destination in org.apache.activemq.broker.region.cursors |
---|
Fields in org.apache.activemq.broker.region.cursors declared as Destination | |
---|---|
protected Destination |
AbstractStoreCursor.regionDestination
|
Methods in org.apache.activemq.broker.region.cursors with parameters of type Destination | |
---|---|
void |
StoreDurableSubscriberCursor.add(ConnectionContext context,
Destination destination)
Add a destination |
void |
AbstractPendingMessageCursor.add(ConnectionContext context,
Destination destination)
|
void |
PendingMessageCursor.add(ConnectionContext context,
Destination destination)
Add a destination |
boolean |
StoreDurableSubscriberCursor.isEmpty(Destination destination)
|
boolean |
AbstractPendingMessageCursor.isEmpty(Destination destination)
|
boolean |
PendingMessageCursor.isEmpty(Destination destination)
check if a Destination is Empty for this cursor |
java.util.List<MessageReference> |
VMPendingMessageCursor.remove(ConnectionContext context,
Destination destination)
|
java.util.List<MessageReference> |
StoreDurableSubscriberCursor.remove(ConnectionContext context,
Destination destination)
remove a destination |
java.util.List<MessageReference> |
AbstractPendingMessageCursor.remove(ConnectionContext context,
Destination destination)
|
java.util.List<MessageReference> |
PendingMessageCursor.remove(ConnectionContext context,
Destination destination)
remove a destination |
Constructors in org.apache.activemq.broker.region.cursors with parameters of type Destination | |
---|---|
AbstractStoreCursor(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 | |
---|---|
protected void |
QueryBasedSubscriptionRecoveryPolicy.dispatchInitialMessage(javax.jms.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 | |
---|---|
class |
CompositeDestinationFilter
Represents a composite Destination where send()s are replicated to
each Destination instance. |
class |
SelectorAwareVirtualTopicInterceptor
|
class |
VirtualTopicInterceptor
A Destination which implements Virtual Topic |
Methods in org.apache.activemq.broker.region.virtual that return Destination | |
---|---|
protected Destination |
VirtualDestinationInterceptor.createCompositeDestination(Destination destination,
java.util.List<Destination> destinations)
|
protected Destination |
MirroredQueue.getMirrorDestination(Destination destination)
|
Destination |
VirtualDestinationInterceptor.intercept(Destination destination)
|
Destination |
MirroredQueue.intercept(Destination destination)
|
Destination |
CompositeDestination.intercept(Destination destination)
|
Destination |
VirtualDestination.intercept(Destination destination)
Creates a virtual destination from the physical destination |
Destination |
VirtualTopic.intercept(Destination destination)
|
Methods in org.apache.activemq.broker.region.virtual with parameters of type Destination | |
---|---|
protected Destination |
VirtualDestinationInterceptor.createCompositeDestination(Destination destination,
java.util.List<Destination> destinations)
|
protected Destination |
MirroredQueue.getMirrorDestination(Destination destination)
|
Destination |
VirtualDestinationInterceptor.intercept(Destination destination)
|
Destination |
MirroredQueue.intercept(Destination destination)
|
Destination |
CompositeDestination.intercept(Destination destination)
|
Destination |
VirtualDestination.intercept(Destination destination)
Creates a virtual destination from the physical destination |
Destination |
VirtualTopic.intercept(Destination destination)
|
void |
VirtualDestinationInterceptor.remove(Destination destination)
|
void |
MirroredQueue.remove(Destination destination)
|
void |
CompositeDestination.remove(Destination destination)
|
void |
VirtualTopic.remove(Destination destination)
|
Method parameters in org.apache.activemq.broker.region.virtual with type arguments of type Destination | |
---|---|
protected Destination |
VirtualDestinationInterceptor.createCompositeDestination(Destination destination,
java.util.List<Destination> destinations)
|
Constructors in org.apache.activemq.broker.region.virtual with parameters of type Destination | |
---|---|
CompositeDestinationFilter(Destination next,
java.util.Collection forwardDestinations,
boolean forwardOnly,
boolean copyMessage)
|
|
SelectorAwareVirtualTopicInterceptor(Destination next,
java.lang.String prefix,
java.lang.String postfix)
|
|
VirtualTopicInterceptor(Destination next,
java.lang.String prefix,
java.lang.String postfix)
|
Uses of Destination in org.apache.activemq.broker.util |
---|
Methods in org.apache.activemq.broker.util that return Destination | |
---|---|
Destination |
DestinationPathSeparatorBroker.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 | |
---|---|
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 | |
---|---|
Destination |
DestinationDotFileInterceptor.addDestination(ConnectionContext context,
ActiveMQDestination destination,
boolean create)
|
Uses of Destination in org.apache.activemq.command |
---|
Methods in org.apache.activemq.command that return Destination | |
---|---|
Destination |
Message.getRegionDestination()
|
Methods in org.apache.activemq.command with parameters of type Destination | |
---|---|
void |
Message.setRegionDestination(Destination destination)
|
Uses of Destination in org.apache.activemq.security |
---|
Methods in org.apache.activemq.security that return Destination | |
---|---|
Destination |
AuthorizationBroker.addDestination(ConnectionContext context,
ActiveMQDestination destination,
boolean create)
|
|
||||||||||
PREV NEXT | FRAMES NO FRAMES |