public interface Region extends Service
Modifier and Type | Method and Description |
---|---|
void |
acknowledge(ConsumerBrokerExchange consumerExchange,
MessageAck ack)
Used to acknowledge the receipt of a message by a client.
|
Subscription |
addConsumer(ConnectionContext context,
ConsumerInfo info)
Adds a consumer.
|
Destination |
addDestination(ConnectionContext context,
ActiveMQDestination destination,
boolean createIfTemporary)
Used to create a destination.
|
void |
addProducer(ConnectionContext context,
ProducerInfo info)
Adds a Producer.
|
void |
gc() |
Map<ActiveMQDestination,Destination> |
getDestinationMap()
Returns a reference to the concurrent hash map that holds known destinations, do not modify
|
Set<Destination> |
getDestinations(ActiveMQDestination destination)
Provide an exact or wildcard lookup of destinations in the region
|
Response |
messagePull(ConnectionContext context,
MessagePull pull)
Allows a consumer to pull a message from a queue
|
void |
processConsumerControl(ConsumerBrokerExchange consumerExchange,
ConsumerControl control) |
void |
processDispatchNotification(MessageDispatchNotification messageDispatchNotification)
Process a notification of a dispatch - used by a Slave Broker
|
void |
removeConsumer(ConnectionContext context,
ConsumerInfo info)
Removes a consumer.
|
void |
removeDestination(ConnectionContext context,
ActiveMQDestination destination,
long timeout)
Used to destroy a destination.
|
void |
removeProducer(ConnectionContext context,
ProducerInfo info)
Removes a Producer.
|
void |
removeSubscription(ConnectionContext context,
RemoveSubscriptionInfo info)
Deletes a durable subscription.
|
void |
send(ProducerBrokerExchange producerExchange,
Message message)
Send a message to the broker to using the specified destination.
|
Destination addDestination(ConnectionContext context, ActiveMQDestination destination, boolean createIfTemporary) throws Exception
context
- destination
- the destination to create.createIfTemporary
- Exception
- TODOvoid removeDestination(ConnectionContext context, ActiveMQDestination destination, long timeout) throws Exception
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 quiesceException
- TODOMap<ActiveMQDestination,Destination> getDestinationMap()
Subscription addConsumer(ConnectionContext context, ConsumerInfo info) throws Exception
context
- the environment the operation is being executed under.Exception
- TODOvoid removeConsumer(ConnectionContext context, ConsumerInfo info) throws Exception
context
- the environment the operation is being executed under.Exception
- TODOvoid addProducer(ConnectionContext context, ProducerInfo info) throws Exception
context
- the environment the operation is being executed under.Exception
- TODOvoid removeProducer(ConnectionContext context, ProducerInfo info) throws Exception
context
- the environment the operation is being executed under.Exception
- TODOvoid removeSubscription(ConnectionContext context, RemoveSubscriptionInfo info) throws Exception
context
- the environment the operation is being executed under.info
- TODOException
- TODOvoid send(ProducerBrokerExchange producerExchange, Message message) throws Exception
producerExchange
- the environment the operation is being executed under.message
- Exception
- TODOvoid acknowledge(ConsumerBrokerExchange consumerExchange, MessageAck ack) throws Exception
consumerExchange
- the environment the operation is being executed under.Exception
- TODOResponse messagePull(ConnectionContext context, MessagePull pull) throws Exception
Exception
void processDispatchNotification(MessageDispatchNotification messageDispatchNotification) throws Exception
messageDispatchNotification
- Exception
- TODOvoid gc()
Set<Destination> getDestinations(ActiveMQDestination destination)
void processConsumerControl(ConsumerBrokerExchange consumerExchange, ConsumerControl control)
Copyright © 2005–2016. All rights reserved.