|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.apache.activemq.broker.BrokerService
public class BrokerService
Manages the lifecycle of an ActiveMQ Broker. A BrokerService consists of a number of transport connectors, network connectors and a bunch of properties which can be used to configure the broker as its lazily created.
Field Summary | |
---|---|
static String |
DEFAULT_BROKER_NAME
|
static String |
DEFAULT_PORT
|
protected DestinationFactory |
destinationFactory
|
static String |
LOCAL_HOST_NAME
|
protected CountDownLatch |
slaveStartSignal
|
Constructor Summary | |
---|---|
BrokerService()
|
Method Summary | |
---|---|
TransportConnector |
addConnector(String bindAddress)
Adds a new transport connector for the given bind address |
TransportConnector |
addConnector(TransportConnector connector)
Adds a new transport connector |
TransportConnector |
addConnector(TransportServer transport)
Adds a new transport connector for the given TransportServer transport |
TransportConnector |
addConnector(URI bindAddress)
Adds a new transport connector for the given bind address |
protected Broker |
addInterceptors(Broker broker)
Strategy method to add interceptors to the broker |
JmsConnector |
addJmsConnector(JmsConnector connector)
|
NetworkConnector |
addNetworkConnector(NetworkConnector connector)
Adds a new network connector to connect this broker to a federated network |
NetworkConnector |
addNetworkConnector(String discoveryAddress)
Adds a new network connector using the given discovery address |
NetworkConnector |
addNetworkConnector(URI discoveryAddress)
Adds a new network connector using the given discovery address |
ProxyConnector |
addProxyConnector(ProxyConnector connector)
|
ProxyConnector |
addProxyConnector(String bindAddress)
Adds a new proxy connector using the given bind address |
ProxyConnector |
addProxyConnector(URI bindAddress)
Adds a new proxy connector using the given bind address |
void |
addService(Service service)
Adds a new service so that it will be started as part of the broker lifecycle |
protected void |
addShutdownHook()
|
void |
addShutdownHook(Runnable hook)
|
boolean |
checkQueueSize(String queueName)
|
protected void |
configureService(Object service)
Perform any custom dependency injection |
protected void |
configureServices(Object[] services)
Perform any custom dependency injection |
protected void |
containerShutdown()
Causes a clean shutdown of the container when the VM is being shut down |
protected ConnectionContext |
createAdminConnectionContext()
Factory method to create the new administration connection context object. |
protected Broker |
createBroker()
Factory method to create a new broker |
protected ObjectName |
createBrokerObjectName()
|
protected DestinationInterceptor[] |
createDefaultDestinationInterceptor()
Create the default destination interceptor |
protected ObjectName |
createNetworkConnectorObjectName(NetworkConnector connector)
|
protected PersistenceAdapter |
createPersistenceAdapter()
|
protected AMQPersistenceAdapterFactory |
createPersistenceFactory()
|
protected Broker |
createRegionBroker()
Factory method to create the core region broker onto which interceptors are added |
protected Broker |
createRegionBroker(DestinationInterceptor destinationInterceptor)
|
protected TransportConnector |
createTransportConnector(URI brokerURI)
|
void |
deleteAllMessages()
Delete all messages from the persistent store |
ConnectionContext |
getAdminConnectionContext()
Returns the broker's administration connection context used for configuring the broker at startup |
BrokerView |
getAdminView()
Returns the administration view of the broker; used to create and destroy resources such as queues and topics. |
Broker |
getBroker()
Returns the message broker |
File |
getBrokerDataDirectory()
|
String |
getBrokerName()
|
ObjectName |
getBrokerObjectName()
|
TransportConnector |
getConnectorByName(String connectorName)
|
SystemUsage |
getConsumerSystemUsage()
|
int |
getConsumerSystemUsagePortion()
|
File |
getDataDirectoryFile()
|
Destination |
getDestination(ActiveMQDestination destination)
Looks up and lazily creates if necessary the destination for the given JMS name |
DestinationInterceptor[] |
getDestinationInterceptors()
|
PolicyMap |
getDestinationPolicy()
|
ActiveMQDestination[] |
getDestinations()
|
JmsConnector[] |
getJmsBridgeConnectors()
|
ManagementContext |
getManagementContext()
|
String |
getMasterConnectorURI()
|
MessageAuthorizationPolicy |
getMessageAuthorizationPolicy()
|
NetworkConnector |
getNetworkConnectorByName(String connectorName)
|
List<NetworkConnector> |
getNetworkConnectors()
|
String[] |
getNetworkConnectorURIs()
|
PersistenceAdapter |
getPersistenceAdapter()
|
PersistenceAdapterFactory |
getPersistenceFactory()
|
TaskRunnerFactory |
getPersistenceTaskRunnerFactory()
|
int |
getPersistenceThreadPriority()
|
BrokerPlugin[] |
getPlugins()
|
protected Object |
getPort(Map options)
Extracts the port from the options |
SystemUsage |
getProducerSystemUsage()
|
int |
getProducerSystemUsagePortion()
|
List<ProxyConnector> |
getProxyConnectors()
|
Broker |
getRegionBroker()
|
Service[] |
getServices()
|
CountDownLatch |
getSlaveStartSignal()
|
SslContext |
getSslContext()
|
int |
getSystemExitOnShutdownExitCode()
|
SystemUsage |
getSystemUsage()
|
TaskRunnerFactory |
getTaskRunnerFactory()
|
int |
getTaskRunnerPriority()
|
Store |
getTempDataStore()
|
int |
getTimeBeforePurgeTempDestinations()
|
File |
getTmpDataDirectory()
|
List<TransportConnector> |
getTransportConnectors()
|
String[] |
getTransportConnectorURIs()
|
Map<String,String> |
getTransportConnectorURIsAsMap()
|
URI |
getVmConnectorURI()
|
long |
getWaitForSlaveTimeout()
|
void |
handleIOException(IOException exception)
|
boolean |
isAdvisorySupport()
|
boolean |
isCacheTempDestinations()
|
boolean |
isDedicatedTaskRunner()
|
boolean |
isDeleteAllMessagesOnStartup()
|
boolean |
isEnableStatistics()
|
boolean |
isKeepDurableSubsActive()
|
boolean |
isMonitorConnectionSplits()
|
boolean |
isPassiveSlave()
Get the passiveSlave |
boolean |
isPersistent()
|
boolean |
isPopulateJMSXUserID()
|
boolean |
isShutdownOnMasterFailure()
|
boolean |
isShutdownOnSlaveFailure()
|
boolean |
isSlave()
|
boolean |
isSplitSystemUsageForProducersConsumers()
|
boolean |
isStarted()
|
boolean |
isSupportFailOver()
|
boolean |
isSystemExitOnShutdown()
|
boolean |
isUseJmx()
|
boolean |
isUseLocalHostBrokerName()
|
boolean |
isUseLoggingForShutdownErrors()
|
boolean |
isUseMirroredQueues()
|
boolean |
isUseShutdownHook()
|
boolean |
isUseTempMirroredQueues()
|
boolean |
isUseVirtualTopics()
|
boolean |
isWaitForSlave()
|
protected void |
logError(String message,
Throwable e)
|
void |
masterFailed()
|
protected void |
processHelperProperties()
Handles any lazy-creation helper properties which are added to make things easier to configure inside environments such as Spring |
protected TransportConnector |
registerConnectorMBean(TransportConnector connector)
|
protected void |
registerFTConnectorMBean(MasterConnector connector)
|
protected void |
registerJmsConnectorMBean(JmsConnector connector)
|
protected void |
registerNetworkConnectorMBean(NetworkConnector connector)
|
protected PersistenceAdapter |
registerPersistenceAdapterMBean(PersistenceAdapter adaptor)
|
protected void |
registerProxyConnectorMBean(ProxyConnector connector)
|
boolean |
removeConnector(TransportConnector connector)
Stops and removes a transport connector from the broker. |
void |
removeDestination(ActiveMQDestination destination)
|
JmsConnector |
removeJmsConnector(JmsConnector connector)
|
boolean |
removeNetworkConnector(NetworkConnector connector)
Removes the given network connector without stopping it. |
void |
removeService(Service service)
|
protected void |
removeShutdownHook()
|
void |
removeShutdownHook(Runnable hook)
|
void |
setAdminView(BrokerView adminView)
|
void |
setAdvisorySupport(boolean advisorySupport)
Allows the support of advisory messages to be disabled for performance reasons. |
void |
setBrokerName(String brokerName)
Sets the name of this broker; which must be unique in the network |
void |
setBrokerObjectName(ObjectName brokerObjectName)
Sets the JMX ObjectName for this broker |
void |
setCacheTempDestinations(boolean cacheTempDestinations)
|
void |
setConsumerSystemUsage(SystemUsage consumerSystemUsaage)
|
void |
setConsumerSystemUsagePortion(int consumerSystemUsagePortion)
|
void |
setDataDirectory(String dataDirectory)
Sets the directory in which the data files will be stored by default for the JDBC and Journal persistence adaptors. |
void |
setDataDirectoryFile(File dataDirectoryFile)
Sets the directory in which the data files will be stored by default for the JDBC and Journal persistence adaptors. |
void |
setDedicatedTaskRunner(boolean dedicatedTaskRunner)
|
void |
setDeleteAllMessagesOnStartup(boolean deletePersistentMessagesOnStartup)
Sets whether or not all messages are deleted on startup - mostly only useful for testing. |
void |
setDestinationFactory(DestinationFactory destinationFactory)
|
void |
setDestinationInterceptors(DestinationInterceptor[] destinationInterceptors)
Sets the destination interceptors to use |
void |
setDestinationPolicy(PolicyMap policyMap)
Sets the destination specific policies available either for exact destinations or for wildcard areas of destinations. |
void |
setDestinations(ActiveMQDestination[] destinations)
Sets the destinations which should be loaded/created on startup |
void |
setEnableStatistics(boolean enableStatistics)
Sets whether or not the Broker's services enable statistics or not. |
void |
setIoExceptionHandler(IOExceptionHandler ioExceptionHandler)
|
void |
setJmsBridgeConnectors(JmsConnector[] jmsConnectors)
|
void |
setKeepDurableSubsActive(boolean keepDurableSubsActive)
|
void |
setManagementContext(ManagementContext managementContext)
|
void |
setMasterConnectorURI(String masterConnectorURI)
|
void |
setMessageAuthorizationPolicy(MessageAuthorizationPolicy messageAuthorizationPolicy)
Sets the policy used to decide if the current connection is authorized to consume a given message |
void |
setMonitorConnectionSplits(boolean monitorConnectionSplits)
|
void |
setNetworkConnectors(List networkConnectors)
Sets the network connectors which this broker will use to connect to other brokers in a federated network |
void |
setNetworkConnectorURIs(String[] networkConnectorURIs)
|
void |
setPassiveSlave(boolean passiveSlave)
Set the passiveSlave |
void |
setPersistenceAdapter(PersistenceAdapter persistenceAdapter)
Sets the persistence adaptor implementation to use for this broker |
void |
setPersistenceFactory(PersistenceAdapterFactory persistenceFactory)
|
void |
setPersistenceTaskRunnerFactory(TaskRunnerFactory persistenceTaskRunnerFactory)
|
void |
setPersistenceThreadPriority(int persistenceThreadPriority)
|
void |
setPersistent(boolean persistent)
Sets whether or not persistence is enabled or disabled. |
void |
setPlugins(BrokerPlugin[] plugins)
Sets a number of broker plugins to install such as for security authentication or authorization |
void |
setPopulateJMSXUserID(boolean populateJMSXUserID)
Sets whether or not the broker should populate the JMSXUserID header. |
void |
setProducerSystemUsage(SystemUsage producerUsageManager)
|
void |
setProducerSystemUsagePortion(int producerSystemUsagePortion)
|
void |
setProxyConnectors(List proxyConnectors)
Sets the network connectors which this broker will use to connect to other brokers in a federated network |
void |
setRegionBroker(Broker regionBroker)
|
void |
setServices(Service[] services)
Sets the services associated with this broker such as a MasterConnector |
void |
setShutdownOnMasterFailure(boolean shutdownOnMasterFailure)
|
void |
setShutdownOnSlaveFailure(boolean shutdownOnSlaveFailure)
|
void |
setSplitSystemUsageForProducersConsumers(boolean splitSystemUsageForProducersConsumers)
|
void |
setSslContext(SslContext sslContext)
|
void |
setSupportFailOver(boolean supportFailOver)
|
void |
setSystemExitOnShutdown(boolean systemExitOnShutdown)
|
void |
setSystemExitOnShutdownExitCode(int systemExitOnShutdownExitCode)
|
void |
setSystemUsage(SystemUsage memoryManager)
|
void |
setTaskRunnerFactory(TaskRunnerFactory taskRunnerFactory)
|
void |
setTaskRunnerPriority(int taskRunnerPriority)
|
void |
setTempDataStore(Store tempDataStore)
|
void |
setTimeBeforePurgeTempDestinations(int timeBeforePurgeTempDestinations)
|
void |
setTmpDataDirectory(File tmpDataDirectory)
|
void |
setTransportConnectors(List<TransportConnector> transportConnectors)
Sets the transport connectors which this broker will listen on for new clients |
void |
setTransportConnectorURIs(String[] transportConnectorURIs)
|
void |
setUseJmx(boolean useJmx)
Sets whether or not the Broker's services should be exposed into JMX or not. |
void |
setUseLocalHostBrokerName(boolean useLocalHostBrokerName)
|
void |
setUseLoggingForShutdownErrors(boolean useLoggingForShutdownErrors)
Sets whether or not we should use commons-logging when reporting errors when shutting down the broker |
void |
setUseMirroredQueues(boolean useMirroredQueues)
Sets whether or not Mirrored Queues should be supported by default if they have not been explicitly configured. |
void |
setUseShutdownHook(boolean useShutdownHook)
Sets whether or not we should use a shutdown handler to close down the broker cleanly if the JVM is terminated. |
void |
setUseTempMirroredQueues(boolean useTempMirroredQueues)
|
void |
setUseVirtualTopics(boolean useVirtualTopics)
Sets whether or not Virtual Topics should be supported by default if they have not been explicitly configured. |
void |
setVmConnectorURI(URI vmConnectorURI)
|
void |
setWaitForSlave(boolean waitForSlave)
|
void |
setWaitForSlaveTimeout(long waitForSlaveTimeout)
|
protected void |
slaveConnectionEstablished()
|
void |
start()
|
void |
start(boolean force)
|
protected void |
startAllConnectors()
Start all transport and network connections, proxies and bridges |
protected void |
startDestinations()
Starts any configured destinations on startup |
protected void |
startDestinationsInPersistenceStore(Broker broker)
Starts all destiantions in persistence store. |
protected void |
startManagementContext()
|
protected TransportConnector |
startTransportConnector(TransportConnector connector)
|
void |
stop()
|
protected void |
stopAllConnectors(ServiceStopper stopper)
|
void |
stopGracefully(String connectorName,
String queueName,
long timeout,
long pollInterval)
This method (both connectorName and queueName are using regex to match) 1. |
String |
toString()
|
protected void |
unregisterConnectorMBean(TransportConnector connector)
|
protected void |
unregisterNetworkConnectorMBean(NetworkConnector connector)
|
protected void |
unregisterPersistenceAdapterMBean(PersistenceAdapter adaptor)
|
protected void |
waitForSlave()
|
void |
waitUntilStarted()
A helper method to block the caller thread until the broker has been started |
void |
waitUntilStopped()
A helper method to block the caller thread until the broker has been stopped |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
Field Detail |
---|
protected CountDownLatch slaveStartSignal
public static final String DEFAULT_PORT
public static final String LOCAL_HOST_NAME
public static final String DEFAULT_BROKER_NAME
protected DestinationFactory destinationFactory
Constructor Detail |
---|
public BrokerService()
Method Detail |
---|
public String toString()
toString
in class Object
public TransportConnector addConnector(String bindAddress) throws Exception
Exception
public TransportConnector addConnector(URI bindAddress) throws Exception
Exception
public TransportConnector addConnector(TransportServer transport) throws Exception
Exception
public TransportConnector addConnector(TransportConnector connector) throws Exception
Exception
public boolean removeConnector(TransportConnector connector) throws Exception
connector
-
Exception
public NetworkConnector addNetworkConnector(String discoveryAddress) throws Exception
Exception
public ProxyConnector addProxyConnector(String bindAddress) throws Exception
Exception
public NetworkConnector addNetworkConnector(URI discoveryAddress) throws Exception
Exception
public ProxyConnector addProxyConnector(URI bindAddress) throws Exception
Exception
public NetworkConnector addNetworkConnector(NetworkConnector connector) throws Exception
Exception
public boolean removeNetworkConnector(NetworkConnector connector)
NetworkConnector.stop()
to close the connector
public ProxyConnector addProxyConnector(ProxyConnector connector) throws Exception
Exception
public JmsConnector addJmsConnector(JmsConnector connector) throws Exception
Exception
public JmsConnector removeJmsConnector(JmsConnector connector)
public String getMasterConnectorURI()
public void setMasterConnectorURI(String masterConnectorURI)
masterConnectorURI
- The masterConnectorURI to set.public boolean isSlave()
public void masterFailed()
public boolean isStarted()
public void start(boolean force) throws Exception
Exception
@PostConstruct public void start() throws Exception
start
in interface Service
Exception
@PreDestroy public void stop() throws Exception
stop
in interface Service
Exception
public boolean checkQueueSize(String queueName)
public void stopGracefully(String connectorName, String queueName, long timeout, long pollInterval) throws Exception
connectorName
- queueName
- timeout
- pollInterval
-
Exception
public void waitUntilStopped()
public void waitUntilStarted()
public Broker getBroker() throws Exception
Exception
public BrokerView getAdminView() throws Exception
Exception
public void setAdminView(BrokerView adminView)
public String getBrokerName()
public void setBrokerName(String brokerName)
brokerName
- public PersistenceAdapterFactory getPersistenceFactory()
public File getDataDirectoryFile()
public File getBrokerDataDirectory()
public void setDataDirectory(String dataDirectory)
dataDirectory
- the directory to store data filespublic void setDataDirectoryFile(File dataDirectoryFile)
dataDirectoryFile
- the directory to store data filespublic File getTmpDataDirectory()
public void setTmpDataDirectory(File tmpDataDirectory)
tmpDataDirectory
- the tmpDataDirectory to setpublic void setPersistenceFactory(PersistenceAdapterFactory persistenceFactory)
public void setDestinationFactory(DestinationFactory destinationFactory)
public boolean isPersistent()
public void setPersistent(boolean persistent)
public boolean isPopulateJMSXUserID()
public void setPopulateJMSXUserID(boolean populateJMSXUserID)
public SystemUsage getSystemUsage()
public void setSystemUsage(SystemUsage memoryManager)
public SystemUsage getConsumerSystemUsage() throws IOException
IOException
public void setConsumerSystemUsage(SystemUsage consumerSystemUsaage)
consumerSystemUsaage
- the storeSystemUsage to setpublic SystemUsage getProducerSystemUsage() throws IOException
IOException
public void setProducerSystemUsage(SystemUsage producerUsageManager)
producerUsageManager
- the producerUsageManager to setpublic PersistenceAdapter getPersistenceAdapter() throws IOException
IOException
public void setPersistenceAdapter(PersistenceAdapter persistenceAdapter) throws IOException
IOException
public TaskRunnerFactory getTaskRunnerFactory()
public void setTaskRunnerFactory(TaskRunnerFactory taskRunnerFactory)
public TaskRunnerFactory getPersistenceTaskRunnerFactory()
public void setPersistenceTaskRunnerFactory(TaskRunnerFactory persistenceTaskRunnerFactory)
public boolean isUseJmx()
public boolean isEnableStatistics()
public void setEnableStatistics(boolean enableStatistics)
public void setUseJmx(boolean useJmx)
public ObjectName getBrokerObjectName() throws IOException
IOException
public void setBrokerObjectName(ObjectName brokerObjectName)
public ManagementContext getManagementContext()
public void setManagementContext(ManagementContext managementContext)
public NetworkConnector getNetworkConnectorByName(String connectorName)
public String[] getNetworkConnectorURIs()
public void setNetworkConnectorURIs(String[] networkConnectorURIs)
public TransportConnector getConnectorByName(String connectorName)
public Map<String,String> getTransportConnectorURIsAsMap()
public String[] getTransportConnectorURIs()
public void setTransportConnectorURIs(String[] transportConnectorURIs)
public JmsConnector[] getJmsBridgeConnectors()
public void setJmsBridgeConnectors(JmsConnector[] jmsConnectors)
jmsConnectors
- The jmsBridgeConnectors to set.public Service[] getServices()
public void setServices(Service[] services)
MasterConnector
public void addService(Service service)
public void removeService(Service service)
public boolean isUseLoggingForShutdownErrors()
public void setUseLoggingForShutdownErrors(boolean useLoggingForShutdownErrors)
public boolean isUseShutdownHook()
public void setUseShutdownHook(boolean useShutdownHook)
public boolean isAdvisorySupport()
public void setAdvisorySupport(boolean advisorySupport)
public List<TransportConnector> getTransportConnectors()
public void setTransportConnectors(List<TransportConnector> transportConnectors) throws Exception
Exception
public List<NetworkConnector> getNetworkConnectors()
public List<ProxyConnector> getProxyConnectors()
public void setNetworkConnectors(List networkConnectors) throws Exception
Exception
public void setProxyConnectors(List proxyConnectors) throws Exception
Exception
public PolicyMap getDestinationPolicy()
public void setDestinationPolicy(PolicyMap policyMap)
public BrokerPlugin[] getPlugins()
public void setPlugins(BrokerPlugin[] plugins)
public MessageAuthorizationPolicy getMessageAuthorizationPolicy()
public void setMessageAuthorizationPolicy(MessageAuthorizationPolicy messageAuthorizationPolicy)
public void deleteAllMessages() throws IOException
IOException
public boolean isDeleteAllMessagesOnStartup()
public void setDeleteAllMessagesOnStartup(boolean deletePersistentMessagesOnStartup)
public URI getVmConnectorURI()
public void setVmConnectorURI(URI vmConnectorURI)
public boolean isShutdownOnMasterFailure()
public void setShutdownOnMasterFailure(boolean shutdownOnMasterFailure)
shutdownOnMasterFailure
- The shutdownOnMasterFailure to set.public boolean isKeepDurableSubsActive()
public void setKeepDurableSubsActive(boolean keepDurableSubsActive)
public boolean isUseVirtualTopics()
public void setUseVirtualTopics(boolean useVirtualTopics)
public DestinationInterceptor[] getDestinationInterceptors()
public boolean isUseMirroredQueues()
public void setUseMirroredQueues(boolean useMirroredQueues)
public void setDestinationInterceptors(DestinationInterceptor[] destinationInterceptors)
public ActiveMQDestination[] getDestinations()
public void setDestinations(ActiveMQDestination[] destinations)
public Store getTempDataStore()
public void setTempDataStore(Store tempDataStore)
tempDataStore
- the tempDataStore to setpublic int getPersistenceThreadPriority()
public void setPersistenceThreadPriority(int persistenceThreadPriority)
public boolean isUseLocalHostBrokerName()
public void setUseLocalHostBrokerName(boolean useLocalHostBrokerName)
useLocalHostBrokerName
- the useLocalHostBrokerName to setpublic boolean isSupportFailOver()
public void setSupportFailOver(boolean supportFailOver)
supportFailOver
- the supportFailOver to setpublic Destination getDestination(ActiveMQDestination destination) throws Exception
Exception
public void removeDestination(ActiveMQDestination destination) throws Exception
Exception
public int getProducerSystemUsagePortion()
public void setProducerSystemUsagePortion(int producerSystemUsagePortion)
public int getConsumerSystemUsagePortion()
public void setConsumerSystemUsagePortion(int consumerSystemUsagePortion)
public boolean isSplitSystemUsageForProducersConsumers()
public void setSplitSystemUsageForProducersConsumers(boolean splitSystemUsageForProducersConsumers)
public boolean isMonitorConnectionSplits()
public void setMonitorConnectionSplits(boolean monitorConnectionSplits)
public int getTaskRunnerPriority()
public void setTaskRunnerPriority(int taskRunnerPriority)
public boolean isDedicatedTaskRunner()
public void setDedicatedTaskRunner(boolean dedicatedTaskRunner)
public boolean isCacheTempDestinations()
public void setCacheTempDestinations(boolean cacheTempDestinations)
public int getTimeBeforePurgeTempDestinations()
public void setTimeBeforePurgeTempDestinations(int timeBeforePurgeTempDestinations)
public boolean isUseTempMirroredQueues()
public void setUseTempMirroredQueues(boolean useTempMirroredQueues)
protected void processHelperProperties() throws Exception
Exception
protected void stopAllConnectors(ServiceStopper stopper)
protected TransportConnector registerConnectorMBean(TransportConnector connector) throws IOException
IOException
protected void unregisterConnectorMBean(TransportConnector connector) throws IOException
IOException
protected PersistenceAdapter registerPersistenceAdapterMBean(PersistenceAdapter adaptor) throws IOException
IOException
protected void unregisterPersistenceAdapterMBean(PersistenceAdapter adaptor) throws IOException
IOException
protected void registerNetworkConnectorMBean(NetworkConnector connector) throws IOException
IOException
protected ObjectName createNetworkConnectorObjectName(NetworkConnector connector) throws MalformedObjectNameException
MalformedObjectNameException
protected void unregisterNetworkConnectorMBean(NetworkConnector connector)
protected void registerProxyConnectorMBean(ProxyConnector connector) throws IOException
IOException
protected void registerFTConnectorMBean(MasterConnector connector) throws IOException
IOException
protected void registerJmsConnectorMBean(JmsConnector connector) throws IOException
IOException
protected Broker createBroker() throws Exception
Exception
protected Broker createRegionBroker() throws Exception
Exception
protected Broker createRegionBroker(DestinationInterceptor destinationInterceptor) throws IOException
IOException
protected DestinationInterceptor[] createDefaultDestinationInterceptor()
protected Broker addInterceptors(Broker broker) throws Exception
IOException
Exception
protected PersistenceAdapter createPersistenceAdapter() throws IOException
IOException
protected AMQPersistenceAdapterFactory createPersistenceFactory()
protected ObjectName createBrokerObjectName() throws IOException
IOException
protected TransportConnector createTransportConnector(URI brokerURI) throws Exception
Exception
protected Object getPort(Map options)
protected void addShutdownHook()
protected void removeShutdownHook()
protected void containerShutdown()
protected void logError(String message, Throwable e)
protected void startDestinations() throws Exception
Exception
public ConnectionContext getAdminConnectionContext() throws Exception
Exception
protected ConnectionContext createAdminConnectionContext() throws Exception
Exception
protected void waitForSlave()
protected void slaveConnectionEstablished()
protected void startManagementContext() throws Exception
Exception
protected void startAllConnectors() throws Exception
Exception
protected TransportConnector startTransportConnector(TransportConnector connector) throws Exception
Exception
protected void configureServices(Object[] services)
protected void configureService(Object service)
public void handleIOException(IOException exception)
protected void startDestinationsInPersistenceStore(Broker broker) throws Exception
Exception
public Broker getRegionBroker()
public void setRegionBroker(Broker regionBroker)
public void addShutdownHook(Runnable hook)
public void removeShutdownHook(Runnable hook)
public boolean isSystemExitOnShutdown()
public void setSystemExitOnShutdown(boolean systemExitOnShutdown)
public int getSystemExitOnShutdownExitCode()
public void setSystemExitOnShutdownExitCode(int systemExitOnShutdownExitCode)
public SslContext getSslContext()
public void setSslContext(SslContext sslContext)
public boolean isShutdownOnSlaveFailure()
public void setShutdownOnSlaveFailure(boolean shutdownOnSlaveFailure)
public boolean isWaitForSlave()
public void setWaitForSlave(boolean waitForSlave)
public long getWaitForSlaveTimeout()
public void setWaitForSlaveTimeout(long waitForSlaveTimeout)
public CountDownLatch getSlaveStartSignal()
public boolean isPassiveSlave()
public void setPassiveSlave(boolean passiveSlave)
passiveSlave
- the passiveSlave to setpublic void setIoExceptionHandler(IOExceptionHandler ioExceptionHandler)
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |