|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
public interface Region
A Region is used to implement the different QOS options available to a broker. A Broker is composed of multiple message processing Regions that provide different QOS options.
Method Summary | |
---|---|
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()
|
java.util.Map<ActiveMQDestination,Destination> |
getDestinationMap()
Returns a reference to the concurrent hash map that holds known destinations, do not modify |
java.util.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. |
Methods inherited from interface org.apache.activemq.Service |
---|
start, stop |
Method Detail |
---|
Destination addDestination(ConnectionContext context, ActiveMQDestination destination, boolean createIfTemporary) throws java.lang.Exception
context
- destination
- the destination to create.createIfTemporary
-
java.lang.Exception
- TODOvoid removeDestination(ConnectionContext context, ActiveMQDestination destination, long timeout) throws java.lang.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 quiesce
java.lang.Exception
- TODOjava.util.Map<ActiveMQDestination,Destination> getDestinationMap()
Subscription addConsumer(ConnectionContext context, ConsumerInfo info) throws java.lang.Exception
context
- the environment the operation is being executed under.
java.lang.Exception
- TODOvoid removeConsumer(ConnectionContext context, ConsumerInfo info) throws java.lang.Exception
context
- the environment the operation is being executed under.
java.lang.Exception
- TODOvoid addProducer(ConnectionContext context, ProducerInfo info) throws java.lang.Exception
context
- the environment the operation is being executed under.
java.lang.Exception
- TODOvoid removeProducer(ConnectionContext context, ProducerInfo info) throws java.lang.Exception
context
- the environment the operation is being executed under.
java.lang.Exception
- TODOvoid removeSubscription(ConnectionContext context, RemoveSubscriptionInfo info) throws java.lang.Exception
context
- the environment the operation is being executed under.info
- TODO
java.lang.Exception
- TODOvoid send(ProducerBrokerExchange producerExchange, Message message) throws java.lang.Exception
producerExchange
- the environment the operation is being executed under.message
-
java.lang.Exception
- TODOvoid acknowledge(ConsumerBrokerExchange consumerExchange, MessageAck ack) throws java.lang.Exception
consumerExchange
- the environment the operation is being executed under.
java.lang.Exception
- TODOResponse messagePull(ConnectionContext context, MessagePull pull) throws java.lang.Exception
java.lang.Exception
void processDispatchNotification(MessageDispatchNotification messageDispatchNotification) throws java.lang.Exception
messageDispatchNotification
-
java.lang.Exception
- TODOvoid gc()
java.util.Set<Destination> getDestinations(ActiveMQDestination destination)
void processConsumerControl(ConsumerBrokerExchange consumerExchange, ConsumerControl control)
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |