|
||||||||||
| PREV NEXT | FRAMES NO FRAMES | |||||||||
| Packages that use ActiveMQDestination | |
|---|---|
| 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.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.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.filter | Filter implementations for wildcards & JMS selectors |
| org.apache.activemq.memory.list | |
| 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.store | The APIs which need to be implemented for persistent message stores for durable messaging |
| org.apache.activemq.store.amq | The default Store implementation for ActiveMQ |
| org.apache.activemq.store.jdbc | Message persistence implemented using JDBC |
| org.apache.activemq.store.jdbc.adapter | Implements database/driver apapters to compensate for the wide differences in the BLOB handing of JDBC drivers. |
| org.apache.activemq.store.journal | Message persistence using a high performance transaction log via the Journal interface. |
| org.apache.activemq.store.kahadaptor | kaha implementation of message persistence for the broker |
| org.apache.activemq.store.memory | VM based implementation of message persistence |
| 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.util | Some utility classes |
| Uses of ActiveMQDestination in org.apache.activemq |
|---|
| Methods in org.apache.activemq that return ActiveMQDestination | |
|---|---|
protected ActiveMQDestination |
ActiveMQMessageConsumer.getDestination()
|
static ActiveMQDestination |
ActiveMQMessageTransformation.transformDestination(Destination destination)
Creates a an available JMS message from another provider. |
| Methods in org.apache.activemq with parameters of type ActiveMQDestination | |
|---|---|
void |
ActiveMQConnection.destroyDestination(ActiveMQDestination destination)
|
boolean |
ActiveMQConnection.isDeleted(ActiveMQDestination dest)
|
protected void |
ActiveMQSession.send(ActiveMQMessageProducer producer,
ActiveMQDestination destination,
Message message,
int deliveryMode,
int priority,
long timeToLive,
MemoryUsage producerWindow,
int sendTimeout)
Sends the message for dispatch by the broker. |
| Constructors in org.apache.activemq with parameters of type ActiveMQDestination | |
|---|---|
ActiveMQInputStream(ActiveMQConnection connection,
ConsumerId consumerId,
ActiveMQDestination dest,
String selector,
boolean noLocal,
String name,
int prefetch)
|
|
ActiveMQMessageConsumer(ActiveMQSession session,
ConsumerId consumerId,
ActiveMQDestination dest,
String name,
String selector,
int prefetch,
int maximumPendingMessageCount,
boolean noLocal,
boolean browser,
boolean dispatchAsync,
MessageListener messageListener)
Create a MessageConsumer |
|
ActiveMQMessageProducer(ActiveMQSession session,
ProducerId producerId,
ActiveMQDestination destination,
int sendTimeout)
|
|
ActiveMQOutputStream(ActiveMQConnection connection,
ProducerId producerId,
ActiveMQDestination destination,
Map<String,Object> properties,
int deliveryMode,
int priority,
long timeToLive)
|
|
ActiveMQQueueBrowser(ActiveMQSession session,
ConsumerId consumerId,
ActiveMQDestination destination,
String selector,
boolean dispatchAsync)
Constructor for an ActiveMQQueueBrowser - used internally |
|
ActiveMQQueueReceiver(ActiveMQSession theSession,
ConsumerId consumerId,
ActiveMQDestination destination,
String selector,
int prefetch,
int maximumPendingMessageCount,
boolean asyncDispatch)
|
|
ActiveMQQueueSender(ActiveMQSession session,
ActiveMQDestination destination,
int sendTimeout)
|
|
ActiveMQTopicPublisher(ActiveMQSession session,
ActiveMQDestination destination,
int sendTimeout)
|
|
ActiveMQTopicSubscriber(ActiveMQSession theSession,
ConsumerId consumerId,
ActiveMQDestination dest,
String name,
String selector,
int prefetch,
int maximumPendingMessageCount,
boolean noLocalValue,
boolean browserValue,
boolean asyncDispatch)
|
|
| Uses of ActiveMQDestination in org.apache.activemq.advisory |
|---|
| Fields in org.apache.activemq.advisory with type parameters of type ActiveMQDestination | |
|---|---|
protected ConcurrentHashMap<ActiveMQDestination,DestinationInfo> |
AdvisoryBroker.destinations
|
| Methods in org.apache.activemq.advisory that return ActiveMQDestination | |
|---|---|
ActiveMQDestination |
DestinationEvent.getDestination()
|
| Methods in org.apache.activemq.advisory that return types with arguments of type ActiveMQDestination | |
|---|---|
Map<ActiveMQDestination,DestinationInfo> |
AdvisoryBroker.getAdvisoryDestinations()
|
| Constructors in org.apache.activemq.advisory with parameters of type ActiveMQDestination | |
|---|---|
ConsumerStartedEvent(ConsumerEventSource source,
ActiveMQDestination destination,
ConsumerInfo consumerInfo,
int count)
|
|
ConsumerStoppedEvent(ConsumerEventSource source,
ActiveMQDestination destination,
ConsumerId consumerId,
int count)
|
|
ProducerStartedEvent(ProducerEventSource source,
ActiveMQDestination destination,
ProducerInfo consumerInfo,
int count)
|
|
ProducerStoppedEvent(ProducerEventSource source,
ActiveMQDestination destination,
ProducerId consumerId,
int count)
|
|
| Uses of ActiveMQDestination in org.apache.activemq.broker |
|---|
| Methods in org.apache.activemq.broker that return ActiveMQDestination | |
|---|---|
ActiveMQDestination |
DestinationAlreadyExistsException.getDestination()
|
ActiveMQDestination[] |
ErrorBroker.getDestinations()
|
ActiveMQDestination[] |
EmptyBroker.getDestinations()
|
ActiveMQDestination[] |
Broker.getDestinations()
|
ActiveMQDestination[] |
BrokerService.getDestinations()
|
ActiveMQDestination[] |
BrokerFilter.getDestinations()
|
ActiveMQDestination[] |
MutableBrokerFilter.getDestinations()
|
| Methods in org.apache.activemq.broker that return types with arguments of type ActiveMQDestination | |
|---|---|
Map<ActiveMQDestination,Destination> |
ErrorBroker.getDestinationMap()
|
Map<ActiveMQDestination,Destination> |
EmptyBroker.getDestinationMap()
|
Map<ActiveMQDestination,Destination> |
BrokerFilter.getDestinationMap()
|
Map<ActiveMQDestination,Destination> |
MutableBrokerFilter.getDestinationMap()
|
Set<ActiveMQDestination> |
ErrorBroker.getDurableDestinations()
|
Set<ActiveMQDestination> |
EmptyBroker.getDurableDestinations()
|
Set<ActiveMQDestination> |
Broker.getDurableDestinations()
|
Set<ActiveMQDestination> |
BrokerFilter.getDurableDestinations()
|
Set<ActiveMQDestination> |
MutableBrokerFilter.getDurableDestinations()
|
| Methods in org.apache.activemq.broker with parameters of type ActiveMQDestination | |
|---|---|
Destination |
BrokerBroadcaster.addDestination(ConnectionContext context,
ActiveMQDestination destination)
|
Destination |
ErrorBroker.addDestination(ConnectionContext context,
ActiveMQDestination destination)
|
Destination |
EmptyBroker.addDestination(ConnectionContext context,
ActiveMQDestination destination)
|
Destination |
BrokerFilter.addDestination(ConnectionContext context,
ActiveMQDestination destination)
|
Destination |
MutableBrokerFilter.addDestination(ConnectionContext context,
ActiveMQDestination destination)
|
Destination |
BrokerService.getDestination(ActiveMQDestination destination)
Looks up and lazily creates if necessary the destination for the given JMS name |
Set |
ErrorBroker.getDestinations(ActiveMQDestination destination)
|
Set |
EmptyBroker.getDestinations(ActiveMQDestination destination)
|
Set<Destination> |
BrokerFilter.getDestinations(ActiveMQDestination destination)
|
Set |
MutableBrokerFilter.getDestinations(ActiveMQDestination destination)
|
void |
BrokerService.removeDestination(ActiveMQDestination destination)
|
void |
BrokerBroadcaster.removeDestination(ConnectionContext context,
ActiveMQDestination destination,
long timeout)
|
void |
ErrorBroker.removeDestination(ConnectionContext context,
ActiveMQDestination destination,
long timeout)
|
void |
EmptyBroker.removeDestination(ConnectionContext context,
ActiveMQDestination destination,
long timeout)
|
void |
BrokerFilter.removeDestination(ConnectionContext context,
ActiveMQDestination destination,
long timeout)
|
void |
MutableBrokerFilter.removeDestination(ConnectionContext context,
ActiveMQDestination destination,
long timeout)
|
void |
BrokerService.setDestinations(ActiveMQDestination[] destinations)
Sets the destinations which should be loaded/created on startup |
| Constructors in org.apache.activemq.broker with parameters of type ActiveMQDestination | |
|---|---|
DestinationAlreadyExistsException(ActiveMQDestination destination)
|
|
| Uses of ActiveMQDestination in org.apache.activemq.broker.jmx |
|---|
| Methods in org.apache.activemq.broker.jmx with parameters of type ActiveMQDestination | |
|---|---|
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)
|
protected ObjectName |
ManagedRegionBroker.createObjectName(ActiveMQDestination destName)
|
boolean |
SubscriptionView.matchesDestination(ActiveMQDestination destination)
Return true if this subscription matches the given destination |
void |
ManagedRegionBroker.register(ActiveMQDestination destName,
Destination destination)
|
protected void |
ManagedRegionBroker.registerDestination(ObjectName key,
ActiveMQDestination dest,
DestinationView view)
|
void |
ManagedQueueRegion.removeDestination(ConnectionContext context,
ActiveMQDestination destination,
long timeout)
|
void |
ManagedTempQueueRegion.removeDestination(ConnectionContext context,
ActiveMQDestination destination,
long timeout)
|
void |
ManagedTempTopicRegion.removeDestination(ConnectionContext context,
ActiveMQDestination destination,
long timeout)
|
void |
ManagedTopicRegion.removeDestination(ConnectionContext context,
ActiveMQDestination destination,
long timeout)
|
void |
ManagedRegionBroker.unregister(ActiveMQDestination destName)
|
| Uses of ActiveMQDestination in org.apache.activemq.broker.region |
|---|
| Fields in org.apache.activemq.broker.region declared as ActiveMQDestination | |
|---|---|
protected ActiveMQDestination |
BaseDestination.destination
|
| Fields in org.apache.activemq.broker.region with type parameters of type ActiveMQDestination | |
|---|---|
protected Map<ActiveMQDestination,Destination> |
AbstractRegion.destinations
|
| Methods in org.apache.activemq.broker.region that return ActiveMQDestination | |
|---|---|
ActiveMQDestination |
Queue.getActiveMQDestination()
|
ActiveMQDestination |
AbstractSubscription.getActiveMQDestination()
|
ActiveMQDestination |
SubscriptionRecovery.getActiveMQDestination()
|
ActiveMQDestination |
Destination.getActiveMQDestination()
|
ActiveMQDestination |
DestinationFilter.getActiveMQDestination()
|
ActiveMQDestination |
BaseDestination.getActiveMQDestination()
|
ActiveMQDestination[] |
RegionBroker.getDestinations()
|
| Methods in org.apache.activemq.broker.region that return types with arguments of type ActiveMQDestination | |
|---|---|
Map<ActiveMQDestination,Destination> |
RegionBroker.getDestinationMap()
|
Map<ActiveMQDestination,Destination> |
AbstractRegion.getDestinationMap()
|
Map<ActiveMQDestination,Destination> |
Region.getDestinationMap()
Returns a copy of the current destinations available in the region |
Set<ActiveMQDestination> |
DestinationFactoryImpl.getDestinations()
|
abstract Set<ActiveMQDestination> |
DestinationFactory.getDestinations()
Returns a set of all the ActiveMQDestination
objects that the persistence store is aware exist. |
Set<ActiveMQDestination> |
RegionBroker.getDurableDestinations()
|
protected Set<ActiveMQDestination> |
TopicRegion.getInactiveDestinations()
|
protected Set<ActiveMQDestination> |
QueueRegion.getInactiveDestinations()
|
protected Set<ActiveMQDestination> |
AbstractRegion.getInactiveDestinations()
|
| Methods in org.apache.activemq.broker.region with parameters of type ActiveMQDestination | |
|---|---|
Destination |
RegionBroker.addDestination(ConnectionContext context,
ActiveMQDestination destination)
|
Destination |
AbstractRegion.addDestination(ConnectionContext context,
ActiveMQDestination destination)
|
Destination |
Region.addDestination(ConnectionContext context,
ActiveMQDestination destination)
Used to create a destination. |
protected void |
DestinationFactoryImpl.configureQueue(Queue queue,
ActiveMQDestination destination)
|
protected void |
DestinationFactoryImpl.configureTopic(Topic topic,
ActiveMQDestination destination)
|
protected void |
TopicRegion.configureTopic(Topic topic,
ActiveMQDestination destination)
|
int |
Queue.copyMatchingMessages(ConnectionContext context,
MessageReferenceFilter filter,
ActiveMQDestination dest,
int maximumMessages)
Copies the messages matching the given filter up to the maximum number of matched messages |
int |
Queue.copyMatchingMessagesTo(ConnectionContext context,
String selector,
ActiveMQDestination dest)
Copies the messages matching the given selector |
int |
Queue.copyMatchingMessagesTo(ConnectionContext context,
String selector,
ActiveMQDestination dest,
int maximumMessages)
Copies the messages matching the given selector up to the maximum number of matched messages |
boolean |
Queue.copyMessageTo(ConnectionContext context,
String messageId,
ActiveMQDestination dest)
Copies the message matching the given messageId |
protected Destination |
AbstractRegion.createDestination(ConnectionContext context,
ActiveMQDestination destination)
|
protected Destination |
AbstractTempRegion.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 JMSException |
RegionBroker.createUnknownDestinationTypeException(ActiveMQDestination destination)
|
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)
|
Set<Destination> |
RegionBroker.getDestinations(ActiveMQDestination destination)
|
Set |
AbstractRegion.getDestinations(ActiveMQDestination destination)
Provide an exact or wildcard lookup of destinations in the region |
Set<Destination> |
Region.getDestinations(ActiveMQDestination destination)
Provide an exact or wildcard lookup of destinations in the region |
protected Destination |
AbstractRegion.lookup(ConnectionContext context,
ActiveMQDestination destination)
|
boolean |
AbstractSubscription.matches(ActiveMQDestination destination)
|
boolean |
Subscription.matches(ActiveMQDestination destination)
Is the subscription interested in messages in the destination? |
int |
Queue.moveMatchingMessagesTo(ConnectionContext context,
MessageReferenceFilter filter,
ActiveMQDestination dest,
int maximumMessages)
Moves the messages matching the given filter up to the maximum number of matched messages |
int |
Queue.moveMatchingMessagesTo(ConnectionContext context,
String selector,
ActiveMQDestination dest)
Moves the messages matching the given selector |
int |
Queue.moveMatchingMessagesTo(ConnectionContext context,
String selector,
ActiveMQDestination dest,
int maximumMessages)
Moves the messages matching the given selector up to the maximum number of matched messages |
boolean |
Queue.moveMessageTo(ConnectionContext context,
Message m,
ActiveMQDestination dest)
Move a message |
boolean |
Queue.moveMessageTo(ConnectionContext context,
String messageId,
ActiveMQDestination dest)
Moves the message matching the given messageId |
void |
TempQueueRegion.removeDestination(ConnectionContext context,
ActiveMQDestination destination,
long timeout)
|
void |
TempTopicRegion.removeDestination(ConnectionContext context,
ActiveMQDestination destination,
long timeout)
|
void |
RegionBroker.removeDestination(ConnectionContext context,
ActiveMQDestination destination,
long timeout)
|
void |
AbstractRegion.removeDestination(ConnectionContext context,
ActiveMQDestination destination,
long timeout)
|
void |
Region.removeDestination(ConnectionContext context,
ActiveMQDestination destination,
long timeout)
Used to destroy a destination. |
protected void |
DestinationFilter.send(ProducerBrokerExchange context,
Message message,
ActiveMQDestination destination)
Sends a message to the given destination which may be a wildcard |
| Constructors in org.apache.activemq.broker.region with parameters of type ActiveMQDestination | |
|---|---|
BaseDestination(BrokerService brokerService,
MessageStore store,
ActiveMQDestination destination,
DestinationStatistics parentStats)
|
|
Queue(BrokerService brokerService,
ActiveMQDestination destination,
MessageStore store,
DestinationStatistics parentStats,
TaskRunnerFactory taskFactory)
|
|
QueueDispatchSelector(ActiveMQDestination destination)
|
|
TempQueue(BrokerService brokerService,
ActiveMQDestination destination,
MessageStore store,
DestinationStatistics parentStats,
TaskRunnerFactory taskFactory)
|
|
TempTopic(BrokerService brokerService,
ActiveMQDestination destination,
TopicMessageStore store,
DestinationStatistics parentStats,
TaskRunnerFactory taskFactory)
|
|
Topic(BrokerService brokerService,
ActiveMQDestination destination,
TopicMessageStore store,
DestinationStatistics parentStats,
TaskRunnerFactory taskFactory)
|
|
| Uses of ActiveMQDestination in org.apache.activemq.broker.region.policy |
|---|
| Methods in org.apache.activemq.broker.region.policy that return ActiveMQDestination | |
|---|---|
protected ActiveMQDestination |
IndividualDeadLetterStrategy.createDestination(ActiveMQDestination originalDestination,
String prefix,
boolean useQueue)
|
ActiveMQDestination |
SharedDeadLetterStrategy.getDeadLetterQueue()
|
ActiveMQDestination |
SharedDeadLetterStrategy.getDeadLetterQueueFor(ActiveMQDestination originalDestination)
|
ActiveMQDestination |
DeadLetterStrategy.getDeadLetterQueueFor(ActiveMQDestination originalDestination)
Returns the dead letter queue for the given destination. |
ActiveMQDestination |
IndividualDeadLetterStrategy.getDeadLetterQueueFor(ActiveMQDestination originalDestination)
|
| Methods in org.apache.activemq.broker.region.policy with parameters of type ActiveMQDestination | |
|---|---|
Message[] |
NoSubscriptionRecoveryPolicy.browse(ActiveMQDestination dest)
|
Message[] |
SubscriptionRecoveryPolicy.browse(ActiveMQDestination dest)
|
Message[] |
FixedSizedSubscriptionRecoveryPolicy.browse(ActiveMQDestination destination)
|
Message[] |
TimedSubscriptionRecoveryPolicy.browse(ActiveMQDestination destination)
|
Message[] |
QueryBasedSubscriptionRecoveryPolicy.browse(ActiveMQDestination dest)
|
Message[] |
LastImageSubscriptionRecoveryPolicy.browse(ActiveMQDestination destination)
|
Message[] |
FixedCountSubscriptionRecoveryPolicy.browse(ActiveMQDestination destination)
|
protected ActiveMQDestination |
IndividualDeadLetterStrategy.createDestination(ActiveMQDestination originalDestination,
String prefix,
boolean useQueue)
|
void |
MessageQuery.execute(ActiveMQDestination destination,
MessageListener listener)
Executes the query for messages; each message is passed into the listener |
ActiveMQDestination |
SharedDeadLetterStrategy.getDeadLetterQueueFor(ActiveMQDestination originalDestination)
|
ActiveMQDestination |
DeadLetterStrategy.getDeadLetterQueueFor(ActiveMQDestination originalDestination)
Returns the dead letter queue for the given destination. |
ActiveMQDestination |
IndividualDeadLetterStrategy.getDeadLetterQueueFor(ActiveMQDestination originalDestination)
|
PolicyEntry |
PolicyMap.getEntryFor(ActiveMQDestination destination)
|
void |
SharedDeadLetterStrategy.setDeadLetterQueue(ActiveMQDestination deadLetterQueue)
|
| Constructors in org.apache.activemq.broker.region.policy with parameters of type ActiveMQDestination | |
|---|---|
SimpleDispatchSelector(ActiveMQDestination destination)
|
|
| Uses of ActiveMQDestination in org.apache.activemq.broker.region.virtual |
|---|
| Methods in org.apache.activemq.broker.region.virtual that return ActiveMQDestination | |
|---|---|
ActiveMQDestination |
FilteredDestination.getDestination()
|
protected ActiveMQDestination |
MirroredQueue.getMirrorTopic(ActiveMQDestination original)
|
protected ActiveMQDestination |
VirtualTopicInterceptor.getQueueConsumersWildcard(ActiveMQDestination original)
|
ActiveMQDestination |
CompositeTopic.getVirtualDestination()
|
ActiveMQDestination |
VirtualDestination.getVirtualDestination()
Returns the virtual destination |
ActiveMQDestination |
CompositeQueue.getVirtualDestination()
|
ActiveMQDestination |
VirtualTopic.getVirtualDestination()
|
| Methods in org.apache.activemq.broker.region.virtual with parameters of type ActiveMQDestination | |
|---|---|
protected ActiveMQDestination |
MirroredQueue.getMirrorTopic(ActiveMQDestination original)
|
protected ActiveMQDestination |
VirtualTopicInterceptor.getQueueConsumersWildcard(ActiveMQDestination original)
|
void |
FilteredDestination.setDestination(ActiveMQDestination destination)
The destination to send messages to if they match the filter |
| Uses of ActiveMQDestination in org.apache.activemq.broker.util |
|---|
| Methods in org.apache.activemq.broker.util with parameters of type ActiveMQDestination | |
|---|---|
void |
UDPTraceBrokerPlugin.removeDestination(ConnectionContext context,
ActiveMQDestination destination,
long timeout)
|
| Uses of ActiveMQDestination in org.apache.activemq.broker.view |
|---|
| Methods in org.apache.activemq.broker.view with parameters of type ActiveMQDestination | |
|---|---|
Destination |
DestinationDotFileInterceptor.addDestination(ConnectionContext context,
ActiveMQDestination destination)
|
void |
DestinationDotFileInterceptor.removeDestination(ConnectionContext context,
ActiveMQDestination destination,
long timeout)
|
| Uses of ActiveMQDestination in org.apache.activemq.command |
|---|
| Subclasses of ActiveMQDestination in org.apache.activemq.command | |
|---|---|
class |
ActiveMQQueue
|
class |
ActiveMQTempDestination
|
class |
ActiveMQTempQueue
|
class |
ActiveMQTempTopic
|
class |
ActiveMQTopic
|
| Fields in org.apache.activemq.command declared as ActiveMQDestination | |
|---|---|
protected ActiveMQDestination[] |
ActiveMQDestination.compositeDestinations
|
protected ActiveMQDestination |
MessageAck.destination
|
protected ActiveMQDestination |
MessagePull.destination
|
protected ActiveMQDestination |
SubscriptionInfo.destination
|
protected ActiveMQDestination |
ConsumerInfo.destination
|
protected ActiveMQDestination |
DestinationInfo.destination
|
protected ActiveMQDestination |
Message.destination
|
protected ActiveMQDestination |
MessageDispatchNotification.destination
|
protected ActiveMQDestination |
ProducerInfo.destination
|
protected ActiveMQDestination |
MessageDispatch.destination
|
protected ActiveMQDestination |
Message.originalDestination
|
protected ActiveMQDestination |
Message.replyTo
|
protected ActiveMQDestination |
SubscriptionInfo.subscribedDestination
|
| Methods in org.apache.activemq.command with parameters of type ActiveMQDestination | |
|---|---|
static int |
ActiveMQDestination.compare(ActiveMQDestination destination,
ActiveMQDestination destination2)
|
void |
ActiveMQDestination.setCompositeDestinations(ActiveMQDestination[] destinations)
|
void |
JournalQueueAck.setDestination(ActiveMQDestination destination)
|
void |
MessageAck.setDestination(ActiveMQDestination destination)
|
void |
MessagePull.setDestination(ActiveMQDestination destination)
|
void |
SubscriptionInfo.setDestination(ActiveMQDestination destination)
|
void |
ConsumerInfo.setDestination(ActiveMQDestination destination)
|
void |
DestinationInfo.setDestination(ActiveMQDestination destination)
|
void |
Message.setDestination(ActiveMQDestination destination)
|
void |
JournalTopicAck.setDestination(ActiveMQDestination destination)
|
void |
MessageDispatchNotification.setDestination(ActiveMQDestination destination)
|
void |
ProducerInfo.setDestination(ActiveMQDestination destination)
|
void |
MessageDispatch.setDestination(ActiveMQDestination destination)
|
void |
Message.setOriginalDestination(ActiveMQDestination destination)
|
void |
Message.setReplyTo(ActiveMQDestination replyTo)
|
void |
SubscriptionInfo.setSubscribedDestination(ActiveMQDestination subscribedDestination)
|
| Constructors in org.apache.activemq.command with parameters of type ActiveMQDestination | |
|---|---|
ActiveMQDestination(ActiveMQDestination[] composites)
|
|
DestinationInfo(ConnectionId connectionId,
byte operationType,
ActiveMQDestination destination)
|
|
| Uses of ActiveMQDestination in org.apache.activemq.filter |
|---|
| Fields in org.apache.activemq.filter declared as ActiveMQDestination | |
|---|---|
protected ActiveMQDestination |
MessageEvaluationContext.destination
|
| Methods in org.apache.activemq.filter that return ActiveMQDestination | |
|---|---|
ActiveMQDestination |
DestinationMapEntry.getDestination()
|
ActiveMQDestination |
MessageEvaluationContext.getDestination()
|
| Methods in org.apache.activemq.filter with parameters of type ActiveMQDestination | |
|---|---|
Object |
DestinationMap.chooseValue(ActiveMQDestination destination)
Returns the value which matches the given destination or null if there is no matching value. |
protected Set |
DestinationMap.findWildcardMatches(ActiveMQDestination key)
|
Set |
DestinationMap.get(ActiveMQDestination key)
Looks up the value(s) matching the given Destination key. |
static String[] |
DestinationPath.getDestinationPaths(ActiveMQDestination destination)
|
protected DestinationMapNode |
DestinationMap.getRootNode(ActiveMQDestination key)
Returns the root node for the given destination type |
boolean |
SimpleDestinationFilter.matches(ActiveMQDestination destination)
|
boolean |
WildcardDestinationFilter.matches(ActiveMQDestination destination)
|
boolean |
CompositeDestinationFilter.matches(ActiveMQDestination destination)
|
abstract boolean |
DestinationFilter.matches(ActiveMQDestination destination)
|
boolean |
PrefixDestinationFilter.matches(ActiveMQDestination destination)
|
static DestinationFilter |
DestinationFilter.parseFilter(ActiveMQDestination destination)
|
void |
DestinationMap.put(ActiveMQDestination key,
Object value)
|
void |
DestinationMap.remove(ActiveMQDestination key,
Object value)
Removes the value from the associated destination |
Set |
DestinationMap.removeAll(ActiveMQDestination key)
|
void |
DestinationMapEntry.setDestination(ActiveMQDestination destination)
|
void |
MessageEvaluationContext.setDestination(ActiveMQDestination destination)
|
| Constructors in org.apache.activemq.filter with parameters of type ActiveMQDestination | |
|---|---|
CompositeDestinationFilter(ActiveMQDestination destination)
|
|
SimpleDestinationFilter(ActiveMQDestination destination)
|
|
| Uses of ActiveMQDestination in org.apache.activemq.memory.list |
|---|
| Methods in org.apache.activemq.memory.list with parameters of type ActiveMQDestination | |
|---|---|
Message[] |
SimpleMessageList.browse(ActiveMQDestination destination)
|
Message[] |
MessageList.browse(ActiveMQDestination destination)
|
Message[] |
DestinationBasedMessageList.browse(ActiveMQDestination destination)
|
List<MessageReference> |
SimpleMessageList.getMessages(ActiveMQDestination destination)
|
List |
MessageList.getMessages(ActiveMQDestination destination)
Returns the current list of MessageReference objects for the given subscription |
List<MessageReference> |
DestinationBasedMessageList.getMessages(ActiveMQDestination destination)
|
| Uses of ActiveMQDestination in org.apache.activemq.network |
|---|
| Fields in org.apache.activemq.network declared as ActiveMQDestination | |
|---|---|
protected ActiveMQDestination[] |
DemandForwardingBridgeSupport.durableDestinations
|
protected ActiveMQDestination[] |
DemandForwardingBridgeSupport.dynamicallyIncludedDestinations
|
protected ActiveMQDestination[] |
DemandForwardingBridgeSupport.excludedDestinations
|
protected ActiveMQDestination[] |
DemandForwardingBridgeSupport.staticallyIncludedDestinations
|
| Methods in org.apache.activemq.network that return ActiveMQDestination | |
|---|---|
ActiveMQDestination[] |
DemandForwardingBridgeSupport.getDurableDestinations()
|
ActiveMQDestination[] |
DemandForwardingBridgeSupport.getDynamicallyIncludedDestinations()
|
ActiveMQDestination[] |
DemandForwardingBridgeSupport.getExcludedDestinations()
|
ActiveMQDestination[] |
DemandForwardingBridgeSupport.getStaticallyIncludedDestinations()
|
| Methods in org.apache.activemq.network that return types with arguments of type ActiveMQDestination | |
|---|---|
List<ActiveMQDestination> |
NetworkConnector.getDynamicallyIncludedDestinations()
|
List<ActiveMQDestination> |
NetworkConnector.getExcludedDestinations()
|
List<ActiveMQDestination> |
NetworkConnector.getStaticallyIncludedDestinations()
|
| Methods in org.apache.activemq.network with parameters of type ActiveMQDestination | |
|---|---|
void |
NetworkConnector.addDynamicallyIncludedDestination(ActiveMQDestination destiantion)
|
void |
NetworkConnector.addExcludedDestination(ActiveMQDestination destiantion)
|
void |
NetworkConnector.addStaticallyIncludedDestination(ActiveMQDestination destiantion)
|
protected DemandSubscription |
DemandForwardingBridgeSupport.createDemandSubscription(ActiveMQDestination destination)
|
protected boolean |
DurableConduitBridge.doesConsumerExist(ActiveMQDestination dest)
|
protected String |
DurableConduitBridge.getSubscriberName(ActiveMQDestination dest)
|
protected boolean |
DemandForwardingBridgeSupport.isPermissableDestination(ActiveMQDestination destination)
|
void |
DemandForwardingBridgeSupport.setDurableDestinations(ActiveMQDestination[] durableDestinations)
|
void |
DemandForwardingBridgeSupport.setDynamicallyIncludedDestinations(ActiveMQDestination[] dynamicallyIncludedDestinations)
|
void |
DemandForwardingBridgeSupport.setExcludedDestinations(ActiveMQDestination[] excludedDestinations)
|
void |
DemandForwardingBridgeSupport.setStaticallyIncludedDestinations(ActiveMQDestination[] staticallyIncludedDestinations)
|
| Method parameters in org.apache.activemq.network with type arguments of type ActiveMQDestination | |
|---|---|
void |
NetworkConnector.setDurableDestinations(Set<ActiveMQDestination> durableDestinations)
|
void |
NetworkConnector.setDynamicallyIncludedDestinations(List<ActiveMQDestination> dynamicallyIncludedDestinations)
|
void |
NetworkConnector.setExcludedDestinations(List<ActiveMQDestination> excludedDestinations)
|
void |
NetworkConnector.setStaticallyIncludedDestinations(List<ActiveMQDestination> staticallyIncludedDestinations)
|
| Uses of ActiveMQDestination in org.apache.activemq.security |
|---|
| Methods in org.apache.activemq.security that return types with arguments of type ActiveMQDestination | |
|---|---|
ConcurrentHashMap<ActiveMQDestination,ActiveMQDestination> |
SecurityContext.getAuthorizedReadDests()
|
ConcurrentHashMap<ActiveMQDestination,ActiveMQDestination> |
SecurityContext.getAuthorizedReadDests()
|
ConcurrentHashMap<ActiveMQDestination,ActiveMQDestination> |
SecurityContext.getAuthorizedWriteDests()
|
ConcurrentHashMap<ActiveMQDestination,ActiveMQDestination> |
SecurityContext.getAuthorizedWriteDests()
|
| Methods in org.apache.activemq.security with parameters of type ActiveMQDestination | |
|---|---|
Destination |
AuthorizationBroker.addDestination(ConnectionContext context,
ActiveMQDestination destination)
|
protected Set<GroupPrincipal> |
LDAPAuthorizationMap.getACLs(ActiveMQDestination destination,
String roleBase,
String roleAttribute)
|
Set<GroupPrincipal> |
LDAPAuthorizationMap.getAdminACLs(ActiveMQDestination destination)
|
Set<?> |
AuthorizationMap.getAdminACLs(ActiveMQDestination destination)
Returns the set of all ACLs capable of administering the given destination |
Set<Object> |
DefaultAuthorizationMap.getAdminACLs(ActiveMQDestination destination)
|
Set<Object> |
SimpleAuthorizationMap.getAdminACLs(ActiveMQDestination destination)
|
protected Set<AuthorizationEntry> |
DefaultAuthorizationMap.getAllEntries(ActiveMQDestination destination)
|
AuthorizationEntry |
DefaultAuthorizationMap.getEntryFor(ActiveMQDestination destination)
|
Set<GroupPrincipal> |
LDAPAuthorizationMap.getReadACLs(ActiveMQDestination destination)
|
Set<?> |
AuthorizationMap.getReadACLs(ActiveMQDestination destination)
Returns the set of all ACLs capable of reading (consuming from) the given destination |
Set<Object> |
DefaultAuthorizationMap.getReadACLs(ActiveMQDestination destination)
|
Set<Object> |
SimpleAuthorizationMap.getReadACLs(ActiveMQDestination destination)
|
Set<GroupPrincipal> |
LDAPAuthorizationMap.getWriteACLs(ActiveMQDestination destination)
|
Set<?> |
AuthorizationMap.getWriteACLs(ActiveMQDestination destination)
Returns the set of all ACLs capable of writing to the given destination |
Set<Object> |
DefaultAuthorizationMap.getWriteACLs(ActiveMQDestination destination)
|
Set<Object> |
SimpleAuthorizationMap.getWriteACLs(ActiveMQDestination destination)
|
void |
AuthorizationBroker.removeDestination(ConnectionContext context,
ActiveMQDestination destination,
long timeout)
|
| Uses of ActiveMQDestination in org.apache.activemq.state |
|---|
| Methods in org.apache.activemq.state with parameters of type ActiveMQDestination | |
|---|---|
void |
ConnectionState.removeTempDestination(ActiveMQDestination destination)
|
| Uses of ActiveMQDestination in org.apache.activemq.store |
|---|
| Methods in org.apache.activemq.store that return ActiveMQDestination | |
|---|---|
ActiveMQDestination |
ProxyTopicMessageStore.getDestination()
|
ActiveMQDestination |
ProxyMessageStore.getDestination()
|
ActiveMQDestination |
MessageStore.getDestination()
The destination that the message store is holding messages for. |
| Methods in org.apache.activemq.store that return types with arguments of type ActiveMQDestination | |
|---|---|
Set<ActiveMQDestination> |
PersistenceAdapter.getDestinations()
Returns a set of all the ActiveMQDestination
objects that the persistence store is aware exist. |
| Uses of ActiveMQDestination in org.apache.activemq.store.amq |
|---|
| Fields in org.apache.activemq.store.amq declared as ActiveMQDestination | |
|---|---|
protected ActiveMQDestination |
AMQMessageStore.destination
|
| Methods in org.apache.activemq.store.amq that return ActiveMQDestination | |
|---|---|
ActiveMQDestination |
AMQMessageStore.getDestination()
|
| Methods in org.apache.activemq.store.amq that return types with arguments of type ActiveMQDestination | |
|---|---|
Set<ActiveMQDestination> |
AMQPersistenceAdapter.getDestinations()
|
| Constructors in org.apache.activemq.store.amq with parameters of type ActiveMQDestination | |
|---|---|
AMQMessageStore(AMQPersistenceAdapter adapter,
ReferenceStore referenceStore,
ActiveMQDestination destination)
|
|
AMQTxOperation(byte operationType,
ActiveMQDestination destination,
Object data,
Location location)
|
|
| Uses of ActiveMQDestination in org.apache.activemq.store.jdbc |
|---|
| Fields in org.apache.activemq.store.jdbc declared as ActiveMQDestination | |
|---|---|
protected ActiveMQDestination |
JDBCMessageStore.destination
|
| Methods in org.apache.activemq.store.jdbc that return ActiveMQDestination | |
|---|---|
ActiveMQDestination |
JDBCMessageStore.getDestination()
|
| Methods in org.apache.activemq.store.jdbc that return types with arguments of type ActiveMQDestination | |
|---|---|
Set<ActiveMQDestination> |
JDBCAdapter.doGetDestinations(TransactionContext c)
|
Set<ActiveMQDestination> |
JDBCPersistenceAdapter.getDestinations()
|
| Constructors in org.apache.activemq.store.jdbc with parameters of type ActiveMQDestination | |
|---|---|
JDBCMessageStore(JDBCPersistenceAdapter persistenceAdapter,
JDBCAdapter adapter,
WireFormat wireFormat,
ActiveMQDestination destination)
|
|
| Uses of ActiveMQDestination in org.apache.activemq.store.jdbc.adapter |
|---|
| Methods in org.apache.activemq.store.jdbc.adapter that return types with arguments of type ActiveMQDestination | |
|---|---|
Set<ActiveMQDestination> |
DefaultJDBCAdapter.doGetDestinations(TransactionContext c)
|
| Uses of ActiveMQDestination in org.apache.activemq.store.journal |
|---|
| Fields in org.apache.activemq.store.journal declared as ActiveMQDestination | |
|---|---|
protected ActiveMQDestination |
JournalMessageStore.destination
|
| Methods in org.apache.activemq.store.journal that return ActiveMQDestination | |
|---|---|
ActiveMQDestination |
JournalMessageStore.getDestination()
|
| Methods in org.apache.activemq.store.journal that return types with arguments of type ActiveMQDestination | |
|---|---|
Set<ActiveMQDestination> |
JournalPersistenceAdapter.getDestinations()
|
| Constructors in org.apache.activemq.store.journal with parameters of type ActiveMQDestination | |
|---|---|
JournalMessageStore(JournalPersistenceAdapter adapter,
MessageStore checkpointStore,
ActiveMQDestination destination)
|
|
| Uses of ActiveMQDestination in org.apache.activemq.store.kahadaptor |
|---|
| Fields in org.apache.activemq.store.kahadaptor declared as ActiveMQDestination | |
|---|---|
protected ActiveMQDestination |
KahaReferenceStore.destination
|
protected ActiveMQDestination |
KahaMessageStore.destination
|
| Fields in org.apache.activemq.store.kahadaptor with type parameters of type ActiveMQDestination | |
|---|---|
protected ConcurrentHashMap<ActiveMQDestination,MessageStore> |
KahaPersistenceAdapter.messageStores
|
| Methods in org.apache.activemq.store.kahadaptor that return ActiveMQDestination | |
|---|---|
ActiveMQDestination |
KahaReferenceStore.getDestination()
|
ActiveMQDestination |
KahaMessageStore.getDestination()
|
| Methods in org.apache.activemq.store.kahadaptor that return types with arguments of type ActiveMQDestination | |
|---|---|
Set<ActiveMQDestination> |
KahaPersistenceAdapter.getDestinations()
|
| Constructors in org.apache.activemq.store.kahadaptor with parameters of type ActiveMQDestination | |
|---|---|
KahaMessageStore(MapContainer<MessageId,Message> container,
ActiveMQDestination destination)
|
|
KahaReferenceStore(KahaReferenceStoreAdapter adapter,
MapContainer<MessageId,ReferenceRecord> container,
ActiveMQDestination destination)
|
|
KahaTopicMessageStore(Store store,
MapContainer<MessageId,Message> messageContainer,
ListContainer<TopicSubAck> ackContainer,
MapContainer<String,SubscriptionInfo> subsContainer,
ActiveMQDestination destination)
|
|
KahaTopicReferenceStore(Store store,
KahaReferenceStoreAdapter adapter,
MapContainer<MessageId,ReferenceRecord> messageContainer,
ListContainer<TopicSubAck> ackContainer,
MapContainer<String,SubscriptionInfo> subsContainer,
ActiveMQDestination destination)
|
|
| Uses of ActiveMQDestination in org.apache.activemq.store.memory |
|---|
| Fields in org.apache.activemq.store.memory declared as ActiveMQDestination | |
|---|---|
protected ActiveMQDestination |
MemoryMessageStore.destination
|
| Methods in org.apache.activemq.store.memory that return ActiveMQDestination | |
|---|---|
ActiveMQDestination |
MemoryMessageStore.getDestination()
|
| Methods in org.apache.activemq.store.memory that return types with arguments of type ActiveMQDestination | |
|---|---|
Set<ActiveMQDestination> |
MemoryPersistenceAdapter.getDestinations()
|
| Constructors in org.apache.activemq.store.memory with parameters of type ActiveMQDestination | |
|---|---|
MemoryMessageStore(ActiveMQDestination destination)
|
|
MemoryMessageStore(ActiveMQDestination destination,
Map<MessageId,Message> messageTable)
|
|
MemoryTopicMessageStore(ActiveMQDestination destination)
|
|
MemoryTopicMessageStore(ActiveMQDestination destination,
Map<MessageId,Message> messageTable,
Map<SubscriptionKey,SubscriptionInfo> subscriberDatabase)
|
|
| Uses of ActiveMQDestination in org.apache.activemq.transport.stomp |
|---|
| Methods in org.apache.activemq.transport.stomp that return ActiveMQDestination | |
|---|---|
ActiveMQDestination |
LegacyFrameTranslator.convertDestination(ProtocolConverter converter,
String name)
|
ActiveMQDestination |
FrameTranslator.convertDestination(ProtocolConverter converter,
String name)
|
ActiveMQDestination |
ProtocolConverter.createTempQueue(String name)
|
ActiveMQDestination |
ProtocolConverter.createTempTopic(String name)
|
ActiveMQDestination |
StompSubscription.getDestination()
|
| Methods in org.apache.activemq.transport.stomp with parameters of type ActiveMQDestination | |
|---|---|
String |
ProtocolConverter.getCreatedTempDestinationName(ActiveMQDestination destination)
|
void |
StompSubscription.setDestination(ActiveMQDestination destination)
|
| Uses of ActiveMQDestination in org.apache.activemq.util |
|---|
| Methods in org.apache.activemq.util with parameters of type ActiveMQDestination | |
|---|---|
static void |
BrokerSupport.resend(ConnectionContext context,
Message originalMessage,
ActiveMQDestination deadLetterDestination)
|
|
||||||||||
| PREV NEXT | FRAMES NO FRAMES | |||||||||