Package org.apache.activemq.xbean

Class XBeanBrokerService

java.lang.Object
org.apache.activemq.broker.BrokerService
org.apache.activemq.xbean.XBeanBrokerService
All Implemented Interfaces:
org.apache.activemq.Service
public class XBeanBrokerService extends org.apache.activemq.broker.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_MAX_UNCOMMITTED_COUNT, 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, getMaxUncommittedCount, 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, isVirtualThreadTaskRunner, 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, setMaxUncommittedCount, 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, setVirtualThreadTaskRunner, 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 Details

    • XBeanBrokerService

      public XBeanBrokerService()

  • Method Details

    • afterPropertiesSet

      public void afterPropertiesSet() throws Exception
      Throws:
      Exception

    • shouldAutostart

      protected boolean shouldAutostart()
      Overrides:
      shouldAutostart in class org.apache.activemq.broker.BrokerService

    • destroy

      public void destroy() throws Exception
      Throws:
      Exception

    • stop

      public void stop() throws Exception
      Specified by:
      stop in interface org.apache.activemq.Service
      Overrides:
      stop in class org.apache.activemq.broker.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.