Modifier and Type | Method and Description |
---|---|
Configuration |
Configuration.addAcceptorConfiguration(String name,
String uri)
Add an acceptor to the config
|
Configuration |
Configuration.addAcceptorConfiguration(TransportConfiguration infos) |
Configuration |
Configuration.addAddressesSetting(String key,
AddressSettings addressesSetting) |
Configuration |
Configuration.addBroadcastGroupConfiguration(BroadcastGroupConfiguration config) |
Configuration |
Configuration.addClusterConfiguration(ClusterConnectionConfiguration config) |
Configuration |
Configuration.addConnectorConfiguration(String name,
String uri) |
Configuration |
Configuration.addConnectorConfiguration(String key,
TransportConfiguration info) |
Configuration |
Configuration.addConnectorServiceConfiguration(ConnectorServiceConfiguration config) |
Configuration |
Configuration.addDiscoveryGroupConfiguration(String key,
DiscoveryGroupConfiguration discoveryGroupConfiguration) |
Configuration |
Configuration.addDivertConfiguration(DivertConfiguration config) |
Configuration |
Configuration.addQueueConfiguration(CoreQueueConfiguration config) |
Configuration |
Configuration.addResourceLimitSettings(ResourceLimitSettings resourceLimitSettings) |
Configuration |
Configuration.clearAcceptorConfigurations() |
Configuration |
Configuration.clearAddressesSettings() |
Configuration |
Configuration.clearClusterConfigurations() |
Configuration |
Configuration.clearConnectorConfigurations() |
Configuration |
Configuration.copy() |
Configuration |
Configuration.setAcceptorConfigurations(Set<TransportConfiguration> infos)
Sets the acceptors configured for this server.
|
Configuration |
Configuration.setAddressesSettings(Map<String,AddressSettings> addressesSettings) |
Configuration |
Configuration.setBindingsDirectory(String dir)
Sets the file system directory used to store bindings.
|
Configuration |
Configuration.setBridgeConfigurations(List<BridgeConfiguration> configs)
Sets the bridges configured for this server.
|
Configuration |
Configuration.setBroadcastGroupConfigurations(List<BroadcastGroupConfiguration> configs)
Sets the broadcast groups configured for this server.
|
Configuration |
Configuration.setClusterConfigurations(List<ClusterConnectionConfiguration> configs)
Sets the cluster connections configured for this server.
|
Configuration |
Configuration.setClusterPassword(String password)
Sets the cluster password for this server.
|
Configuration |
Configuration.setClusterUser(String user)
Sets the cluster user for this server.
|
Configuration |
Configuration.setConnectionTTLOverride(long ttl)
Sets the connection time to live.
|
Configuration |
Configuration.setConnectorConfigurations(Map<String,TransportConfiguration> infos)
Sets the connectors configured for this server.
|
Configuration |
Configuration.setConnectorServiceConfigurations(List<ConnectorServiceConfiguration> configs) |
Configuration |
Configuration.setCreateBindingsDir(boolean create)
Sets whether the bindings directory is created on this server startup.
|
Configuration |
Configuration.setCreateJournalDir(boolean create)
Sets whether the journal directory is created on this server startup.
|
Configuration |
Configuration.setDiscoveryGroupConfigurations(Map<String,DiscoveryGroupConfiguration> configs)
Sets the discovery groups configured for this server.
|
Configuration |
Configuration.setDivertConfigurations(List<DivertConfiguration> configs)
Sets the diverts configured for this server.
|
Configuration |
Configuration.setEnabledAsyncConnectionExecution(boolean enabled)
Sets whether code coming from connection is executed asynchronously or not.
|
Configuration |
Configuration.setFileDeployerScanPeriod(long period)
Sets the period to scan configuration files used by deployment.
|
Configuration |
Configuration.setGracefulShutdownEnabled(boolean enabled)
Sets whether security is enabled for this server.
|
Configuration |
Configuration.setGracefulShutdownTimeout(long timeout)
Sets the graceful shutdown timeout
|
Configuration |
Configuration.setGroupingHandlerConfiguration(GroupingHandlerConfiguration groupingHandlerConfiguration)
Sets the grouping handler configured for this server.
|
Configuration |
Configuration.setHAPolicyConfiguration(HAPolicyConfiguration haPolicyConfiguration) |
Configuration |
Configuration.setIDCacheSize(int idCacheSize)
Sets the size of the cache for pre-creating message IDs.
|
Configuration |
Configuration.setIncomingInterceptorClassNames(List<String> interceptors)
Sets the list of interceptors classes used by this server for incoming messages (i.e.
|
Configuration |
Configuration.setJMXDomain(String domain)
Sets the domain used by JMX MBeans (provided JMX management is enabled).
|
Configuration |
Configuration.setJMXManagementEnabled(boolean enabled)
Sets whether this server is manageable using JMX or not.
|
Configuration |
Configuration.setJournalBufferSize_AIO(int journalBufferSize)
Sets the buffer size (in bytes) for AIO.
|
Configuration |
Configuration.setJournalBufferSize_NIO(int journalBufferSize)
Sets the buffer size (in bytes) for NIO.
|
Configuration |
Configuration.setJournalBufferTimeout_AIO(int journalBufferTimeout)
Sets the timeout (in nanoseconds) used to flush buffers in the AIO queue.
|
Configuration |
Configuration.setJournalBufferTimeout_NIO(int journalBufferTimeout)
Sets the timeout (in nanoseconds) used to flush buffers in the NIO.
|
Configuration |
Configuration.setJournalCompactMinFiles(int minFiles)
Sets the minimal number of journal files before compacting.
|
Configuration |
Configuration.setJournalCompactPercentage(int percentage)
Sets the percentage of live data before compacting the journal.
|
Configuration |
Configuration.setJournalDirectory(String dir)
Sets the file system directory used to store journal log.
|
Configuration |
Configuration.setJournalFileSize(int size)
Sets the size (in bytes) of each journal files.
|
Configuration |
Configuration.setJournalLockAcquisitionTimeout(long journalLockAcquisitionTimeout) |
Configuration |
Configuration.setJournalMaxIO_AIO(int journalMaxIO)
Sets the maximum number of write requests that can be in the AIO queue at any given time.
|
Configuration |
Configuration.setJournalMaxIO_NIO(int journalMaxIO)
Sets the maximum number of write requests for NIO journal.
|
Configuration |
Configuration.setJournalMinFiles(int files)
Sets the number of journal files to pre-create.
|
Configuration |
Configuration.setJournalPerfBlastPages(int pages) |
Configuration |
Configuration.setJournalPoolFiles(int poolSize)
Number of files that would be acceptable to keep on a pool.
|
Configuration |
Configuration.setJournalSyncNonTransactional(boolean sync)
Sets whether the journal is synchronized when receiving non-transactional data.
|
Configuration |
Configuration.setJournalSyncTransactional(boolean sync)
Sets whether the journal is synchronized when receiving transactional data.
|
Configuration |
Configuration.setJournalType(JournalType type)
Sets the type of journal used by this server (either
NIO or ASYNCIO ). |
Configuration |
Configuration.setLargeMessagesDirectory(String directory)
Sets the file system directory used to store large messages.
|
Configuration |
Configuration.setLogJournalWriteRate(boolean rate) |
Configuration |
Configuration.setManagementAddress(SimpleString address)
Sets the management address of this server.
|
Configuration |
Configuration.setManagementNotificationAddress(SimpleString address)
Sets the management notification address of this server.
|
Configuration |
Configuration.setMaskPassword(boolean maskPassword)
Sets if passwords should be masked or not.
|
Configuration |
Configuration.setMemoryMeasureInterval(long memoryMeasureInterval) |
Configuration |
Configuration.setMemoryWarningThreshold(int memoryWarningThreshold) |
Configuration |
Configuration.setMessageCounterEnabled(boolean enabled)
Sets whether message counter is enabled for this server.
|
Configuration |
Configuration.setMessageCounterMaxDayHistory(int maxDayHistory)
Sets the maximum number of days kept in memory for message counter.
|
Configuration |
Configuration.setMessageCounterSamplePeriod(long period)
Sets the sample period to take message counter snapshot.
|
Configuration |
Configuration.setMessageExpiryScanPeriod(long messageExpiryScanPeriod)
Sets the frequency (in milliseconds) to scan messages to detect which messages
have expired.
|
Configuration |
Configuration.setMessageExpiryThreadPriority(int messageExpiryThreadPriority)
Sets the priority of the thread used to scan message expiration.
|
Configuration |
Configuration.setName(String name)
To be used on dependency management on the application server
|
Configuration |
Configuration.setOutgoingInterceptorClassNames(List<String> interceptors)
Sets the list of interceptors classes used by this server for outgoing messages (i.e.
|
Configuration |
Configuration.setPageMaxConcurrentIO(int maxIO)
The max number of concurrent reads allowed on paging.
|
Configuration |
Configuration.setPagingDirectory(String dir)
Sets the file system directory used to store paging files.
|
Configuration |
Configuration.setPasswordCodec(String codec)
The default password decoder
|
Configuration |
Configuration.setPersistDeliveryCountBeforeDelivery(boolean persistDeliveryCountBeforeDelivery)
Sets whether delivery count is persisted before messages are delivered to consumers.
|
Configuration |
Configuration.setPersistenceEnabled(boolean enable)
Sets whether this server is using persistence and store data.
|
Configuration |
Configuration.setPersistIDCache(boolean persist)
Sets whether message ID cache is persisted.
|
Configuration |
Configuration.setQueueConfigurations(List<CoreQueueConfiguration> configs)
Sets the queues configured for this server.
|
Configuration |
Configuration.setResolveProtocols(boolean resolveProtocols) |
Configuration |
Configuration.setResourceLimitSettings(Map<String,ResourceLimitSettings> resourceLimitSettings) |
Configuration |
Configuration.setRunSyncSpeedTest(boolean run) |
Configuration |
Configuration.setScheduledThreadPoolMaxSize(int maxSize)
Sets the maximum number of threads in the scheduled thread pool of this server.
|
Configuration |
Configuration.setSecurityEnabled(boolean enabled)
Sets whether security is enabled for this server.
|
Configuration |
Configuration.setSecurityInvalidationInterval(long interval)
Sets the interval time (in milliseconds) to invalidate security credentials.
|
Configuration |
Configuration.setSecurityRoles(Map<String,Set<Role>> roles) |
Configuration |
Configuration.setServerDumpInterval(long interval) |
Configuration |
Configuration.setThreadPoolMaxSize(int maxSize)
Sets the maximum number of threads in the thread pool of this server.
|
Configuration |
Configuration.setTransactionTimeout(long timeout)
Sets the timeout (in milliseconds) after which transactions is removed
from the resource manager after it was created.
|
Configuration |
Configuration.setTransactionTimeoutScanPeriod(long period)
Sets the frequency (in milliseconds) to scan transactions to detect which transactions
have timed out.
|
Configuration |
Configuration.setWildcardRoutingEnabled(boolean enabled)
Sets whether wildcard routing is supported by this server.
|
Modifier and Type | Method and Description |
---|---|
static ClusterConnectionConfiguration |
ConfigurationUtils.getReplicationClusterConfiguration(Configuration conf,
String replicationCluster) |
static void |
ConfigurationUtils.validateConfiguration(Configuration configuration) |
Modifier and Type | Class and Description |
---|---|
class |
ConfigurationImpl |
class |
FileConfiguration
A
FileConfiguration reads configuration values from a file. |
Modifier and Type | Method and Description |
---|---|
Configuration |
ConfigurationImpl.copy() |
Configuration |
ConfigurationImpl.setJournalPoolFiles(int poolSize) |
Modifier and Type | Method and Description |
---|---|
Configuration |
FileConfigurationParser.parseMainConfig(InputStream input) |
Modifier and Type | Method and Description |
---|---|
void |
FileConfigurationParser.parseMainConfig(Element e,
Configuration config) |
Constructor and Description |
---|
ActiveMQServerControlImpl(PostOffice postOffice,
Configuration configuration,
ResourceManager resourceManager,
RemotingService remotingService,
ActiveMQServer messagingServer,
MessageCounterManager messageCounterManager,
StorageManager storageManager,
NotificationBroadcasterSupport broadcaster) |
Constructor and Description |
---|
JournalStorageManager(Configuration config,
ExecutorFactory executorFactory) |
JournalStorageManager(Configuration config,
ExecutorFactory executorFactory,
IOCriticalErrorListener criticalErrorListener) |
Constructor and Description |
---|
RemotingServiceImpl(ClusterManager clusterManager,
Configuration config,
ActiveMQServer server,
ManagementService managementService,
ScheduledExecutorService scheduledThreadPool,
List<ProtocolManagerFactory> protocolManagerFactories,
Executor flushExecutor,
ServiceRegistry serviceRegistry) |
Modifier and Type | Method and Description |
---|---|
Configuration |
ActiveMQServer.getConfiguration() |
Modifier and Type | Method and Description |
---|---|
ActiveMQServer |
ActiveMQServer.createBackupServer(Configuration configuration) |
static ActiveMQServer |
ActiveMQServers.newActiveMQServer(Configuration config) |
static ActiveMQServer |
ActiveMQServers.newActiveMQServer(Configuration config,
boolean enablePersistence) |
static ActiveMQServer |
ActiveMQServers.newActiveMQServer(Configuration config,
MBeanServer mbeanServer) |
static ActiveMQServer |
ActiveMQServers.newActiveMQServer(Configuration config,
MBeanServer mbeanServer,
ActiveMQSecurityManager securityManager) |
static ActiveMQServer |
ActiveMQServers.newActiveMQServer(Configuration config,
MBeanServer mbeanServer,
ActiveMQSecurityManager securityManager,
boolean enablePersistence) |
static ActiveMQServer |
ActiveMQServers.newActiveMQServer(Configuration config,
MBeanServer mbeanServer,
boolean enablePersistence) |
static ActiveMQServer |
ActiveMQServers.newActiveMQServer(Configuration config,
MBeanServer mbeanServer,
boolean enablePersistence,
String user,
String password) |
static ActiveMQServer |
ActiveMQServers.newActiveMQServer(Configuration config,
String defUser,
String defPass) |
void |
ActiveMQServerLogger.serverStarting(String type,
Configuration configuration) |
Modifier and Type | Method and Description |
---|---|
static TransportConfiguration[] |
ClusterConfigurationUtil.connectorNameListToArray(List<String> connectorNames,
Configuration configuration) |
static DiscoveryGroupConfiguration |
ClusterConfigurationUtil.getDiscoveryGroupConfiguration(ClusterConnectionConfiguration config,
Configuration configuration) |
static TransportConfiguration |
ClusterConfigurationUtil.getTransportConfiguration(ClusterConnectionConfiguration config,
Configuration configuration) |
static TransportConfiguration[] |
ClusterConfigurationUtil.getTransportConfigurations(ClusterConnectionConfiguration config,
Configuration configuration) |
Constructor and Description |
---|
BackupManager(ActiveMQServer server,
ExecutorFactory executorFactory,
ScheduledExecutorService scheduledExecutor,
NodeManager nodeManager,
Configuration configuration,
ClusterManager clusterManager) |
ClusterManager(ExecutorFactory executorFactory,
ActiveMQServer server,
PostOffice postOffice,
ScheduledExecutorService scheduledExecutor,
ManagementService managementService,
Configuration configuration,
NodeManager nodeManager,
boolean backup) |
Modifier and Type | Field and Description |
---|---|
protected Configuration |
EmbeddedActiveMQ.configuration |
Modifier and Type | Method and Description |
---|---|
void |
EmbeddedActiveMQ.setConfiguration(Configuration configuration)
Set this object if you are not using file-based configuration.
|
Modifier and Type | Method and Description |
---|---|
Configuration |
ActiveMQServerImpl.getConfiguration() |
Modifier and Type | Method and Description |
---|---|
ActiveMQServer |
ActiveMQServerImpl.createBackupServer(Configuration configuration) |
JournalLoader |
SharedStoreBackupActivation.createJournalLoader(PostOffice postOffice,
PagingManager pagingManager,
StorageManager storageManager,
QueueFactory queueFactory,
NodeManager nodeManager,
ManagementService managementService,
GroupingHandler groupingHandler,
Configuration configuration,
ActiveMQServer parentServer) |
JournalLoader |
SharedNothingBackupActivation.createJournalLoader(PostOffice postOffice,
PagingManager pagingManager,
StorageManager storageManager,
QueueFactory queueFactory,
NodeManager nodeManager,
ManagementService managementService,
GroupingHandler groupingHandler,
Configuration configuration,
ActiveMQServer parentServer) |
JournalLoader |
Activation.createJournalLoader(PostOffice postOffice,
PagingManager pagingManager,
StorageManager storageManager,
QueueFactory queueFactory,
NodeManager nodeManager,
ManagementService managementService,
GroupingHandler groupingHandler,
Configuration configuration,
ActiveMQServer parentServer) |
Modifier and Type | Method and Description |
---|---|
ActiveMQServerControlImpl |
ManagementService.registerServer(PostOffice postOffice,
StorageManager storageManager,
Configuration configuration,
HierarchicalRepository<AddressSettings> addressSettingsRepository,
HierarchicalRepository<Set<Role>> securityRepository,
ResourceManager resourceManager,
RemotingService remotingService,
ActiveMQServer messagingServer,
QueueFactory queueFactory,
ScheduledExecutorService scheduledThreadPool,
PagingManager pagingManager,
boolean backup) |
Modifier and Type | Method and Description |
---|---|
ActiveMQServerControlImpl |
ManagementServiceImpl.registerServer(PostOffice postOffice,
StorageManager storageManager1,
Configuration configuration,
HierarchicalRepository<AddressSettings> addressSettingsRepository,
HierarchicalRepository<Set<Role>> securityRepository,
ResourceManager resourceManager,
RemotingService remotingService,
ActiveMQServer messagingServer,
QueueFactory queueFactory,
ScheduledExecutorService scheduledThreadPool,
PagingManager pagingManager,
boolean backup) |
Constructor and Description |
---|
ManagementServiceImpl(MBeanServer mbeanServer,
Configuration configuration) |
Constructor and Description |
---|
JMSJournalStorageManagerImpl(IDGenerator idGenerator,
Configuration config,
ReplicationManager replicator) |
Copyright © 2016 JBoss by Red Hat. All rights reserved.