Save This Page
Home » activemq-parent-5.3.1-source-release » org.apache » activemq » broker » region » [javadoc | source]
org.apache.activemq.broker.region
public class: RegionBroker [javadoc | source]
java.lang.Object
   org.apache.activemq.broker.EmptyBroker
      org.apache.activemq.broker.region.RegionBroker

All Implemented Interfaces:
    Broker

Direct Known Subclasses:
    ManagedRegionBroker

Routes Broker operations to the correct messaging regions for processing.
Field Summary
public static final  String ORIGINAL_EXPIRATION     
protected final  DestinationStatistics destinationStatistics     
protected  DestinationFactory destinationFactory     
protected final  Map<ConnectionId, ConnectionState> connectionStates     
protected final  BrokerService brokerService     
Constructor:
 public RegionBroker(BrokerService brokerService,
    TaskRunnerFactory taskRunnerFactory,
    SystemUsage memoryManager,
    DestinationFactory destinationFactory,
    DestinationInterceptor destinationInterceptor) throws IOException 
Method from org.apache.activemq.broker.region.RegionBroker Summary:
acknowledge,   addBroker,   addConnection,   addConsumer,   addDestination,   addDestinationInfo,   addProducer,   beginTransaction,   brokerServiceStarted,   commitTransaction,   createQueueRegion,   createTempQueueRegion,   createTempTopicRegion,   createTopicRegion,   createUnknownDestinationTypeException,   doStop,   forgetTransaction,   gc,   getAdaptor,   getAdminConnectionContext,   getBrokerId,   getBrokerName,   getBrokerSequenceId,   getBrokerService,   getClients,   getConnectionStates,   getDestinationInterceptor,   getDestinationMap,   getDestinationPolicy,   getDestinationStatistics,   getDestinations,   getDestinations,   getDurableDestinations,   getPeerBrokerInfos,   getPreparedTransactions,   getQueueRegion,   getRoot,   getTempDataStore,   getTempQueueRegion,   getTempTopicRegion,   getTopicRegion,   getVmConnectorURI,   isEqual,   isExpired,   isKeepDurableSubsActive,   isSlaveBroker,   isStopped,   messageExpired,   messagePull,   postProcessDispatch,   preProcessDispatch,   prepareTransaction,   processDispatchNotification,   removeBroker,   removeConnection,   removeConsumer,   removeDestination,   removeDestinationInfo,   removeProducer,   removeSubscription,   rollbackTransaction,   send,   sendToDeadLetterQueue,   setAdminConnectionContext,   setBrokerId,   setBrokerName,   setKeepDurableSubsActive,   start,   stop
Methods from org.apache.activemq.broker.EmptyBroker:
acknowledge,   addBroker,   addConnection,   addConsumer,   addDestination,   addDestinationInfo,   addProducer,   addSession,   beginTransaction,   brokerServiceStarted,   commitTransaction,   fastProducer,   forgetTransaction,   gc,   getAdaptor,   getAdminConnectionContext,   getBrokerId,   getBrokerName,   getBrokerSequenceId,   getBrokerService,   getClients,   getDestinationMap,   getDestinations,   getDestinations,   getDurableDestinations,   getPeerBrokerInfos,   getPreparedTransactions,   getRoot,   getTempDataStore,   getVmConnectorURI,   isExpired,   isFaultTolerantConfiguration,   isFull,   isStopped,   messageConsumed,   messageDelivered,   messageDiscarded,   messageExpired,   messagePull,   nowMasterBroker,   postProcessDispatch,   preProcessDispatch,   prepareTransaction,   processDispatchNotification,   removeBroker,   removeConnection,   removeConsumer,   removeDestination,   removeDestinationInfo,   removeProducer,   removeSession,   removeSubscription,   rollbackTransaction,   send,   sendToDeadLetterQueue,   setAdminConnectionContext,   slowConsumer,   start,   stop
Methods from java.lang.Object:
clone,   equals,   finalize,   getClass,   hashCode,   notify,   notifyAll,   toString,   wait,   wait,   wait
Method from org.apache.activemq.broker.region.RegionBroker Detail:
 public  void acknowledge(ConsumerBrokerExchange consumerExchange,
    MessageAck ack) throws Exception 
 public synchronized  void addBroker(Connection connection,
    BrokerInfo info) 
 public  void addConnection(ConnectionContext context,
    ConnectionInfo info) throws Exception 
 public Subscription addConsumer(ConnectionContext context,
    ConsumerInfo info) throws Exception 
 public Destination addDestination(ConnectionContext context,
    ActiveMQDestination destination) throws Exception 
 public  void addDestinationInfo(ConnectionContext context,
    DestinationInfo info) throws Exception 
 public  void addProducer(ConnectionContext context,
    ProducerInfo info) throws Exception 
 public  void beginTransaction(ConnectionContext context,
    TransactionId xid) throws Exception 
 public  void brokerServiceStarted() 
 public  void commitTransaction(ConnectionContext context,
    TransactionId xid,
    boolean onePhase) throws Exception 
 protected Region createQueueRegion(SystemUsage memoryManager,
    TaskRunnerFactory taskRunnerFactory,
    DestinationFactory destinationFactory) 
 protected Region createTempQueueRegion(SystemUsage memoryManager,
    TaskRunnerFactory taskRunnerFactory,
    DestinationFactory destinationFactory) 
 protected Region createTempTopicRegion(SystemUsage memoryManager,
    TaskRunnerFactory taskRunnerFactory,
    DestinationFactory destinationFactory) 
 protected Region createTopicRegion(SystemUsage memoryManager,
    TaskRunnerFactory taskRunnerFactory,
    DestinationFactory destinationFactory) 
 protected JMSException createUnknownDestinationTypeException(ActiveMQDestination destination) 
 protected  void doStop(ServiceStopper ss) 
 public  void forgetTransaction(ConnectionContext context,
    TransactionId transactionId) throws Exception 
 public  void gc() 
 public Broker getAdaptor(Class type) 
 public ConnectionContext getAdminConnectionContext() 
 public BrokerId getBrokerId() 
 public String getBrokerName() 
 public long getBrokerSequenceId() 
 public BrokerService getBrokerService() 
 public Connection[] getClients() throws Exception 
 public Map<ConnectionId, ConnectionState> getConnectionStates() 
 public DestinationInterceptor getDestinationInterceptor() 
 public Map<ActiveMQDestination, Destination> getDestinationMap() 
 public PolicyMap getDestinationPolicy() 
 public DestinationStatistics getDestinationStatistics() 
 public ActiveMQDestination[] getDestinations() throws Exception 
 public Set<Destination> getDestinations(ActiveMQDestination destination) 
 public Set<ActiveMQDestination> getDurableDestinations() 
 public synchronized BrokerInfo[] getPeerBrokerInfos() 
 public TransactionId[] getPreparedTransactions(ConnectionContext context) throws Exception 
 public Region getQueueRegion() 
 public Broker getRoot() 
 public Store getTempDataStore() 
 public Region getTempQueueRegion() 
 public Region getTempTopicRegion() 
 public Region getTopicRegion() 
 public URI getVmConnectorURI() 
 protected boolean isEqual(ConnectionId connectionId,
    ConnectionId connectionId2) 
 public boolean isExpired(MessageReference messageReference) 
 public boolean isKeepDurableSubsActive() 
 public boolean isSlaveBroker() 
 public boolean isStopped() 
 public  void messageExpired(ConnectionContext context,
    MessageReference node) 
 public Response messagePull(ConnectionContext context,
    MessagePull pull) throws Exception 
 public  void postProcessDispatch(MessageDispatch messageDispatch) 
 public  void preProcessDispatch(MessageDispatch messageDispatch) 
 public int prepareTransaction(ConnectionContext context,
    TransactionId xid) throws Exception 
 public  void processDispatchNotification(MessageDispatchNotification messageDispatchNotification) throws Exception 
 public synchronized  void removeBroker(Connection connection,
    BrokerInfo info) 
 public  void removeConnection(ConnectionContext context,
    ConnectionInfo info,
    Throwable error) throws Exception 
 public  void removeConsumer(ConnectionContext context,
    ConsumerInfo info) throws Exception 
 public  void removeDestination(ConnectionContext context,
    ActiveMQDestination destination,
    long timeout) throws Exception 
 public  void removeDestinationInfo(ConnectionContext context,
    DestinationInfo info) throws Exception 
 public  void removeProducer(ConnectionContext context,
    ProducerInfo info) throws Exception 
 public  void removeSubscription(ConnectionContext context,
    RemoveSubscriptionInfo info) throws Exception 
 public  void rollbackTransaction(ConnectionContext context,
    TransactionId xid) throws Exception 
 public  void send(ProducerBrokerExchange producerExchange,
    Message message) throws Exception 
 public  void sendToDeadLetterQueue(ConnectionContext context,
    MessageReference node) 
 public  void setAdminConnectionContext(ConnectionContext adminConnectionContext) 
 public  void setBrokerId(BrokerId brokerId) 
 public  void setBrokerName(String brokerName) 
 public  void setKeepDurableSubsActive(boolean keepDurableSubsActive) 
 public  void start() throws Exception 
 public  void stop() throws Exception