Package org.apache.activemq.broker.region

Interface Region

All Superinterfaces:

Service

All Known Subinterfaces:

Broker

All Known Implementing Classes:

AbstractAuthenticationBroker, AbstractRegion, AbstractRuntimeConfigurationBroker, AbstractTempRegion, AdvisoryBroker, AuthenticationFilter, AuthorizationBroker, AuthorizationFilter, BrokerBroadcaster, BrokerFilter, BrokerPluginSupport, CompositeDestinationBroker, ConnectionDotFileInterceptor, ConnectionSplitBroker, DestinationDotFileInterceptor, DestinationPathSeparatorBroker, DestinationsPlugin, DiscardingDLQBroker, DotFileInterceptorSupport, EmptyBroker, EnvironmentFilter, ErrorBroker, ForcePersistencyModeBroker, InsertableMutableBrokerFilter, JaasAuthenticationBroker, JaasCertificateAuthenticationBroker, JaasDualAuthenticationBroker, JavaRuntimeConfigurationBroker, LoggingBrokerPlugin, ManagedQueueRegion, ManagedRegionBroker, ManagedTempQueueRegion, ManagedTempTopicRegion, ManagedTopicRegion, MulticastTraceBrokerPlugin, MutableBrokerFilter, PartitionBroker, QueueRegion, RedeliveryPlugin, RegionBroker, RuntimeConfigurationBroker, SchedulerBroker, SecurityFilter, ShiroPlugin, SimpleAuthenticationBroker, StatisticsBroker, SubjectFilter, SubQueueSelectorCacheBroker, TempQueueRegion, TempTopicRegion, TimeStampingBrokerPlugin, TopicRegion, TraceBrokerPathPlugin, TransactionBroker, UDPTraceBrokerPlugin, UserIDBroker, ZooKeeperPartitionBroker

public interface Region
extends Service

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

Modifier and Type	Method	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	reapplyInterceptor()
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

addDestination

Destination addDestination(ConnectionContext context,
                           ActiveMQDestination destination,
                           boolean createIfTemporary)
                    throws Exception

Used to create a destination. Usually, this method is invoked as a side-effect of sending a message to a destination that does not exist yet.

Parameters:

context -

destination - the destination to create.

createIfTemporary -

Returns:

TODO

Throws:

Exception - TODO

removeDestination

void removeDestination(ConnectionContext context,
                       ActiveMQDestination destination,
                       long timeout)
                throws Exception

Used to destroy a destination. This should try to quiesce use of the destination up to the timeout allotted time before removing the destination. This will remove all persistent messages associated with the destination.

Parameters:

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

Throws:

Exception - TODO

getDestinationMap

Map<ActiveMQDestination,Destination> getDestinationMap()

Returns a reference to the concurrent hash map that holds known destinations, do not modify

addConsumer

Subscription addConsumer(ConnectionContext context,
                         ConsumerInfo info)
                  throws Exception

Adds a consumer.

Parameters:

context - the environment the operation is being executed under.

Returns:

TODO

Throws:

Exception - TODO

removeConsumer

void removeConsumer(ConnectionContext context,
                    ConsumerInfo info)
             throws Exception

Removes a consumer.

Parameters:

context - the environment the operation is being executed under.

Throws:

Exception - TODO

addProducer

void addProducer(ConnectionContext context,
                 ProducerInfo info)
          throws Exception

Adds a Producer.

Parameters:

context - the environment the operation is being executed under.

Throws:

Exception - TODO

removeProducer

void removeProducer(ConnectionContext context,
                    ProducerInfo info)
             throws Exception

Removes a Producer.

Parameters:

context - the environment the operation is being executed under.

Throws:

Exception - TODO

removeSubscription

void removeSubscription(ConnectionContext context,
                        RemoveSubscriptionInfo info)
                 throws Exception

Deletes a durable subscription.

Parameters:

context - the environment the operation is being executed under.

info - TODO

Throws:

Exception - TODO

send

void send(ProducerBrokerExchange producerExchange,
          Message message)
   throws Exception

Send a message to the broker to using the specified destination. The destination specified in the message does not need to match the destination the message is sent to. This is handy in case the message is being sent to a dead letter destination.

Parameters:

producerExchange - the environment the operation is being executed under.

message -

Throws:

Exception - TODO

acknowledge

void acknowledge(ConsumerBrokerExchange consumerExchange,
                 MessageAck ack)
          throws Exception

Used to acknowledge the receipt of a message by a client.

Parameters:

consumerExchange - the environment the operation is being executed under.

Throws:

Exception - TODO

messagePull

Response messagePull(ConnectionContext context,
                     MessagePull pull)
              throws Exception

Allows a consumer to pull a message from a queue

Throws:

Exception

processDispatchNotification

void processDispatchNotification(MessageDispatchNotification messageDispatchNotification)
                          throws Exception

Process a notification of a dispatch - used by a Slave Broker

Parameters:

messageDispatchNotification -

Throws:

Exception - TODO

gc

void gc()

getDestinations

Set<Destination> getDestinations(ActiveMQDestination destination)

Provide an exact or wildcard lookup of destinations in the region

Returns:

a set of matching destination objects.

processConsumerControl

void processConsumerControl(ConsumerBrokerExchange consumerExchange,
                            ConsumerControl control)

reapplyInterceptor

void reapplyInterceptor()