Package org.apache.activemq.xbean

Class XBeanBrokerService

java.lang.Object

org.apache.activemq.broker.BrokerService

org.apache.activemq.xbean.XBeanBrokerService

All Implemented Interfaces:

Service

public class XBeanBrokerService
extends BrokerService

An ActiveMQ Message Broker. It 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

Fields inherited from class org.apache.activemq.broker.BrokerService

BROKER_VERSION, DEFAULT_BROKER_NAME, DEFAULT_MAX_FILE_LENGTH, DEFAULT_PORT, DEFAULT_START_TIMEOUT, destinationFactory, LOCAL_HOST_NAME, MAX_SCHEDULER_REPEAT_ALLOWED

Constructor Summary

Constructors

Constructor	Description
XBeanBrokerService()

Method Summary

Modifier and Type	Method	Description
void	afterPropertiesSet()
void	destroy()
void	setStart(boolean start)	Sets whether or not the broker is started along with the ApplicationContext it is defined within.
protected boolean	shouldAutostart()
void	stop()

Methods inherited from class org.apache.activemq.broker.BrokerService

addConnector, addConnector, addConnector, addConnector, addInterceptors, addJmsConnector, addNetworkConnector, addNetworkConnector, addNetworkConnector, addPreShutdownHook, addProxyConnector, addProxyConnector, addProxyConnector, addService, addShutdownHook, addShutdownHook, autoStart, checkMemorySystemUsageLimits, checkQueueSize, checkStoreSystemUsageLimits, checkStoreUsageLimits, checkTmpStoreUsageLimits, checkUsageLimit, configureService, configureServices, containerShutdown, createBroker, createBrokerObjectName, createDefaultDestinationInterceptor, createDuplexNetworkConnectorObjectName, createNetworkConnectorObjectName, createPersistenceAdapter, createRegionBroker, createRegionBroker, createTransportConnector, decrementCurrentConnections, deleteAllMessages, getAdminConnectionContext, getAdminView, getBroker, getBrokerContext, getBrokerDataDirectory, getBrokerName, getBrokerObjectName, getConnectorByName, getConsumerSystemUsage, getConsumerSystemUsagePortion, getCurrentConnections, getDataDirectoryFile, getDefaultSocketURIString, getDestination, getDestinationInterceptors, getDestinationPolicy, getDestinations, getDiskUsageCheckRegrowThreshold, getExecutor, getIoExceptionHandler, getJmsBridgeConnectors, getJobSchedulerStore, getManagementContext, getMaxPurgedDestinationsPerSweep, getMaxSchedulerRepeatAllowed, getMbeanInvocationTimeout, getMessageAuthorizationPolicy, getNetworkConnectorByName, getNetworkConnectors, getNetworkConnectorURIs, getOfflineDurableSubscriberTaskSchedule, getOfflineDurableSubscriberTimeout, getPersistenceAdapter, getPersistenceFactory, getPersistenceTaskRunnerFactory, getPersistenceThreadPriority, getPlugins, getPort, getProducerBrokerExchange, getProducerSystemUsage, getProducerSystemUsagePortion, getProxyConnectors, getRegionBroker, getSchedulePeriodForDestinationPurge, getScheduler, getSchedulerDirectoryFile, getServices, getSslContext, getStartException, getStoreOpenWireVersion, getSystemExitOnShutdownExitCode, getSystemUsage, getTaskRunnerFactory, getTaskRunnerPriority, getTempDataStore, getTimeBeforePurgeTempDestinations, getTmpDataDirectory, getTotalConnections, getTransportConnectorByName, getTransportConnectorByScheme, getTransportConnectors, getTransportConnectorURIs, getTransportConnectorURIsAsMap, getUptime, getUptimeMillis, getVmConnectorURI, getWaitForSlaveTimeout, handleIOException, incrementCurrentConnections, incrementTotalConnections, isAdjustUsageLimits, isAdvisorySupport, isAllowTempAutoCreationOnSend, isAnonymousProducerAdvisorySupport, isCacheTempDestinations, isDedicatedTaskRunner, isDeleteAllMessagesOnStartup, isEnableMessageExpirationOnActiveDurableSubs, isEnableStatistics, isKeepDurableSubsActive, isMonitorConnectionSplits, isNetworkConnectorStartAsync, isPassiveSlave, isPersistent, isPopulateJMSXUserID, isPopulateUserNameInMBeans, isRejectDurableConsumers, isRestartAllowed, isRestartRequested, isRollbackOnlyOnAsyncException, isSchedulerSupport, isShutdownOnMasterFailure, isShutdownOnSlaveFailure, isSlave, isSplitSystemUsageForProducersConsumers, isStartAsync, isStarted, isStopped, isStopping, isSystemExitOnShutdown, isUseAuthenticatedPrincipalForJMSXUserID, isUseJmx, isUseLocalHostBrokerName, isUseLoggingForShutdownErrors, isUseMirroredQueues, isUseShutdownHook, isUseTempMirroredQueues, isUseVirtualDestSubs, isUseVirtualDestSubsOnCreation, isUseVirtualTopics, isWaitForSlave, logError, masterFailed, processHelperProperties, registerConnectorMBean, registerJmsConnectorMBean, registerNetworkConnectorMBean, registerPersistenceAdapterMBean, registerProxyConnectorMBean, removeConnector, removeDestination, removeJmsConnector, removeNetworkConnector, removePreShutdownHook, removeService, removeShutdownHook, removeShutdownHook, requestRestart, scheduleDiskUsageLimitsCheck, setAdjustUsageLimits, setAdminView, setAdvisorySupport, setAllowTempAutoCreationOnSend, setAnonymousProducerAdvisorySupport, setBrokerContext, setBrokerId, setBrokerName, setBrokerObjectName, setCacheTempDestinations, setConsumerSystemUsage, setConsumerSystemUsagePortion, setDataDirectory, setDataDirectoryFile, setDedicatedTaskRunner, setDeleteAllMessagesOnStartup, setDestinationFactory, setDestinationInterceptors, setDestinationPolicy, setDestinations, setDiskUsageCheckRegrowThreshold, setEnableMessageExpirationOnActiveDurableSubs, setEnableStatistics, setIoExceptionHandler, setJmsBridgeConnectors, setJobSchedulerStore, setKeepDurableSubsActive, setManagementContext, setMaxPurgedDestinationsPerSweep, setMaxSchedulerRepeatAllowed, setMbeanInvocationTimeout, setMessageAuthorizationPolicy, setMonitorConnectionSplits, setNetworkConnectors, setNetworkConnectorStartAsync, setNetworkConnectorURIs, setOfflineDurableSubscriberTaskSchedule, setOfflineDurableSubscriberTimeout, setPassiveSlave, setPersistenceAdapter, setPersistenceFactory, setPersistenceTaskRunnerFactory, setPersistenceThreadPriority, setPersistent, setPlugins, setPopulateJMSXUserID, setPopulateUserNameInMBeans, setProducerSystemUsage, setProducerSystemUsagePortion, setProxyConnectors, setRegionBroker, setRejectDurableConsumers, setRestartAllowed, setRollbackOnlyOnAsyncException, setSchedulePeriodForDestinationPurge, setSchedulePeriodForDiskUsageCheck, setSchedulerDirectory, setSchedulerDirectoryFile, setSchedulerSupport, setServices, setShutdownHooks, setShutdownOnMasterFailure, setShutdownOnSlaveFailure, setSplitSystemUsageForProducersConsumers, setSslContext, setStartAsync, setStoreOpenWireVersion, setSystemExitOnShutdown, setSystemExitOnShutdownExitCode, setSystemUsage, setTaskRunnerFactory, setTaskRunnerPriority, setTempDataStore, setTimeBeforePurgeTempDestinations, setTmpDataDirectory, setTransportConnectors, setTransportConnectorURIs, setUseAuthenticatedPrincipalForJMSXUserID, setUseJmx, setUseLocalHostBrokerName, setUseLoggingForShutdownErrors, setUseMirroredQueues, setUseShutdownHook, setUseTempMirroredQueues, setUseVirtualDestSubs, setUseVirtualDestSubsOnCreation, setUseVirtualTopics, setVmConnectorURI, setWaitForSlave, setWaitForSlaveTimeout, shouldRecordVirtualDestination, start, start, startAllConnectors, startDestinations, startManagementContext, startNetworkConnector, startNetworkConnector, startTransportConnector, startVirtualConsumerDestinations, stopAllConnectors, stopGracefully, toString, unregisterConnectorMBean, unregisterNetworkConnectorMBean, unregisterPersistenceAdapterMBean, waitUntilStarted, waitUntilStarted, waitUntilStopped

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

XBeanBrokerService

public XBeanBrokerService()

Method Detail

afterPropertiesSet

public void afterPropertiesSet()
                        throws Exception

Throws:

Exception

shouldAutostart

protected boolean shouldAutostart()

Overrides:

shouldAutostart in class BrokerService

destroy

public void destroy()
             throws Exception

Throws:

Exception

stop

public void stop()
          throws Exception

Specified by:

stop in interface Service

Overrides:

stop in class BrokerService

Throws:

Exception

setStart

public void setStart(boolean start)

Sets whether or not the broker is started along with the ApplicationContext it is defined within. Normally you would want the broker to start up along with the ApplicationContext but sometimes when working with JUnit tests you may wish to start and stop the broker explicitly yourself.