|
||||||||||
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.ra | JCA managed connections and resource adapters for working with ActiveMQ |
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.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.store.rapid | |
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.transport.xmpp | |
org.apache.activemq.util | Some utility classes |
org.apache.activemq.web | Web Connectors so that messages can be sent via HTTP POST or read via HTTP POST or GET as well as support for web streaming to we browser or JavaScript clients. |
org.apache.activemq.web.controller |
Uses of ActiveMQDestination in org.apache.activemq |
---|
Methods in org.apache.activemq that return ActiveMQDestination | |
---|---|
protected ActiveMQDestination |
ActiveMQMessageConsumer.getDestination()
|
static ActiveMQDestination |
ActiveMQMessageTransformation.transformDestination(javax.jms.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,
javax.jms.Message message,
int deliveryMode,
int priority,
long timeToLive)
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,
java.lang.String selector,
boolean noLocal,
java.lang.String name,
int prefetch)
|
|
ActiveMQMessageConsumer(ActiveMQSession session,
ConsumerId consumerId,
ActiveMQDestination dest,
java.lang.String name,
java.lang.String selector,
int prefetch,
int maximumPendingMessageCount,
boolean noLocal,
boolean browser,
boolean dispatchAsync)
Create a MessageConsumer |
|
ActiveMQMessageProducer(ActiveMQSession session,
ProducerId producerId,
ActiveMQDestination destination)
|
|
ActiveMQOutputStream(ActiveMQConnection connection,
ProducerId producerId,
ActiveMQDestination destination,
java.util.Map properties,
int deliveryMode,
int priority,
long timeToLive)
|
|
ActiveMQQueueBrowser(ActiveMQSession session,
ConsumerId consumerId,
ActiveMQDestination destination,
java.lang.String selector,
boolean dispatchAsync)
Constructor for an ActiveMQQueueBrowser - used internally |
|
ActiveMQQueueReceiver(ActiveMQSession theSession,
ConsumerId consumerId,
ActiveMQDestination destination,
java.lang.String selector,
int prefetch,
int maximumPendingMessageCount,
boolean asyncDispatch)
|
|
ActiveMQQueueSender(ActiveMQSession session,
ActiveMQDestination destination)
|
|
ActiveMQTopicPublisher(ActiveMQSession session,
ActiveMQDestination destination)
|
|
ActiveMQTopicSubscriber(ActiveMQSession theSession,
ConsumerId consumerId,
ActiveMQDestination dest,
java.lang.String name,
java.lang.String selector,
int prefetch,
int maximumPendingMessageCount,
boolean noLocalValue,
boolean browserValue,
boolean asyncDispatch)
|
Uses of ActiveMQDestination in org.apache.activemq.advisory |
---|
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[] |
EmptyBroker.getDestinations()
|
ActiveMQDestination[] |
ErrorBroker.getDestinations()
|
ActiveMQDestination[] |
MutableBrokerFilter.getDestinations()
|
ActiveMQDestination[] |
BrokerFilter.getDestinations()
|
ActiveMQDestination[] |
BrokerService.getDestinations()
|
ActiveMQDestination[] |
Broker.getDestinations()
|
Methods in org.apache.activemq.broker with parameters of type ActiveMQDestination | |
---|---|
Destination |
EmptyBroker.addDestination(ConnectionContext context,
ActiveMQDestination destination)
|
Destination |
ErrorBroker.addDestination(ConnectionContext context,
ActiveMQDestination destination)
|
Destination |
MutableBrokerFilter.addDestination(ConnectionContext context,
ActiveMQDestination destination)
|
Destination |
BrokerFilter.addDestination(ConnectionContext context,
ActiveMQDestination destination)
|
Destination |
BrokerBroadcaster.addDestination(ConnectionContext context,
ActiveMQDestination destination)
|
java.util.Set |
EmptyBroker.getDestinations(ActiveMQDestination destination)
|
java.util.Set |
ErrorBroker.getDestinations(ActiveMQDestination destination)
|
java.util.Set |
MutableBrokerFilter.getDestinations(ActiveMQDestination destination)
|
java.util.Set |
BrokerFilter.getDestinations(ActiveMQDestination destination)
|
void |
EmptyBroker.removeDestination(ConnectionContext context,
ActiveMQDestination destination,
long timeout)
|
void |
ErrorBroker.removeDestination(ConnectionContext context,
ActiveMQDestination destination,
long timeout)
|
void |
MutableBrokerFilter.removeDestination(ConnectionContext context,
ActiveMQDestination destination,
long timeout)
|
void |
BrokerFilter.removeDestination(ConnectionContext context,
ActiveMQDestination destination,
long timeout)
|
void |
BrokerBroadcaster.removeDestination(ConnectionContext context,
ActiveMQDestination destination,
long timeout)
|
void |
BrokerService.setDestinations(ActiveMQDestination[] destinations)
Sets the destinations which should be loaded/created on startup |
Uses of ActiveMQDestination in org.apache.activemq.broker.jmx |
---|
Methods in org.apache.activemq.broker.jmx with parameters of type ActiveMQDestination | |
---|---|
protected Destination |
ManagedTempQueueRegion.createDestination(ConnectionContext context,
ActiveMQDestination destination)
|
protected Destination |
ManagedTempTopicRegion.createDestination(ConnectionContext context,
ActiveMQDestination destination)
|
protected Destination |
ManagedQueueRegion.createDestination(ConnectionContext context,
ActiveMQDestination destination)
|
protected Destination |
ManagedTopicRegion.createDestination(ConnectionContext context,
ActiveMQDestination destination)
|
protected javax.management.ObjectName |
ManagedRegionBroker.createObjectName(ActiveMQDestination destName)
|
void |
ManagedRegionBroker.register(ActiveMQDestination destName,
Destination destination)
|
protected void |
ManagedRegionBroker.registerDestination(javax.management.ObjectName key,
ActiveMQDestination dest,
DestinationView view)
|
void |
ManagedTempQueueRegion.removeDestination(ConnectionContext context,
ActiveMQDestination destination,
long timeout)
|
void |
ManagedTempTopicRegion.removeDestination(ConnectionContext context,
ActiveMQDestination destination,
long timeout)
|
void |
ManagedQueueRegion.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 |
Topic.destination
|
protected ActiveMQDestination |
Queue.destination
|
protected ActiveMQDestination |
TopicSubscription.dlqDestination
|
Methods in org.apache.activemq.broker.region that return ActiveMQDestination | |
---|---|
ActiveMQDestination |
DestinationFilter.getActiveMQDestination()
|
ActiveMQDestination |
Topic.getActiveMQDestination()
|
ActiveMQDestination |
Destination.getActiveMQDestination()
|
ActiveMQDestination |
Queue.getActiveMQDestination()
|
ActiveMQDestination[] |
RegionBroker.getDestinations()
|
Methods in org.apache.activemq.broker.region with parameters of type ActiveMQDestination | |
---|---|
Destination |
Region.addDestination(ConnectionContext context,
ActiveMQDestination destination)
Used to create a destination. |
Destination |
RegionBroker.addDestination(ConnectionContext context,
ActiveMQDestination destination)
|
Destination |
AbstractRegion.addDestination(ConnectionContext context,
ActiveMQDestination destination)
|
protected void |
DestinationFactoryImpl.configureQueue(Queue queue,
ActiveMQDestination destination)
|
protected void |
TopicRegion.configureTopic(Topic topic,
ActiveMQDestination destination)
|
protected void |
DestinationFactoryImpl.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,
java.lang.String selector,
ActiveMQDestination dest)
Copies the messages matching the given selector |
int |
Queue.copyMatchingMessagesTo(ConnectionContext context,
java.lang.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,
java.lang.String messageId,
ActiveMQDestination dest)
Copies the message matching the given messageId |
protected Destination |
TopicRegion.createDestination(ConnectionContext context,
ActiveMQDestination destination)
|
protected Destination |
TempQueueRegion.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 javax.jms.JMSException |
RegionBroker.createUnknownDestinationTypeException(ActiveMQDestination destination)
|
java.util.Set |
Region.getDestinations(ActiveMQDestination destination)
Provide an exact or wildcard lookup of destinations in the region |
java.util.Set |
RegionBroker.getDestinations(ActiveMQDestination destination)
|
java.util.Set |
AbstractRegion.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,
java.lang.String selector,
ActiveMQDestination dest)
Moves the messages matching the given selector |
int |
Queue.moveMatchingMessagesTo(ConnectionContext context,
java.lang.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,
java.lang.String messageId,
ActiveMQDestination dest)
Moves the message matching the given messageId |
void |
Region.removeDestination(ConnectionContext context,
ActiveMQDestination destination,
long timeout)
Used to destroy a destination. |
void |
RegionBroker.removeDestination(ConnectionContext context,
ActiveMQDestination destination,
long timeout)
|
void |
TempQueueRegion.removeDestination(ConnectionContext context,
ActiveMQDestination destination,
long timeout)
|
void |
AbstractRegion.removeDestination(ConnectionContext context,
ActiveMQDestination destination,
long timeout)
|
void |
TempTopicRegion.removeDestination(ConnectionContext context,
ActiveMQDestination destination,
long timeout)
|
protected void |
DestinationFilter.send(ConnectionContext 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 | |
---|---|
Queue(ActiveMQDestination destination,
UsageManager memoryManager,
MessageStore store,
DestinationStatistics parentStats,
TaskRunnerFactory taskFactory)
|
|
Topic(ActiveMQDestination destination,
TopicMessageStore store,
UsageManager memoryManager,
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,
java.lang.String prefix,
boolean useQueue)
|
ActiveMQDestination |
SharedDeadLetterStrategy.getDeadLetterQueue()
|
ActiveMQDestination |
IndividualDeadLetterStrategy.getDeadLetterQueueFor(ActiveMQDestination originalDestination)
|
ActiveMQDestination |
DeadLetterStrategy.getDeadLetterQueueFor(ActiveMQDestination originalDestination)
Returns the dead letter queue for the given destination. |
ActiveMQDestination |
SharedDeadLetterStrategy.getDeadLetterQueueFor(ActiveMQDestination originalDestination)
|
Methods in org.apache.activemq.broker.region.policy with parameters of type ActiveMQDestination | |
---|---|
Message[] |
NoSubscriptionRecoveryPolicy.browse(ActiveMQDestination dest)
|
Message[] |
LastImageSubscriptionRecoveryPolicy.browse(ActiveMQDestination destination)
|
Message[] |
FixedSizedSubscriptionRecoveryPolicy.browse(ActiveMQDestination destination)
|
Message[] |
TimedSubscriptionRecoveryPolicy.browse(ActiveMQDestination destination)
|
Message[] |
QueryBasedSubscriptionRecoveryPolicy.browse(ActiveMQDestination dest)
|
Message[] |
SubscriptionRecoveryPolicy.browse(ActiveMQDestination dest)
|
Message[] |
FixedCountSubscriptionRecoveryPolicy.browse(ActiveMQDestination destination)
|
protected ActiveMQDestination |
IndividualDeadLetterStrategy.createDestination(ActiveMQDestination originalDestination,
java.lang.String prefix,
boolean useQueue)
|
void |
MessageQuery.execute(ActiveMQDestination destination,
javax.jms.MessageListener listener)
Executes the query for messages; each message is passed into the listener |
ActiveMQDestination |
IndividualDeadLetterStrategy.getDeadLetterQueueFor(ActiveMQDestination originalDestination)
|
ActiveMQDestination |
DeadLetterStrategy.getDeadLetterQueueFor(ActiveMQDestination originalDestination)
Returns the dead letter queue for the given destination. |
ActiveMQDestination |
SharedDeadLetterStrategy.getDeadLetterQueueFor(ActiveMQDestination originalDestination)
|
PolicyEntry |
PolicyMap.getEntryFor(ActiveMQDestination destination)
|
void |
SharedDeadLetterStrategy.setDeadLetterQueue(ActiveMQDestination deadLetterQueue)
|
Uses of ActiveMQDestination in org.apache.activemq.broker.region.virtual |
---|
Methods in org.apache.activemq.broker.region.virtual that return ActiveMQDestination | |
---|---|
protected ActiveMQDestination |
VirtualTopic.getQueueConsumersWildcard(ActiveMQDestination original)
|
protected ActiveMQDestination |
VirtualTopicInterceptor.getQueueConsumersWildcard(ActiveMQDestination original)
|
ActiveMQDestination |
VirtualTopic.getVirtualDestination()
|
ActiveMQDestination |
CompositeQueue.getVirtualDestination()
|
ActiveMQDestination |
VirtualDestination.getVirtualDestination()
Returns the virtual destination |
ActiveMQDestination |
CompositeTopic.getVirtualDestination()
|
Methods in org.apache.activemq.broker.region.virtual with parameters of type ActiveMQDestination | |
---|---|
protected ActiveMQDestination |
VirtualTopic.getQueueConsumersWildcard(ActiveMQDestination original)
|
protected ActiveMQDestination |
VirtualTopicInterceptor.getQueueConsumersWildcard(ActiveMQDestination original)
|
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 |
ProducerInfo.destination
|
protected ActiveMQDestination |
ConsumerInfo.destination
|
protected ActiveMQDestination |
SubscriptionInfo.destination
|
protected ActiveMQDestination |
MessageAck.destination
|
protected ActiveMQDestination |
MessageDispatch.destination
|
protected ActiveMQDestination |
MessagePull.destination
|
protected ActiveMQDestination |
DestinationInfo.destination
|
protected ActiveMQDestination |
Message.destination
|
protected ActiveMQDestination |
MessageDispatchNotification.destination
|
protected ActiveMQDestination |
Message.originalDestination
|
protected ActiveMQDestination |
Message.replyTo
|
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 |
ProducerInfo.setDestination(ActiveMQDestination destination)
|
void |
ConsumerInfo.setDestination(ActiveMQDestination destination)
|
void |
SubscriptionInfo.setDestination(ActiveMQDestination destination)
|
void |
JournalTopicAck.setDestination(ActiveMQDestination destination)
|
void |
JournalQueueAck.setDestination(ActiveMQDestination destination)
|
void |
MessageAck.setDestination(ActiveMQDestination destination)
|
void |
MessageDispatch.setDestination(ActiveMQDestination destination)
|
void |
MessagePull.setDestination(ActiveMQDestination destination)
|
void |
DestinationInfo.setDestination(ActiveMQDestination destination)
|
void |
Message.setDestination(ActiveMQDestination destination)
|
void |
MessageDispatchNotification.setDestination(ActiveMQDestination destination)
|
void |
Message.setOriginalDestination(ActiveMQDestination destination)
|
void |
Message.setReplyTo(ActiveMQDestination replyTo)
|
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 |
---|
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 | |
---|---|
java.lang.Object |
DestinationMap.chooseValue(ActiveMQDestination destination)
Returns the value which matches the given destination or null if there is no matching value. |
protected java.util.Set |
DestinationMap.findWildcardMatches(ActiveMQDestination key)
|
java.util.Set |
DestinationMap.get(ActiveMQDestination key)
Looks up the value(s) matching the given Destination key. |
static java.lang.String[] |
DestinationPath.getDestinationPaths(ActiveMQDestination destination)
|
protected DestinationMapNode |
DestinationMap.getRootNode(ActiveMQDestination key)
Returns the root node for the given destination type |
abstract boolean |
DestinationFilter.matches(ActiveMQDestination destination)
|
boolean |
CompositeDestinationFilter.matches(ActiveMQDestination destination)
|
boolean |
SimpleDestinationFilter.matches(ActiveMQDestination destination)
|
boolean |
PrefixDestinationFilter.matches(ActiveMQDestination destination)
|
boolean |
WildcardDestinationFilter.matches(ActiveMQDestination destination)
|
static DestinationFilter |
DestinationFilter.parseFilter(ActiveMQDestination destination)
|
void |
DestinationMap.put(ActiveMQDestination key,
java.lang.Object value)
|
void |
DestinationMap.remove(ActiveMQDestination key,
java.lang.Object value)
Removes the value from the associated destination |
java.util.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[] |
DestinationBasedMessageList.browse(ActiveMQDestination destination)
|
Message[] |
MessageList.browse(ActiveMQDestination destination)
|
Message[] |
SimpleMessageList.browse(ActiveMQDestination destination)
|
protected java.util.List |
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 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 java.lang.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)
|
Uses of ActiveMQDestination in org.apache.activemq.ra |
---|
Methods in org.apache.activemq.ra that return ActiveMQDestination | |
---|---|
ActiveMQDestination |
ActiveMQActivationSpec.createDestination()
|
Methods in org.apache.activemq.ra with parameters of type ActiveMQDestination | |
---|---|
void |
ActiveMQActivationSpec.setActiveMQDestination(ActiveMQDestination destination)
A helper method mostly for use in Dependency Injection containers which allows you to customize the destination and destinationType properties from a single ActiveMQDestination POJO |
Uses of ActiveMQDestination in org.apache.activemq.security |
---|
Methods in org.apache.activemq.security with parameters of type ActiveMQDestination | |
---|---|
Destination |
AuthorizationBroker.addDestination(ConnectionContext context,
ActiveMQDestination destination)
|
protected java.util.Set |
LDAPAuthorizationMap.getACLs(ActiveMQDestination destination,
java.lang.String roleBase,
java.lang.String roleAttribute)
|
java.util.Set |
AuthorizationMap.getAdminACLs(ActiveMQDestination destination)
Returns the set of all ACLs capable of administering the given destination |
java.util.Set |
DefaultAuthorizationMap.getAdminACLs(ActiveMQDestination destination)
|
java.util.Set |
SimpleAuthorizationMap.getAdminACLs(ActiveMQDestination destination)
|
java.util.Set |
LDAPAuthorizationMap.getAdminACLs(ActiveMQDestination destination)
|
protected java.util.Set |
DefaultAuthorizationMap.getAllEntries(ActiveMQDestination destination)
|
AuthorizationEntry |
DefaultAuthorizationMap.getEntryFor(ActiveMQDestination destination)
|
java.util.Set |
AuthorizationMap.getReadACLs(ActiveMQDestination destination)
Returns the set of all ACLs capable of reading (consuming from) the given destination |
java.util.Set |
DefaultAuthorizationMap.getReadACLs(ActiveMQDestination destination)
|
java.util.Set |
SimpleAuthorizationMap.getReadACLs(ActiveMQDestination destination)
|
java.util.Set |
LDAPAuthorizationMap.getReadACLs(ActiveMQDestination destination)
|
java.util.Set |
AuthorizationMap.getWriteACLs(ActiveMQDestination destination)
Returns the set of all ACLs capable of writing to the given destination |
java.util.Set |
DefaultAuthorizationMap.getWriteACLs(ActiveMQDestination destination)
|
java.util.Set |
SimpleAuthorizationMap.getWriteACLs(ActiveMQDestination destination)
|
java.util.Set |
LDAPAuthorizationMap.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. |
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 with parameters of type ActiveMQDestination | |
---|---|
void |
JDBCAdapter.doAddMessage(TransactionContext c,
MessageId messageID,
ActiveMQDestination destination,
byte[] data,
long expiration)
|
void |
JDBCAdapter.doAddMessageReference(TransactionContext c,
MessageId messageId,
ActiveMQDestination destination,
long expirationTime,
java.lang.String messageRef)
|
void |
JDBCAdapter.doDeleteSubscription(TransactionContext c,
ActiveMQDestination destinationName,
java.lang.String clientId,
java.lang.String subscriptionName)
|
SubscriptionInfo[] |
JDBCAdapter.doGetAllSubscriptions(TransactionContext c,
ActiveMQDestination destination)
|
int |
JDBCAdapter.doGetDurableSubscriberMessageCount(TransactionContext c,
ActiveMQDestination destination,
java.lang.String clientId,
java.lang.String subscriptionName)
|
void |
JDBCAdapter.doGetNextDurableSubscriberMessageIdStatement(TransactionContext c,
ActiveMQDestination destination,
java.lang.String clientId,
java.lang.String subscriberName,
long id,
JDBCMessageRecoveryListener listener)
|
void |
JDBCAdapter.doGetPrevDurableSubscriberMessageIdStatement(TransactionContext c,
ActiveMQDestination destination,
java.lang.String clientId,
java.lang.String subscriberName,
long id,
JDBCMessageRecoveryListener listener)
|
SubscriptionInfo |
JDBCAdapter.doGetSubscriberEntry(TransactionContext c,
ActiveMQDestination destination,
java.lang.String clientId,
java.lang.String subscriptionName)
|
void |
JDBCAdapter.doRecover(TransactionContext c,
ActiveMQDestination destination,
JDBCMessageRecoveryListener listener)
|
void |
JDBCAdapter.doRecoverNextMessages(TransactionContext c,
ActiveMQDestination destination,
java.lang.String clientId,
java.lang.String subscriptionName,
long seq,
int maxReturned,
JDBCMessageRecoveryListener listener)
|
void |
JDBCAdapter.doRecoverSubscription(TransactionContext c,
ActiveMQDestination destination,
java.lang.String clientId,
java.lang.String subscriptionName,
JDBCMessageRecoveryListener listener)
|
void |
JDBCAdapter.doRemoveAllMessages(TransactionContext c,
ActiveMQDestination destinationName)
|
void |
JDBCAdapter.doSetLastAck(TransactionContext c,
ActiveMQDestination destination,
java.lang.String clientId,
java.lang.String subscriptionName,
long seq)
|
void |
JDBCAdapter.doSetSubscriberEntry(TransactionContext c,
ActiveMQDestination destination,
java.lang.String clientId,
java.lang.String subscriptionName,
java.lang.String selector,
boolean retroactive)
|
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 with parameters of type ActiveMQDestination | |
---|---|
void |
DefaultJDBCAdapter.doAddMessage(TransactionContext c,
MessageId messageID,
ActiveMQDestination destination,
byte[] data,
long expiration)
|
void |
DefaultJDBCAdapter.doAddMessageReference(TransactionContext c,
MessageId messageID,
ActiveMQDestination destination,
long expirationTime,
java.lang.String messageRef)
|
void |
DefaultJDBCAdapter.doDeleteSubscription(TransactionContext c,
ActiveMQDestination destination,
java.lang.String clientId,
java.lang.String subscriptionName)
|
SubscriptionInfo[] |
DefaultJDBCAdapter.doGetAllSubscriptions(TransactionContext c,
ActiveMQDestination destination)
|
int |
DefaultJDBCAdapter.doGetDurableSubscriberMessageCount(TransactionContext c,
ActiveMQDestination destination,
java.lang.String clientId,
java.lang.String subscriptionName)
|
void |
DefaultJDBCAdapter.doGetNextDurableSubscriberMessageIdStatement(TransactionContext c,
ActiveMQDestination destination,
java.lang.String clientId,
java.lang.String subscriberName,
long id,
JDBCMessageRecoveryListener listener)
|
byte[] |
DefaultJDBCAdapter.doGetNextDurableSubscriberMessageStatement(TransactionContext c,
ActiveMQDestination destination,
java.lang.String clientId,
java.lang.String subscriberName)
|
void |
DefaultJDBCAdapter.doGetPrevDurableSubscriberMessageIdStatement(TransactionContext c,
ActiveMQDestination destination,
java.lang.String clientId,
java.lang.String subscriberName,
long id,
JDBCMessageRecoveryListener listener)
|
SubscriptionInfo |
DefaultJDBCAdapter.doGetSubscriberEntry(TransactionContext c,
ActiveMQDestination destination,
java.lang.String clientId,
java.lang.String subscriptionName)
|
void |
DefaultJDBCAdapter.doRecover(TransactionContext c,
ActiveMQDestination destination,
JDBCMessageRecoveryListener listener)
|
void |
DefaultJDBCAdapter.doRecoverNextMessages(TransactionContext c,
ActiveMQDestination destination,
java.lang.String clientId,
java.lang.String subscriptionName,
long seq,
int maxReturned,
JDBCMessageRecoveryListener listener)
|
void |
DefaultJDBCAdapter.doRecoverSubscription(TransactionContext c,
ActiveMQDestination destination,
java.lang.String clientId,
java.lang.String subscriptionName,
JDBCMessageRecoveryListener listener)
|
void |
DefaultJDBCAdapter.doRemoveAllMessages(TransactionContext c,
ActiveMQDestination destinationName)
|
void |
DefaultJDBCAdapter.doSetLastAck(TransactionContext c,
ActiveMQDestination destination,
java.lang.String clientId,
java.lang.String subscriptionName,
long seq)
|
void |
DefaultJDBCAdapter.doSetSubscriberEntry(TransactionContext c,
ActiveMQDestination destination,
java.lang.String clientId,
java.lang.String subscriptionName,
java.lang.String selector,
boolean retroactive)
|
Uses of ActiveMQDestination in org.apache.activemq.store.journal |
---|
Fields in org.apache.activemq.store.journal declared as ActiveMQDestination | |
---|---|
protected ActiveMQDestination |
JournalMessageStore.destination
|
protected ActiveMQDestination |
QuickJournalMessageStore.destination
|
Methods in org.apache.activemq.store.journal that return ActiveMQDestination | |
---|---|
ActiveMQDestination |
JournalMessageStore.getDestination()
|
ActiveMQDestination |
QuickJournalMessageStore.getDestination()
|
Constructors in org.apache.activemq.store.journal with parameters of type ActiveMQDestination | |
---|---|
JournalMessageStore(JournalPersistenceAdapter adapter,
MessageStore checkpointStore,
ActiveMQDestination destination)
|
|
QuickJournalMessageStore(QuickJournalPersistenceAdapter 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 |
KahaMessageStore.destination
|
Methods in org.apache.activemq.store.kahadaptor that return ActiveMQDestination | |
---|---|
ActiveMQDestination |
KahaMessageStore.getDestination()
|
ActiveMQDestination |
KahaTopicMessageStore.getDestination()
|
Constructors in org.apache.activemq.store.kahadaptor with parameters of type ActiveMQDestination | |
---|---|
KahaMessageStore(MapContainer container,
ActiveMQDestination destination)
|
|
KahaTopicMessageStore(Store store,
ListContainer messageContainer,
ListContainer ackContainer,
MapContainer 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()
|
Constructors in org.apache.activemq.store.memory with parameters of type ActiveMQDestination | |
---|---|
MemoryMessageStore(ActiveMQDestination destination)
|
|
MemoryMessageStore(ActiveMQDestination destination,
java.util.Map messageTable)
|
|
MemoryTopicMessageStore(ActiveMQDestination destination)
|
|
MemoryTopicMessageStore(ActiveMQDestination destination,
java.util.Map messageTable,
java.util.Map subscriberDatabase,
java.util.Map ackDatabase)
|
Uses of ActiveMQDestination in org.apache.activemq.store.rapid |
---|
Fields in org.apache.activemq.store.rapid declared as ActiveMQDestination | |
---|---|
protected ActiveMQDestination |
RapidMessageStore.destination
|
Methods in org.apache.activemq.store.rapid that return ActiveMQDestination | |
---|---|
ActiveMQDestination |
RapidMessageStore.getDestination()
|
Constructors in org.apache.activemq.store.rapid with parameters of type ActiveMQDestination | |
---|---|
RapidMessageStore(RapidPersistenceAdapter adapter,
ActiveMQDestination destination,
MapContainer container)
|
Uses of ActiveMQDestination in org.apache.activemq.transport.stomp |
---|
Methods in org.apache.activemq.transport.stomp that return ActiveMQDestination | |
---|---|
ActiveMQDestination |
LegacyFrameTranslator.convertDestination(java.lang.String name)
|
ActiveMQDestination |
FrameTranslator.convertDestination(java.lang.String name)
|
ActiveMQDestination |
StompSubscription.getDestination()
|
Methods in org.apache.activemq.transport.stomp with parameters of type ActiveMQDestination | |
---|---|
void |
StompSubscription.setDestination(ActiveMQDestination destination)
|
Uses of ActiveMQDestination in org.apache.activemq.transport.xmpp |
---|
Methods in org.apache.activemq.transport.xmpp that return ActiveMQDestination | |
---|---|
protected ActiveMQDestination |
ProtocolConverter.createActiveMQDestination(java.lang.String jabberDestination)
Converts the Jabber destination name into a destination in ActiveMQ |
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 message,
ActiveMQDestination deadLetterDestination)
|
Uses of ActiveMQDestination in org.apache.activemq.web |
---|
Methods in org.apache.activemq.web that return ActiveMQDestination | |
---|---|
protected ActiveMQDestination |
DestinationFacade.createDestination()
|
Uses of ActiveMQDestination in org.apache.activemq.web.controller |
---|
Methods in org.apache.activemq.web.controller with parameters of type ActiveMQDestination | |
---|---|
protected void |
SendMessage.sendMessages(javax.servlet.http.HttpServletRequest request,
WebClient client,
ActiveMQDestination dest)
|
|
||||||||||
PREV NEXT | FRAMES NO FRAMES |