Package | Description |
---|---|
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.region.policy | |
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.state | |
org.apache.activemq.util |
Modifier and Type | Method and Description |
---|---|
protected ActiveMQDestination |
ActiveMQMessageConsumer.getDestination() |
static ActiveMQDestination |
ActiveMQMessageTransformation.transformDestination(Destination destination)
Creates a an available JMS message from another provider.
|
Modifier and Type | Method and Description |
---|---|
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,
AsyncCallback onComplete)
Sends the message for dispatch by the broker.
|
Constructor and Description |
---|
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) |
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) |
Modifier and Type | Method and Description |
---|---|
ActiveMQDestination |
DestinationEvent.getDestination() |
Constructor and Description |
---|
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) |
Modifier and Type | Method and Description |
---|---|
RedeliveryPolicy |
RedeliveryPolicyMap.getEntryFor(ActiveMQDestination destination) |
Modifier and Type | Class and Description |
---|---|
class |
ActiveMQQueue |
class |
ActiveMQTempDestination |
class |
ActiveMQTempQueue |
class |
ActiveMQTempTopic |
class |
ActiveMQTopic |
Modifier and Type | Field and Description |
---|---|
protected ActiveMQDestination[] |
ActiveMQDestination.compositeDestinations |
protected ActiveMQDestination |
ProducerInfo.destination |
protected ActiveMQDestination |
Message.destination |
protected ActiveMQDestination |
MessageDispatchNotification.destination |
protected ActiveMQDestination |
DestinationInfo.destination |
protected ActiveMQDestination |
SubscriptionInfo.destination |
protected ActiveMQDestination |
ConsumerInfo.destination |
protected ActiveMQDestination |
MessagePull.destination |
protected ActiveMQDestination |
MessageAck.destination |
protected ActiveMQDestination |
ConsumerControl.destination |
protected ActiveMQDestination |
MessageDispatch.destination |
protected ActiveMQDestination |
Message.originalDestination |
protected ActiveMQDestination |
Message.replyTo |
protected ActiveMQDestination |
SubscriptionInfo.subscribedDestination |
Modifier and Type | Method and Description |
---|---|
ActiveMQDestination |
ActiveMQDestination.createDestination(String name) |
static ActiveMQDestination |
ActiveMQDestination.createDestination(String name,
byte defaultType) |
ActiveMQDestination[] |
ActiveMQDestination.getCompositeDestinations() |
ActiveMQDestination |
ProducerInfo.getDestination() |
ActiveMQDestination |
Message.getDestination() |
ActiveMQDestination |
MessageDispatchNotification.getDestination() |
ActiveMQDestination |
DestinationInfo.getDestination() |
ActiveMQDestination |
SubscriptionInfo.getDestination()
This is the a resolved destination that the subscription is receiving
messages from.
|
ActiveMQDestination |
JournalQueueAck.getDestination() |
ActiveMQDestination |
ConsumerInfo.getDestination()
The destination that the consumer is interested in receiving messages
from.
|
ActiveMQDestination |
MessagePull.getDestination() |
ActiveMQDestination |
MessageAck.getDestination() |
ActiveMQDestination |
JournalTopicAck.getDestination() |
ActiveMQDestination |
ConsumerControl.getDestination() |
ActiveMQDestination |
MessageDispatch.getDestination() |
ActiveMQDestination |
Message.getOriginalDestination() |
ActiveMQDestination |
Message.getReplyTo() |
ActiveMQDestination |
SubscriptionInfo.getSubscribedDestination()
The destination the client originally subscribed to..
|
ActiveMQDestination |
DefaultUnresolvedDestinationTransformer.transform(Destination dest) |
ActiveMQDestination |
UnresolvedDestinationTransformer.transform(Destination dest) |
static ActiveMQDestination |
ActiveMQDestination.transform(Destination dest) |
ActiveMQDestination |
DefaultUnresolvedDestinationTransformer.transform(String dest) |
ActiveMQDestination |
UnresolvedDestinationTransformer.transform(String dest) |
Constructor and Description |
---|
ActiveMQDestination(ActiveMQDestination[] composites) |
DestinationInfo(ConnectionId connectionId,
byte operationType,
ActiveMQDestination destination) |
Modifier and Type | Class and Description |
---|---|
class |
AnyDestination |
Modifier and Type | Field and Description |
---|---|
protected ActiveMQDestination |
MessageEvaluationContext.destination |
protected ActiveMQDestination |
DestinationMapEntry.destination |
Modifier and Type | Method and Description |
---|---|
ActiveMQDestination |
MessageEvaluationContext.getDestination() |
ActiveMQDestination |
DestinationMapEntry.getDestination() |
Modifier and Type | Method and Description |
---|---|
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) |
protected Set |
DestinationMap.findWildcardMatches(ActiveMQDestination key,
boolean deep) |
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 |
PrefixDestinationFilter.matches(ActiveMQDestination destination) |
boolean |
SimpleDestinationFilter.matches(ActiveMQDestination destination) |
boolean |
CompositeDestinationFilter.matches(ActiveMQDestination destination) |
boolean |
WildcardDestinationFilter.matches(ActiveMQDestination destination) |
abstract boolean |
DestinationFilter.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 |
MessageEvaluationContext.setDestination(ActiveMQDestination destination) |
void |
DestinationMapEntry.setDestination(ActiveMQDestination destination) |
Constructor and Description |
---|
AnyDestination(ActiveMQDestination[] destinations) |
CompositeDestinationFilter(ActiveMQDestination destination) |
SimpleDestinationFilter(ActiveMQDestination destination) |
Modifier and Type | Method and Description |
---|---|
void |
ConnectionState.removeTempDestination(ActiveMQDestination destination) |
Modifier and Type | Method and Description |
---|---|
static List<ActiveMQDestination> |
StringToListOfActiveMQDestinationConverter.convertToActiveMQDestination(Object value) |
Copyright © 2005–2016 FuseSource, Corp.. All rights reserved.