|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.apache.activemq.broker.region.AbstractRegion
public abstract class AbstractRegion
Field Summary | |
---|---|
protected boolean |
autoCreateDestinations
|
protected RegionBroker |
broker
|
protected java.util.Map<ConsumerId,java.lang.Object> |
consumerChangeMutexMap
|
protected DestinationFactory |
destinationFactory
|
protected DestinationMap |
destinationMap
|
protected java.util.Map<ActiveMQDestination,Destination> |
destinations
|
protected java.util.concurrent.locks.ReentrantReadWriteLock |
destinationsLock
|
protected DestinationStatistics |
destinationStatistics
|
protected boolean |
started
|
protected java.util.Map<ConsumerId,Subscription> |
subscriptions
|
protected TaskRunnerFactory |
taskRunnerFactory
|
protected SystemUsage |
usageManager
|
Constructor Summary | |
---|---|
AbstractRegion(RegionBroker broker,
DestinationStatistics destinationStatistics,
SystemUsage memoryManager,
TaskRunnerFactory taskRunnerFactory,
DestinationFactory destinationFactory)
|
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. |
protected java.util.List<Subscription> |
addSubscriptionsForDestination(ConnectionContext context,
Destination dest)
|
protected Destination |
createDestination(ConnectionContext context,
ActiveMQDestination destination)
|
protected abstract Subscription |
createSubscription(ConnectionContext context,
ConsumerInfo info)
|
protected void |
destroySubscription(Subscription sub)
|
protected void |
dispose(ConnectionContext context,
Destination dest)
|
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 |
java.util.Set |
getDurableDestinations()
Get all the Destinations that are in storage |
protected java.util.Set<ActiveMQDestination> |
getInactiveDestinations()
|
java.util.Map<ConsumerId,Subscription> |
getSubscriptions()
|
boolean |
isAutoCreateDestinations()
|
protected Destination |
lookup(ConnectionContext context,
ActiveMQDestination destination,
boolean createTemporary)
|
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 |
protected void |
processDispatchNotificationViaDestination(MessageDispatchNotification messageDispatchNotification)
|
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 messageSend)
Send a message to the broker to using the specified destination. |
void |
setAutoCreateDestinations(boolean autoCreateDestinations)
|
void |
start()
|
void |
stop()
|
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
---|
protected final java.util.Map<ActiveMQDestination,Destination> destinations
protected final DestinationMap destinationMap
protected final java.util.Map<ConsumerId,Subscription> subscriptions
protected final SystemUsage usageManager
protected final DestinationFactory destinationFactory
protected final DestinationStatistics destinationStatistics
protected final RegionBroker broker
protected boolean autoCreateDestinations
protected final TaskRunnerFactory taskRunnerFactory
protected final java.util.concurrent.locks.ReentrantReadWriteLock destinationsLock
protected final java.util.Map<ConsumerId,java.lang.Object> consumerChangeMutexMap
protected boolean started
Constructor Detail |
---|
public AbstractRegion(RegionBroker broker, DestinationStatistics destinationStatistics, SystemUsage memoryManager, TaskRunnerFactory taskRunnerFactory, DestinationFactory destinationFactory)
Method Detail |
---|
public final void start() throws java.lang.Exception
start
in interface Service
java.lang.Exception
public void stop() throws java.lang.Exception
stop
in interface Service
java.lang.Exception
public Destination addDestination(ConnectionContext context, ActiveMQDestination destination, boolean createIfTemporary) throws java.lang.Exception
Region
addDestination
in interface Region
destination
- the destination to create.
java.lang.Exception
- TODOpublic java.util.Map<ConsumerId,Subscription> getSubscriptions()
protected java.util.List<Subscription> addSubscriptionsForDestination(ConnectionContext context, Destination dest) throws java.lang.Exception
java.lang.Exception
public void removeDestination(ConnectionContext context, ActiveMQDestination destination, long timeout) throws java.lang.Exception
Region
removeDestination
in interface Region
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
- TODOpublic java.util.Set<Destination> getDestinations(ActiveMQDestination destination)
getDestinations
in interface Region
public java.util.Map<ActiveMQDestination,Destination> getDestinationMap()
Region
getDestinationMap
in interface Region
public Subscription addConsumer(ConnectionContext context, ConsumerInfo info) throws java.lang.Exception
Region
addConsumer
in interface Region
context
- the environment the operation is being executed under.
java.lang.Exception
- TODOpublic java.util.Set getDurableDestinations()
protected java.util.Set<ActiveMQDestination> getInactiveDestinations()
public void removeConsumer(ConnectionContext context, ConsumerInfo info) throws java.lang.Exception
Region
removeConsumer
in interface Region
context
- the environment the operation is being executed under.
java.lang.Exception
- TODOprotected void destroySubscription(Subscription sub)
public void removeSubscription(ConnectionContext context, RemoveSubscriptionInfo info) throws java.lang.Exception
Region
removeSubscription
in interface Region
context
- the environment the operation is being executed under.info
- TODO
java.lang.Exception
- TODOpublic void send(ProducerBrokerExchange producerExchange, Message messageSend) throws java.lang.Exception
Region
send
in interface Region
producerExchange
- the environment the operation is being executed under.
java.lang.Exception
- TODOpublic void acknowledge(ConsumerBrokerExchange consumerExchange, MessageAck ack) throws java.lang.Exception
Region
acknowledge
in interface Region
consumerExchange
- the environment the operation is being executed under.
java.lang.Exception
- TODOpublic Response messagePull(ConnectionContext context, MessagePull pull) throws java.lang.Exception
Region
messagePull
in interface Region
java.lang.Exception
protected Destination lookup(ConnectionContext context, ActiveMQDestination destination, boolean createTemporary) throws java.lang.Exception
java.lang.Exception
public void processDispatchNotification(MessageDispatchNotification messageDispatchNotification) throws java.lang.Exception
Region
processDispatchNotification
in interface Region
java.lang.Exception
- TODOprotected void processDispatchNotificationViaDestination(MessageDispatchNotification messageDispatchNotification) throws java.lang.Exception
java.lang.Exception
public void gc()
gc
in interface Region
protected abstract Subscription createSubscription(ConnectionContext context, ConsumerInfo info) throws java.lang.Exception
java.lang.Exception
protected Destination createDestination(ConnectionContext context, ActiveMQDestination destination) throws java.lang.Exception
java.lang.Exception
public boolean isAutoCreateDestinations()
public void setAutoCreateDestinations(boolean autoCreateDestinations)
public void addProducer(ConnectionContext context, ProducerInfo info) throws java.lang.Exception
Region
addProducer
in interface Region
context
- the environment the operation is being executed under.
java.lang.Exception
- TODOpublic void removeProducer(ConnectionContext context, ProducerInfo info) throws java.lang.Exception
removeProducer
in interface Region
context
- the environment the operation is being executed under.
java.lang.Exception
- TODOprotected void dispose(ConnectionContext context, Destination dest) throws java.lang.Exception
java.lang.Exception
public void processConsumerControl(ConsumerBrokerExchange consumerExchange, ConsumerControl control)
processConsumerControl
in interface Region
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |