|
||||||||||
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 java.lang.String |
DEFAULT_BROKER_NAME
|
static java.lang.String |
DEFAULT_PORT
|
protected DestinationFactory |
destinationFactory
|
static java.lang.String |
LOCAL_HOST_NAME
|
protected java.util.concurrent.CountDownLatch |
slaveStartSignal
|
Constructor Summary | |
---|---|
BrokerService()
|
Method Summary | |
---|---|
TransportConnector |
addConnector(java.lang.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(java.net.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(java.lang.String discoveryAddress)
Adds a new network connector using the given discovery address |
NetworkConnector |
addNetworkConnector(java.net.URI discoveryAddress)
Adds a new network connector using the given discovery address |
ProxyConnector |
addProxyConnector(ProxyConnector connector)
|
ProxyConnector |
addProxyConnector(java.lang.String bindAddress)
Adds a new proxy connector using the given bind address |
ProxyConnector |
addProxyConnector(java.net.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(java.lang.Runnable hook)
|
void |
autoStart()
|
boolean |
checkQueueSize(java.lang.String queueName)
|
protected void |
checkSystemUsageLimits()
|
protected void |
configureService(java.lang.Object service)
Perform any custom dependency injection |
protected void |
configureServices(java.lang.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 Broker |
createBroker()
Factory method to create a new broker |
protected javax.management.ObjectName |
createBrokerObjectName()
|
protected DestinationInterceptor[] |
createDefaultDestinationInterceptor()
Create the default destination interceptor |
javax.management.ObjectName |
createDuplexNetworkConnectorObjectName(java.lang.String transport)
|
protected javax.management.ObjectName |
createNetworkConnectorObjectName(NetworkConnector connector)
|
protected PersistenceAdapter |
createPersistenceAdapter()
|
protected Broker |
createRegionBroker()
Factory method to create the core region broker onto which interceptors are added |
protected Broker |
createRegionBroker(DestinationInterceptor destinationInterceptor)
|
protected TransportConnector |
createTransportConnector(java.net.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 |
BrokerContext |
getBrokerContext()
|
java.io.File |
getBrokerDataDirectory()
|
java.lang.String |
getBrokerName()
|
javax.management.ObjectName |
getBrokerObjectName()
|
TransportConnector |
getConnectorByName(java.lang.String connectorName)
|
SystemUsage |
getConsumerSystemUsage()
|
int |
getConsumerSystemUsagePortion()
|
java.io.File |
getDataDirectoryFile()
|
java.lang.String |
getDefaultSocketURIString()
|
Destination |
getDestination(ActiveMQDestination destination)
Looks up and lazily creates if necessary the destination for the given JMS name |
DestinationInterceptor[] |
getDestinationInterceptors()
|
PolicyMap |
getDestinationPolicy()
|
ActiveMQDestination[] |
getDestinations()
|
protected java.util.concurrent.ThreadPoolExecutor |
getExecutor()
|
IOExceptionHandler |
getIoExceptionHandler()
|
JmsConnector[] |
getJmsBridgeConnectors()
|
ManagementContext |
getManagementContext()
|
java.lang.String |
getMasterConnectorURI()
|
int |
getMaxPurgedDestinationsPerSweep()
|
MessageAuthorizationPolicy |
getMessageAuthorizationPolicy()
|
NetworkConnector |
getNetworkConnectorByName(java.lang.String connectorName)
|
java.util.List<NetworkConnector> |
getNetworkConnectors()
|
java.lang.String[] |
getNetworkConnectorURIs()
|
int |
getOfflineDurableSubscriberTaskSchedule()
|
int |
getOfflineDurableSubscriberTimeout()
|
PersistenceAdapter |
getPersistenceAdapter()
|
PersistenceAdapterFactory |
getPersistenceFactory()
|
TaskRunnerFactory |
getPersistenceTaskRunnerFactory()
|
int |
getPersistenceThreadPriority()
|
BrokerPlugin[] |
getPlugins()
|
protected java.lang.Object |
getPort(java.util.Map options)
Extracts the port from the options |
SystemUsage |
getProducerSystemUsage()
|
int |
getProducerSystemUsagePortion()
|
java.util.List<ProxyConnector> |
getProxyConnectors()
|
Broker |
getRegionBroker()
|
int |
getSchedulePeriodForDestinationPurge()
|
Scheduler |
getScheduler()
|
java.io.File |
getSchedulerDirectoryFile()
|
Service[] |
getServices()
|
java.util.concurrent.CountDownLatch |
getSlaveStartSignal()
|
SslContext |
getSslContext()
|
int |
getSystemExitOnShutdownExitCode()
|
SystemUsage |
getSystemUsage()
|
TaskRunnerFactory |
getTaskRunnerFactory()
|
int |
getTaskRunnerPriority()
|
PListStore |
getTempDataStore()
|
int |
getTimeBeforePurgeTempDestinations()
|
java.io.File |
getTmpDataDirectory()
|
TransportConnector |
getTransportConnectorByName(java.lang.String name)
|
TransportConnector |
getTransportConnectorByScheme(java.lang.String scheme)
|
java.util.List<TransportConnector> |
getTransportConnectors()
|
java.lang.String[] |
getTransportConnectorURIs()
|
java.util.Map<java.lang.String,java.lang.String> |
getTransportConnectorURIsAsMap()
|
java.net.URI |
getVmConnectorURI()
|
long |
getWaitForSlaveTimeout()
|
void |
handleIOException(java.io.IOException exception)
|
boolean |
isAdvisorySupport()
|
boolean |
isAllowTempAutoCreationOnSend()
|
boolean |
isCacheTempDestinations()
|
boolean |
isDedicatedTaskRunner()
|
boolean |
isDeleteAllMessagesOnStartup()
|
boolean |
isEnableStatistics()
|
boolean |
isKeepDurableSubsActive()
|
boolean |
isMonitorConnectionSplits()
|
boolean |
isNetworkConnectorStartAsync()
|
boolean |
isPassiveSlave()
Get the passiveSlave |
boolean |
isPersistent()
|
boolean |
isPopulateJMSXUserID()
|
boolean |
isPopulateUserNameInMBeans()
Should MBeans that support showing the Authenticated User Name information have this value filled in or not. |
boolean |
isSchedulerSupport()
|
boolean |
isShutdownOnMasterFailure()
|
boolean |
isShutdownOnSlaveFailure()
|
boolean |
isSlave()
|
boolean |
isSplitSystemUsageForProducersConsumers()
|
boolean |
isStarted()
|
boolean |
isSupportFailOver()
|
boolean |
isSystemExitOnShutdown()
|
boolean |
isUseAuthenticatedPrincipalForJMSXUserID()
|
boolean |
isUseJmx()
|
boolean |
isUseLocalHostBrokerName()
|
boolean |
isUseLoggingForShutdownErrors()
|
boolean |
isUseMirroredQueues()
|
boolean |
isUseShutdownHook()
|
boolean |
isUseTempMirroredQueues()
|
boolean |
isUseVirtualTopics()
|
boolean |
isWaitForSlave()
|
protected void |
logError(java.lang.String message,
java.lang.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(java.lang.Runnable hook)
|
void |
setAdminView(BrokerView adminView)
|
void |
setAdvisorySupport(boolean advisorySupport)
Allows the support of advisory messages to be disabled for performance reasons. |
void |
setAllowTempAutoCreationOnSend(boolean allowTempAutoCreationOnSend)
enable if temp destinations need to be propagated through a network when advisorySupport==false. |
void |
setBrokerContext(BrokerContext brokerContext)
|
void |
setBrokerId(java.lang.String brokerId)
|
void |
setBrokerName(java.lang.String brokerName)
Sets the name of this broker; which must be unique in the network |
void |
setBrokerObjectName(javax.management.ObjectName brokerObjectName)
Sets the JMX ObjectName for this broker |
void |
setCacheTempDestinations(boolean cacheTempDestinations)
|
void |
setConsumerSystemUsage(SystemUsage consumerSystemUsaage)
|
void |
setConsumerSystemUsagePortion(int consumerSystemUsagePortion)
|
void |
setDataDirectory(java.lang.String dataDirectory)
Sets the directory in which the data files will be stored by default for the JDBC and Journal persistence adaptors. |
void |
setDataDirectoryFile(java.io.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)
override the Default IOException handler, called when persistence adapter has experiences File or JDBC I/O Exceptions |
void |
setJmsBridgeConnectors(JmsConnector[] jmsConnectors)
|
void |
setKeepDurableSubsActive(boolean keepDurableSubsActive)
|
void |
setManagementContext(ManagementContext managementContext)
|
void |
setMasterConnectorURI(java.lang.String masterConnectorURI)
|
void |
setMaxPurgedDestinationsPerSweep(int maxPurgedDestinationsPerSweep)
|
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(java.util.List networkConnectors)
Sets the network connectors which this broker will use to connect to other brokers in a federated network |
void |
setNetworkConnectorStartAsync(boolean networkConnectorStartAsync)
|
void |
setNetworkConnectorURIs(java.lang.String[] networkConnectorURIs)
|
void |
setOfflineDurableSubscriberTaskSchedule(int offlineDurableSubscriberTaskSchedule)
|
void |
setOfflineDurableSubscriberTimeout(int offlineDurableSubscriberTimeout)
|
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 |
setPopulateUserNameInMBeans(boolean value)
Sets whether Authenticated User Name information is shown in MBeans that support this field. |
void |
setProducerSystemUsage(SystemUsage producerUsageManager)
|
void |
setProducerSystemUsagePortion(int producerSystemUsagePortion)
|
void |
setProxyConnectors(java.util.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 |
setSchedulePeriodForDestinationPurge(int schedulePeriodForDestinationPurge)
|
void |
setSchedulerDirectory(java.lang.String schedulerDirectory)
|
void |
setSchedulerDirectoryFile(java.io.File schedulerDirectory)
|
void |
setSchedulerSupport(boolean schedulerSupport)
|
void |
setServices(Service[] services)
Sets the services associated with this broker such as a MasterConnector |
void |
setShutdownHooks(java.util.List<java.lang.Runnable> hooks)
Sets hooks to be executed when broker shut down |
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(PListStore tempDataStore)
|
void |
setTimeBeforePurgeTempDestinations(int timeBeforePurgeTempDestinations)
|
void |
setTmpDataDirectory(java.io.File tmpDataDirectory)
|
void |
setTransportConnectors(java.util.List<TransportConnector> transportConnectors)
Sets the transport connectors which this broker will listen on for new clients |
void |
setTransportConnectorURIs(java.lang.String[] transportConnectorURIs)
|
void |
setUseAuthenticatedPrincipalForJMSXUserID(boolean useAuthenticatedPrincipalForJMSXUserID)
|
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(java.net.URI vmConnectorURI)
|
void |
setWaitForSlave(boolean waitForSlave)
|
void |
setWaitForSlaveTimeout(long waitForSlaveTimeout)
|
protected boolean |
shouldAutostart()
|
boolean |
shouldRecordVirtualDestination(ActiveMQDestination destination)
|
protected void |
slaveConnectionEstablished()
|
void |
start()
|
void |
start(boolean force)
Forces a start of the broker. |
void |
startAllConnectors()
Start all transport and network connections, proxies and bridges |
protected void |
startDestinations()
Starts any configured destinations on startup |
protected void |
startManagementContext()
|
protected TransportConnector |
startTransportConnector(TransportConnector connector)
|
protected void |
startVirtualConsumerDestinations()
|
void |
stop()
|
void |
stopAllConnectors(ServiceStopper stopper)
|
void |
stopGracefully(java.lang.String connectorName,
java.lang.String queueName,
long timeout,
long pollInterval)
This method (both connectorName and queueName are using regex to match) 1. |
java.lang.String |
toString()
|
protected void |
unregisterConnectorMBean(TransportConnector connector)
|
protected void |
unregisterNetworkConnectorMBean(NetworkConnector connector)
|
protected void |
unregisterPersistenceAdapterMBean(PersistenceAdapter adaptor)
|
protected void |
waitForSlave()
|
boolean |
waitUntilStarted()
A helper method to block the caller thread until the broker has fully 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 java.util.concurrent.CountDownLatch slaveStartSignal
public static final java.lang.String DEFAULT_PORT
public static final java.lang.String LOCAL_HOST_NAME
public static final java.lang.String DEFAULT_BROKER_NAME
protected DestinationFactory destinationFactory
Constructor Detail |
---|
public BrokerService()
Method Detail |
---|
public java.lang.String toString()
toString
in class java.lang.Object
public TransportConnector addConnector(java.lang.String bindAddress) throws java.lang.Exception
java.lang.Exception
public TransportConnector addConnector(java.net.URI bindAddress) throws java.lang.Exception
java.lang.Exception
public TransportConnector addConnector(TransportServer transport) throws java.lang.Exception
java.lang.Exception
public TransportConnector addConnector(TransportConnector connector) throws java.lang.Exception
java.lang.Exception
public boolean removeConnector(TransportConnector connector) throws java.lang.Exception
connector
-
java.lang.Exception
public NetworkConnector addNetworkConnector(java.lang.String discoveryAddress) throws java.lang.Exception
java.lang.Exception
public ProxyConnector addProxyConnector(java.lang.String bindAddress) throws java.lang.Exception
java.lang.Exception
public NetworkConnector addNetworkConnector(java.net.URI discoveryAddress) throws java.lang.Exception
java.lang.Exception
public ProxyConnector addProxyConnector(java.net.URI bindAddress) throws java.lang.Exception
java.lang.Exception
public NetworkConnector addNetworkConnector(NetworkConnector connector) throws java.lang.Exception
java.lang.Exception
public boolean removeNetworkConnector(NetworkConnector connector)
NetworkConnector.stop()
to close the connector
public ProxyConnector addProxyConnector(ProxyConnector connector) throws java.lang.Exception
java.lang.Exception
public JmsConnector addJmsConnector(JmsConnector connector) throws java.lang.Exception
java.lang.Exception
public JmsConnector removeJmsConnector(JmsConnector connector)
public java.lang.String getMasterConnectorURI()
public void setMasterConnectorURI(java.lang.String masterConnectorURI)
masterConnectorURI
- The masterConnectorURI to set.public boolean isSlave()
public void masterFailed()
public boolean isStarted()
public void start(boolean force) throws java.lang.Exception
force
- - if true enforces a restart.
java.lang.Exception
protected boolean shouldAutostart()
@PostConstruct public void autoStart() throws java.lang.Exception
java.lang.Exception
public void start() throws java.lang.Exception
start
in interface Service
java.lang.Exception
@PreDestroy public void stop() throws java.lang.Exception
stop
in interface Service
java.lang.Exception
public boolean checkQueueSize(java.lang.String queueName)
public void stopGracefully(java.lang.String connectorName, java.lang.String queueName, long timeout, long pollInterval) throws java.lang.Exception
connectorName
- queueName
- timeout
- pollInterval
-
java.lang.Exception
public void waitUntilStopped()
public boolean waitUntilStarted()
public Broker getBroker() throws java.lang.Exception
java.lang.Exception
public BrokerView getAdminView() throws java.lang.Exception
java.lang.Exception
public void setAdminView(BrokerView adminView)
public java.lang.String getBrokerName()
public void setBrokerName(java.lang.String brokerName)
brokerName
- public PersistenceAdapterFactory getPersistenceFactory()
public java.io.File getDataDirectoryFile()
public java.io.File getBrokerDataDirectory()
public void setDataDirectory(java.lang.String dataDirectory)
dataDirectory
- the directory to store data filespublic void setDataDirectoryFile(java.io.File dataDirectoryFile)
dataDirectoryFile
- the directory to store data filespublic java.io.File getTmpDataDirectory()
public void setTmpDataDirectory(java.io.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 java.io.IOException
java.io.IOException
public void setConsumerSystemUsage(SystemUsage consumerSystemUsaage)
consumerSystemUsaage
- the storeSystemUsage to setpublic SystemUsage getProducerSystemUsage() throws java.io.IOException
java.io.IOException
public void setProducerSystemUsage(SystemUsage producerUsageManager)
producerUsageManager
- the producerUsageManager to setpublic PersistenceAdapter getPersistenceAdapter() throws java.io.IOException
java.io.IOException
public void setPersistenceAdapter(PersistenceAdapter persistenceAdapter) throws java.io.IOException
java.io.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 javax.management.ObjectName getBrokerObjectName() throws java.io.IOException
java.io.IOException
public void setBrokerObjectName(javax.management.ObjectName brokerObjectName)
public ManagementContext getManagementContext()
public void setManagementContext(ManagementContext managementContext)
public NetworkConnector getNetworkConnectorByName(java.lang.String connectorName)
public java.lang.String[] getNetworkConnectorURIs()
public void setNetworkConnectorURIs(java.lang.String[] networkConnectorURIs)
public TransportConnector getConnectorByName(java.lang.String connectorName)
public java.util.Map<java.lang.String,java.lang.String> getTransportConnectorURIsAsMap()
public java.lang.String[] getTransportConnectorURIs()
public void setTransportConnectorURIs(java.lang.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 java.util.List<TransportConnector> getTransportConnectors()
public void setTransportConnectors(java.util.List<TransportConnector> transportConnectors) throws java.lang.Exception
java.lang.Exception
public TransportConnector getTransportConnectorByName(java.lang.String name)
public TransportConnector getTransportConnectorByScheme(java.lang.String scheme)
public java.util.List<NetworkConnector> getNetworkConnectors()
public java.util.List<ProxyConnector> getProxyConnectors()
public void setNetworkConnectors(java.util.List networkConnectors) throws java.lang.Exception
java.lang.Exception
public void setProxyConnectors(java.util.List proxyConnectors) throws java.lang.Exception
java.lang.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 java.io.IOException
java.io.IOException
public boolean isDeleteAllMessagesOnStartup()
public void setDeleteAllMessagesOnStartup(boolean deletePersistentMessagesOnStartup)
public java.net.URI getVmConnectorURI()
public void setVmConnectorURI(java.net.URI vmConnectorURI)
public java.lang.String getDefaultSocketURIString()
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 PListStore getTempDataStore()
public void setTempDataStore(PListStore 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 java.lang.Exception
java.lang.Exception
public void removeDestination(ActiveMQDestination destination) throws java.lang.Exception
java.lang.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 java.lang.Exception
java.lang.Exception
protected void checkSystemUsageLimits() throws java.io.IOException
java.io.IOException
public void stopAllConnectors(ServiceStopper stopper)
protected TransportConnector registerConnectorMBean(TransportConnector connector) throws java.io.IOException
java.io.IOException
protected void unregisterConnectorMBean(TransportConnector connector) throws java.io.IOException
java.io.IOException
protected PersistenceAdapter registerPersistenceAdapterMBean(PersistenceAdapter adaptor) throws java.io.IOException
java.io.IOException
protected void unregisterPersistenceAdapterMBean(PersistenceAdapter adaptor) throws java.io.IOException
java.io.IOException
protected void registerNetworkConnectorMBean(NetworkConnector connector) throws java.io.IOException
java.io.IOException
protected javax.management.ObjectName createNetworkConnectorObjectName(NetworkConnector connector) throws javax.management.MalformedObjectNameException
javax.management.MalformedObjectNameException
public javax.management.ObjectName createDuplexNetworkConnectorObjectName(java.lang.String transport) throws javax.management.MalformedObjectNameException
javax.management.MalformedObjectNameException
protected void unregisterNetworkConnectorMBean(NetworkConnector connector)
protected void registerProxyConnectorMBean(ProxyConnector connector) throws java.io.IOException
java.io.IOException
protected void registerFTConnectorMBean(MasterConnector connector) throws java.io.IOException
java.io.IOException
protected void registerJmsConnectorMBean(JmsConnector connector) throws java.io.IOException
java.io.IOException
protected Broker createBroker() throws java.lang.Exception
java.lang.Exception
protected Broker createRegionBroker() throws java.lang.Exception
java.lang.Exception
protected Broker createRegionBroker(DestinationInterceptor destinationInterceptor) throws java.io.IOException
java.io.IOException
protected DestinationInterceptor[] createDefaultDestinationInterceptor()
protected Broker addInterceptors(Broker broker) throws java.lang.Exception
java.io.IOException
java.lang.Exception
protected PersistenceAdapter createPersistenceAdapter() throws java.io.IOException
java.io.IOException
protected javax.management.ObjectName createBrokerObjectName() throws java.io.IOException
java.io.IOException
protected TransportConnector createTransportConnector(java.net.URI brokerURI) throws java.lang.Exception
java.lang.Exception
protected java.lang.Object getPort(java.util.Map options)
protected void addShutdownHook()
protected void removeShutdownHook()
public void setShutdownHooks(java.util.List<java.lang.Runnable> hooks) throws java.lang.Exception
java.lang.Exception
protected void containerShutdown()
protected void logError(java.lang.String message, java.lang.Throwable e)
protected void startDestinations() throws java.lang.Exception
java.lang.Exception
public ConnectionContext getAdminConnectionContext() throws java.lang.Exception
java.lang.Exception
protected void waitForSlave()
protected void slaveConnectionEstablished()
protected void startManagementContext() throws java.lang.Exception
java.lang.Exception
public void startAllConnectors() throws java.lang.Exception
java.lang.Exception
protected TransportConnector startTransportConnector(TransportConnector connector) throws java.lang.Exception
java.lang.Exception
protected void configureServices(java.lang.Object[] services)
protected void configureService(java.lang.Object service)
public void handleIOException(java.io.IOException exception)
protected void startVirtualConsumerDestinations() throws java.lang.Exception
java.lang.Exception
protected java.util.concurrent.ThreadPoolExecutor getExecutor()
public Scheduler getScheduler()
public Broker getRegionBroker()
public void setRegionBroker(Broker regionBroker)
public void addShutdownHook(java.lang.Runnable hook)
public void removeShutdownHook(java.lang.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 java.util.concurrent.CountDownLatch getSlaveStartSignal()
public boolean isPassiveSlave()
public void setPassiveSlave(boolean passiveSlave)
passiveSlave
- the passiveSlave to setpublic void setIoExceptionHandler(IOExceptionHandler ioExceptionHandler)
ioExceptionHandler
- public IOExceptionHandler getIoExceptionHandler()
public boolean isSchedulerSupport()
public void setSchedulerSupport(boolean schedulerSupport)
schedulerSupport
- the schedulerSupport to setpublic java.io.File getSchedulerDirectoryFile()
public void setSchedulerDirectoryFile(java.io.File schedulerDirectory)
schedulerDirectory
- the schedulerDirectory to setpublic void setSchedulerDirectory(java.lang.String schedulerDirectory)
public int getSchedulePeriodForDestinationPurge()
public void setSchedulePeriodForDestinationPurge(int schedulePeriodForDestinationPurge)
public int getMaxPurgedDestinationsPerSweep()
public void setMaxPurgedDestinationsPerSweep(int maxPurgedDestinationsPerSweep)
public BrokerContext getBrokerContext()
public void setBrokerContext(BrokerContext brokerContext)
public void setBrokerId(java.lang.String brokerId)
public boolean isUseAuthenticatedPrincipalForJMSXUserID()
public void setUseAuthenticatedPrincipalForJMSXUserID(boolean useAuthenticatedPrincipalForJMSXUserID)
public boolean isPopulateUserNameInMBeans()
public void setPopulateUserNameInMBeans(boolean value)
true
- if MBeans should expose user name information.public boolean isNetworkConnectorStartAsync()
public void setNetworkConnectorStartAsync(boolean networkConnectorStartAsync)
public boolean isAllowTempAutoCreationOnSend()
public void setAllowTempAutoCreationOnSend(boolean allowTempAutoCreationOnSend)
allowTempAutoCreationOnSend
- public int getOfflineDurableSubscriberTimeout()
public void setOfflineDurableSubscriberTimeout(int offlineDurableSubscriberTimeout)
public int getOfflineDurableSubscriberTaskSchedule()
public void setOfflineDurableSubscriberTaskSchedule(int offlineDurableSubscriberTaskSchedule)
public boolean shouldRecordVirtualDestination(ActiveMQDestination destination)
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |