Package | Description |
---|---|
org.apache.activemq.command |
Command objects used via the Command Pattern to communicate among nodes
|
Modifier and Type | Field and Description |
---|---|
protected BrokerId[] |
ProducerInfo.brokerPath |
protected BrokerId[] |
ConnectionInfo.brokerPath |
protected BrokerId[] |
DestinationInfo.brokerPath |
protected BrokerId[] |
ConsumerInfo.brokerPath |
protected BrokerId |
NetworkBridgeFilter.networkBrokerId |
Modifier and Type | Method and Description |
---|---|
BrokerId |
Endpoint.getBrokerId()
Returns the broker ID for this endpoint, if the endpoint is a broker or
null
|
BrokerId |
BrokerInfo.getBrokerId() |
BrokerId |
BaseEndpoint.getBrokerId()
Returns the broker ID for this endpoint, if the endpoint is a broker or
null
|
BrokerId[] |
ProducerInfo.getBrokerPath()
The route of brokers the command has moved through.
|
BrokerId[] |
Message.getBrokerPath()
The route of brokers the command has moved through.
|
BrokerId[] |
ConnectionInfo.getBrokerPath()
The route of brokers the command has moved through.
|
BrokerId[] |
DestinationInfo.getBrokerPath()
The route of brokers the command has moved through.
|
BrokerId[] |
ConsumerInfo.getBrokerPath()
The route of brokers the command has moved through.
|
BrokerId[] |
Message.getCluster()
If a message is stored in multiple nodes on a cluster, all the cluster
members will be listed here.
|
BrokerId |
NetworkBridgeFilter.getNetworkBrokerId() |
Modifier and Type | Method and Description |
---|---|
static boolean |
NetworkBridgeFilter.contains(BrokerId[] brokerPath,
BrokerId brokerId) |
static boolean |
NetworkBridgeFilter.contains(BrokerId[] brokerPath,
BrokerId brokerId) |
void |
BrokerInfo.setBrokerId(BrokerId brokerId) |
void |
ProducerInfo.setBrokerPath(BrokerId[] brokerPath) |
void |
Message.setBrokerPath(BrokerId[] brokerPath) |
void |
ConnectionInfo.setBrokerPath(BrokerId[] brokerPath) |
void |
DestinationInfo.setBrokerPath(BrokerId[] brokerPath) |
void |
ConsumerInfo.setBrokerPath(BrokerId[] brokerPath) |
void |
Message.setCluster(BrokerId[] cluster) |
void |
NetworkBridgeFilter.setNetworkBrokerId(BrokerId remoteBrokerPath) |
Constructor and Description |
---|
NetworkBridgeFilter(ConsumerInfo consumerInfo,
BrokerId networkBrokerId,
int messageTTL,
int consumerTTL) |
Copyright © 2005–2016 FuseSource, Corp.. All rights reserved.