|
||||||||||
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(ConnectionContext context,
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)
Used to create a destination. |
void |
gc()
|
java.util.Map |
getDestinationMap()
Returns a copy of the current destinations available in the region |
java.util.Set |
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 |
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 |
removeSubscription(ConnectionContext context,
RemoveSubscriptionInfo info)
Deletes a durable subscription. |
void |
send(ConnectionContext context,
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) throws java.lang.Exception
context
- destination
- the destination to create.
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 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 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(ConnectionContext context, Message message) throws java.lang.Exception
context
- the environment the operation is being executed under.
java.lang.Exception
- TODOvoid acknowledge(ConnectionContext context, MessageAck ack) throws java.lang.Exception
context
- 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 getDestinations(ActiveMQDestination destination)
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |