Package | Description |
---|---|
io.fabric8.gateway.handlers.detecting.protocol.openwire.command |
Command objects used via the Command Pattern to communicate among nodes
|
io.fabric8.gateway.handlers.detecting.protocol.openwire.support.advisory |
Support for JMS Advisory messages as well as some helper listeners to listen to the clients, producers and consumers available.
|
Modifier and Type | Class and Description |
---|---|
class |
ActiveMQQueue |
class |
ActiveMQTempDestination |
class |
ActiveMQTempQueue |
class |
ActiveMQTempTopic |
class |
ActiveMQTopic |
Modifier and Type | Field and Description |
---|---|
protected ActiveMQDestination |
ConsumerInfo.destination |
protected ActiveMQDestination |
ConsumerControl.destination |
protected ActiveMQDestination |
MessagePull.destination |
protected ActiveMQDestination |
DestinationInfo.destination |
protected ActiveMQDestination |
Message.destination |
protected ActiveMQDestination |
SubscriptionInfo.destination |
protected ActiveMQDestination |
MessageDispatchNotification.destination |
protected ActiveMQDestination |
MessageAck.destination |
protected ActiveMQDestination |
ProducerInfo.destination |
protected ActiveMQDestination |
MessageDispatch.destination |
protected ActiveMQDestination |
Message.originalDestination |
protected ActiveMQDestination |
Message.replyTo |
protected ActiveMQDestination |
SubscriptionInfo.subscribedDestination |
Modifier and Type | Method and Description |
---|---|
static ActiveMQDestination |
ActiveMQDestination.createDestination(java.lang.String name) |
ActiveMQDestination |
ConsumerInfo.getDestination()
The destination that the consumer is interested in receiving messages
from.
|
ActiveMQDestination |
ConsumerControl.getDestination() |
ActiveMQDestination |
MessagePull.getDestination() |
ActiveMQDestination |
DestinationInfo.getDestination() |
ActiveMQDestination |
Message.getDestination() |
ActiveMQDestination |
SubscriptionInfo.getDestination()
This is the a resolved destination that the subscription is receiving
messages from.
|
ActiveMQDestination |
MessageDispatchNotification.getDestination() |
ActiveMQDestination |
MessageAck.getDestination() |
ActiveMQDestination |
ProducerInfo.getDestination() |
ActiveMQDestination |
MessageDispatch.getDestination() |
ActiveMQDestination |
Message.getOriginalDestination() |
ActiveMQDestination |
Message.getReplyTo() |
ActiveMQDestination |
SubscriptionInfo.getSubscribedDestination()
The destination the client originally subscribed to..
|
Modifier and Type | Method and Description |
---|---|
static int |
ActiveMQDestination.compare(ActiveMQDestination destination,
ActiveMQDestination destination2) |
void |
ConsumerInfo.setDestination(ActiveMQDestination destination) |
void |
ConsumerControl.setDestination(ActiveMQDestination destination) |
void |
MessagePull.setDestination(ActiveMQDestination destination) |
void |
DestinationInfo.setDestination(ActiveMQDestination destination) |
void |
Message.setDestination(ActiveMQDestination destination) |
void |
SubscriptionInfo.setDestination(ActiveMQDestination destination) |
void |
MessageDispatchNotification.setDestination(ActiveMQDestination destination) |
void |
MessageAck.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) |
Constructor and Description |
---|
DestinationInfo(ConnectionId connectionId,
byte operationType,
ActiveMQDestination destination) |
Modifier and Type | Method and Description |
---|---|
static ActiveMQDestination |
AdvisorySupport.getAgentDestination()
Returns the agent topic which is used to send commands to the broker
|
Copyright © 2011-2014 Red Hat. All Rights Reserved.