org.apache.activemq.broker
public class BrokerBroadcaster extends BrokerFilter
Modifier and Type | Field and Description |
---|---|
protected Broker[] |
listeners |
next
Constructor and Description |
---|
BrokerBroadcaster(Broker next) |
Modifier and Type | Method and Description |
---|---|
void |
acknowledge(ConsumerBrokerExchange consumerExchange,
MessageAck ack)
Used to acknowledge the receipt of a message by a client.
|
void |
addBroker(Connection connection,
BrokerInfo info)
A remote Broker connects
|
void |
addConnection(ConnectionContext context,
ConnectionInfo info)
A client is establishing a connection with the broker.
|
Subscription |
addConsumer(ConnectionContext context,
ConsumerInfo info)
Adds a consumer.
|
Destination |
addDestination(ConnectionContext context,
ActiveMQDestination destination,
boolean createIfTemporary)
Used to create a destination.
|
void |
addListener(Broker broker) |
void |
addProducer(ConnectionContext context,
ProducerInfo info)
Adds a producer.
|
void |
addSession(ConnectionContext context,
SessionInfo info)
Adds a session.
|
void |
beginTransaction(ConnectionContext context,
TransactionId xid)
Starts a transaction.
|
void |
commitTransaction(ConnectionContext context,
TransactionId xid,
boolean onePhase)
Commits a transaction.
|
void |
forgetTransaction(ConnectionContext context,
TransactionId transactionId)
Forgets a transaction.
|
void |
gc() |
protected Broker[] |
getListeners() |
protected java.util.List<Broker> |
getListenersAsList() |
int |
prepareTransaction(ConnectionContext context,
TransactionId xid)
Prepares a transaction.
|
void |
removeConnection(ConnectionContext context,
ConnectionInfo info,
java.lang.Throwable error)
A client is disconnecting from the broker.
|
void |
removeConsumer(ConnectionContext context,
ConsumerInfo info)
Removes a consumer.
|
void |
removeDestination(ConnectionContext context,
ActiveMQDestination destination,
long timeout)
Used to destroy a destination.
|
void |
removeListener(Broker broker) |
void |
removeProducer(ConnectionContext context,
ProducerInfo info)
Removes a producer.
|
void |
removeSession(ConnectionContext context,
SessionInfo info)
Removes a session.
|
void |
removeSubscription(ConnectionContext context,
RemoveSubscriptionInfo info)
Deletes a durable subscription.
|
void |
rollbackTransaction(ConnectionContext context,
TransactionId xid)
Rollsback a transaction.
|
void |
send(ProducerBrokerExchange producerExchange,
Message messageSend)
Send a message to the broker to using the specified destination.
|
void |
start() |
void |
stop() |
addDestinationInfo, brokerServiceStarted, fastProducer, getAdaptor, getAdminConnectionContext, getBrokerId, getBrokerName, getBrokerSequenceId, getBrokerService, getClients, getDestinationMap, getDestinations, getDestinations, getDurableDestinations, getExecutor, getPeerBrokerInfos, getPreparedTransactions, getRoot, getScheduler, getTempDataStore, getVmConnectorURI, isExpired, isFaultTolerantConfiguration, isFull, isStopped, messageConsumed, messageDelivered, messageDiscarded, messageExpired, messagePull, networkBridgeStarted, networkBridgeStopped, nowMasterBroker, postProcessDispatch, preProcessDispatch, processConsumerControl, processDispatchNotification, removeBroker, removeDestinationInfo, sendToDeadLetterQueue, setAdminConnectionContext, slowConsumer
public BrokerBroadcaster(Broker next)
public void acknowledge(ConsumerBrokerExchange consumerExchange, MessageAck ack) throws java.lang.Exception
Region
acknowledge
in interface Region
acknowledge
in class BrokerFilter
consumerExchange
- the environment the operation is being executed under.java.lang.Exception
- TODOpublic void addConnection(ConnectionContext context, ConnectionInfo info) throws java.lang.Exception
Broker
addConnection
in interface Broker
addConnection
in class BrokerFilter
java.lang.Exception
- TODOpublic Subscription addConsumer(ConnectionContext context, ConsumerInfo info) throws java.lang.Exception
Region
addConsumer
in interface Region
addConsumer
in class BrokerFilter
context
- the environment the operation is being executed under.java.lang.Exception
- TODOpublic void addProducer(ConnectionContext context, ProducerInfo info) throws java.lang.Exception
Broker
addProducer
in interface Broker
addProducer
in interface Region
addProducer
in class BrokerFilter
context
- the enviorment the operation is being executed under.java.lang.Exception
- TODOpublic void commitTransaction(ConnectionContext context, TransactionId xid, boolean onePhase) throws java.lang.Exception
Broker
commitTransaction
in interface Broker
commitTransaction
in class BrokerFilter
java.lang.Exception
- TODOpublic void removeSubscription(ConnectionContext context, RemoveSubscriptionInfo info) throws java.lang.Exception
Region
removeSubscription
in interface Region
removeSubscription
in class BrokerFilter
context
- the environment the operation is being executed under.info
- TODOjava.lang.Exception
- TODOpublic int prepareTransaction(ConnectionContext context, TransactionId xid) throws java.lang.Exception
Broker
prepareTransaction
in interface Broker
prepareTransaction
in class BrokerFilter
java.lang.Exception
- TODOpublic void removeConnection(ConnectionContext context, ConnectionInfo info, java.lang.Throwable error) throws java.lang.Exception
Broker
removeConnection
in interface Broker
removeConnection
in class BrokerFilter
context
- the environment the operation is being executed under.error
- null if the client requested the disconnect or the error
that caused the client to disconnect.java.lang.Exception
- TODOpublic void removeConsumer(ConnectionContext context, ConsumerInfo info) throws java.lang.Exception
Region
removeConsumer
in interface Region
removeConsumer
in class BrokerFilter
context
- the environment the operation is being executed under.java.lang.Exception
- TODOpublic void removeProducer(ConnectionContext context, ProducerInfo info) throws java.lang.Exception
Broker
removeProducer
in interface Broker
removeProducer
in interface Region
removeProducer
in class BrokerFilter
context
- the enviorment the operation is being executed under.java.lang.Exception
- TODOpublic void rollbackTransaction(ConnectionContext context, TransactionId xid) throws java.lang.Exception
Broker
rollbackTransaction
in interface Broker
rollbackTransaction
in class BrokerFilter
java.lang.Exception
- TODOpublic void send(ProducerBrokerExchange producerExchange, Message messageSend) throws java.lang.Exception
Region
send
in interface Region
send
in class BrokerFilter
producerExchange
- the environment the operation is being executed under.java.lang.Exception
- TODOpublic void beginTransaction(ConnectionContext context, TransactionId xid) throws java.lang.Exception
Broker
beginTransaction
in interface Broker
beginTransaction
in class BrokerFilter
java.lang.Exception
- TODOpublic void forgetTransaction(ConnectionContext context, TransactionId transactionId) throws java.lang.Exception
Broker
forgetTransaction
in interface Broker
forgetTransaction
in class BrokerFilter
java.lang.Exception
public Destination addDestination(ConnectionContext context, ActiveMQDestination destination, boolean createIfTemporary) throws java.lang.Exception
Region
addDestination
in interface Region
addDestination
in class BrokerFilter
destination
- the destination to create.java.lang.Exception
- TODOpublic void removeDestination(ConnectionContext context, ActiveMQDestination destination, long timeout) throws java.lang.Exception
Region
removeDestination
in interface Region
removeDestination
in class BrokerFilter
context
- the environment the operation is being executed under.destination
- what is being removed from the broker.timeout
- the max amount of time to wait for the destination to quiescejava.lang.Exception
- TODOpublic void start() throws java.lang.Exception
start
in interface Service
start
in class BrokerFilter
java.lang.Exception
public void stop() throws java.lang.Exception
stop
in interface Service
stop
in class BrokerFilter
java.lang.Exception
public void addSession(ConnectionContext context, SessionInfo info) throws java.lang.Exception
Broker
addSession
in interface Broker
addSession
in class BrokerFilter
java.lang.Exception
- TODOpublic void removeSession(ConnectionContext context, SessionInfo info) throws java.lang.Exception
Broker
removeSession
in interface Broker
removeSession
in class BrokerFilter
java.lang.Exception
- TODOpublic void gc()
gc
in interface Region
gc
in class BrokerFilter
public void addBroker(Connection connection, BrokerInfo info)
Broker
addBroker
in interface Broker
addBroker
in class BrokerFilter
protected Broker[] getListeners()
public void addListener(Broker broker)
public void removeListener(Broker broker)
protected java.util.List<Broker> getListenersAsList()
Copyright © 2005-2014. All Rights Reserved.