Modifier and Type | Method and Description |
---|---|
static HAPolicy |
ConfigurationUtils.getHAPolicy(HAPolicyConfiguration conf,
ActiveMQServer server) |
Constructor and Description |
---|
ActiveMQServerControlImpl(PostOffice postOffice,
Configuration configuration,
ResourceManager resourceManager,
RemotingService remotingService,
ActiveMQServer messagingServer,
MessageCounterManager messageCounterManager,
StorageManager storageManager,
NotificationBroadcasterSupport broadcaster) |
Modifier and Type | Method and Description |
---|---|
ActiveMQServer |
PostOfficeImpl.getServer() |
Constructor and Description |
---|
PostOfficeImpl(ActiveMQServer server,
StorageManager storageManager,
PagingManager pagingManager,
QueueFactory bindableFactory,
ManagementService managementService,
long reaperPeriod,
int reaperPriority,
boolean enableWildCardRouting,
int idCacheSize,
boolean persistIDCache,
HierarchicalRepository<AddressSettings> addressSettingsRepository) |
Modifier and Type | Method and Description |
---|---|
ProtocolManager |
CoreProtocolManagerFactory.createProtocolManager(ActiveMQServer server,
Map<String,Object> parameters,
List<BaseInterceptor> incomingInterceptors,
List<BaseInterceptor> outgoingInterceptors)
When you create the ProtocolManager, you should filter out any interceptors that won't belong
to this Protocol.
|
Constructor and Description |
---|
ActiveMQPacketHandler(CoreProtocolManager protocolManager,
ActiveMQServer server,
Channel channel1,
CoreRemotingConnection connection) |
CoreProtocolManager(CoreProtocolManagerFactory factory,
ActiveMQServer server,
List<Interceptor> incomingInterceptors,
List<Interceptor> outgoingInterceptors) |
Modifier and Type | Method and Description |
---|---|
ProtocolManager |
HornetQProtocolManagerFactory.createProtocolManager(ActiveMQServer server,
Map<String,Object> parameters,
List<BaseInterceptor> incomingInterceptors,
List<BaseInterceptor> outgoingInterceptors) |
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 |
---|---|
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) |
Modifier and Type | Method and Description |
---|---|
void |
ActiveMQServerLogger.activationDidntFinish(ActiveMQServer server) |
String |
ActiveMQMessageBundle.activationForServer(ActiveMQServer server) |
void |
ActiveMQServerLogger.becomingLive(ActiveMQServer server) |
void |
ActiveMQServerLogger.errorRestartingBackupServer(Exception e,
ActiveMQServer backup) |
Modifier and Type | Method and Description |
---|---|
ActiveMQServer |
ClusterConnection.getServer() |
Constructor and Description |
---|
BackupManager(ActiveMQServer server,
ExecutorFactory executorFactory,
ScheduledExecutorService scheduledExecutor,
NodeManager nodeManager,
Configuration configuration,
ClusterManager clusterManager) |
ClusterControl(ClientSessionFactoryInternal sessionFactory,
ActiveMQServer server) |
ClusterController(ActiveMQServer server,
ScheduledExecutorService scheduledExecutor) |
ClusterManager(ExecutorFactory executorFactory,
ActiveMQServer server,
PostOffice postOffice,
ScheduledExecutorService scheduledExecutor,
ManagementService managementService,
Configuration configuration,
NodeManager nodeManager,
boolean backup) |
Modifier and Type | Method and Description |
---|---|
Map<String,ActiveMQServer> |
StandaloneHAManager.getBackupServers() |
Map<String,ActiveMQServer> |
HAManager.getBackupServers()
return the current backup servers
|
Map<String,ActiveMQServer> |
ColocatedHAManager.getBackupServers()
return the current backup servers
|
Modifier and Type | Method and Description |
---|---|
static ServerLocatorInternal |
ScaleDownPolicy.getScaleDownConnector(ScaleDownPolicy scaleDownPolicy,
ActiveMQServer activeMQServer) |
Constructor and Description |
---|
ColocatedHAManager(ColocatedPolicy haPolicy,
ActiveMQServer activeMQServer) |
Modifier and Type | Method and Description |
---|---|
ActiveMQServer |
ClusterConnectionImpl.getServer() |
Constructor and Description |
---|
ClusterConnectionImpl(ClusterManager manager,
DiscoveryGroupConfiguration dg,
TransportConfiguration connector,
SimpleString name,
SimpleString address,
int minLargeMessageSize,
long clientFailureCheckPeriod,
long connectionTTL,
long retryInterval,
double retryIntervalMultiplier,
long maxRetryInterval,
int initialConnectAttempts,
int reconnectAttempts,
long callTimeout,
long callFailoverTimeout,
boolean useDuplicateDetection,
MessageLoadBalancingType messageLoadBalancingType,
int confirmationWindowSize,
int producerWindowSize,
ExecutorFactory executorFactory,
ActiveMQServer server,
PostOffice postOffice,
ManagementService managementService,
ScheduledExecutorService scheduledExecutor,
int maxHops,
NodeManager nodeManager,
String clusterUser,
String clusterPassword,
boolean allowDirectConnectionsOnly,
long clusterNotificationInterval,
int clusterNotificationAttempts) |
ClusterConnectionImpl(ClusterManager manager,
TransportConfiguration[] staticTranspConfigs,
TransportConfiguration connector,
SimpleString name,
SimpleString address,
int minLargeMessageSize,
long clientFailureCheckPeriod,
long connectionTTL,
long retryInterval,
double retryIntervalMultiplier,
long maxRetryInterval,
int initialConnectAttempts,
int reconnectAttempts,
long callTimeout,
long callFailoverTimeout,
boolean useDuplicateDetection,
MessageLoadBalancingType messageLoadBalancingType,
int confirmationWindowSize,
int producerWindowSize,
ExecutorFactory executorFactory,
ActiveMQServer server,
PostOffice postOffice,
ManagementService managementService,
ScheduledExecutorService scheduledExecutor,
int maxHops,
NodeManager nodeManager,
String clusterUser,
String clusterPassword,
boolean allowDirectConnectionsOnly,
long clusterNotificationInterval,
int clusterNotificationAttempts) |
Modifier and Type | Field and Description |
---|---|
protected ActiveMQServer |
EmbeddedActiveMQ.activeMQServer |
Modifier and Type | Method and Description |
---|---|
ActiveMQServer |
EmbeddedActiveMQ.getActiveMQServer() |
Modifier and Type | Class and Description |
---|---|
class |
ActiveMQServerImpl
The ActiveMQ Artemis server implementation
|
Modifier and Type | Field and Description |
---|---|
protected ActiveMQServer |
ServerSessionImpl.server |
Modifier and Type | Method and Description |
---|---|
ActiveMQServer |
ActiveMQServerImpl.createBackupServer(Configuration configuration) |
Modifier and Type | Method and Description |
---|---|
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) |
Constructor and Description |
---|
ActiveMQServerImpl(Configuration configuration,
ActiveMQServer parentServer) |
ActiveMQServerImpl(Configuration configuration,
MBeanServer mbeanServer,
ActiveMQSecurityManager securityManager,
ActiveMQServer parentServer) |
ActiveMQServerImpl(Configuration configuration,
MBeanServer mbeanServer,
ActiveMQSecurityManager securityManager,
ActiveMQServer parentServer,
ServiceRegistry serviceRegistry) |
BackupRecoveryJournalLoader(PostOffice postOffice,
PagingManager pagingManager,
StorageManager storageManager,
QueueFactory queueFactory,
NodeManager nodeManager,
ManagementService managementService,
GroupingHandler groupingHandler,
Configuration configuration,
ActiveMQServer parentServer,
ServerLocatorInternal locator,
ClusterController clusterController) |
ServerConsumerImpl(long id,
ServerSession session,
QueueBinding binding,
Filter filter,
boolean started,
boolean browseOnly,
StorageManager storageManager,
SessionCallback callback,
boolean preAcknowledge,
boolean strictUpdateDeliveryCount,
ManagementService managementService,
ActiveMQServer server) |
ServerConsumerImpl(long id,
ServerSession session,
QueueBinding binding,
Filter filter,
boolean started,
boolean browseOnly,
StorageManager storageManager,
SessionCallback callback,
boolean preAcknowledge,
boolean strictUpdateDeliveryCount,
ManagementService managementService,
boolean supportLargeMessage,
Integer credits,
ActiveMQServer server) |
ServerInfo(ActiveMQServer server,
PagingManager pagingManager) |
ServerSessionImpl(String name,
String username,
String password,
String validatedUser,
int minLargeMessageSize,
boolean autoCommitSends,
boolean autoCommitAcks,
boolean preAcknowledge,
boolean strictUpdateDeliveryCount,
boolean xa,
RemotingConnection remotingConnection,
StorageManager storageManager,
PostOffice postOffice,
ResourceManager resourceManager,
SecurityStore securityStore,
ManagementService managementService,
ActiveMQServer server,
SimpleString managementAddress,
SimpleString defaultAddress,
SessionCallback callback,
OperationContext context,
QueueCreator queueCreator,
PagingManager pagingManager) |
TempQueueCleanerUpper(ActiveMQServer server,
SimpleString bindingName) |
TransientQueueManagerImpl(ActiveMQServer server,
SimpleString queueName) |
Modifier and Type | Method and Description |
---|---|
ActiveMQServerControlImpl |
ManagementService.registerServer(PostOffice postOffice,
SecurityStore securityStore,
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,
SecurityStore securityStore,
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) |
Modifier and Type | Method and Description |
---|---|
ActiveMQServer |
FileBroker.getServer() |
ActiveMQServer |
Broker.getServer() |
Modifier and Type | Method and Description |
---|---|
ActiveMQServer |
JMSServerManager.getActiveMQServer() |
Modifier and Type | Method and Description |
---|---|
ActiveMQServer |
JMSServerManagerImpl.getActiveMQServer() |
Constructor and Description |
---|
JMSServerManagerImpl(ActiveMQServer server) |
JMSServerManagerImpl(ActiveMQServer server,
BindingRegistry registry)
This constructor is used by the Application Server's integration
|
JMSServerManagerImpl(ActiveMQServer server,
JMSConfiguration configuration) |
Constructor and Description |
---|
JMSManagementServiceImpl(ManagementService managementService,
ActiveMQServer server,
JMSServerManager jmsServerManager) |
Modifier and Type | Method and Description |
---|---|
ProtocolManager |
ProtocolManagerFactory.createProtocolManager(ActiveMQServer server,
Map<String,Object> parameters,
List<BaseInterceptor> incomingInterceptors,
List<BaseInterceptor> outgoingInterceptors)
When you create the ProtocolManager, you should filter out any interceptors that won't belong
to this Protocol.
|
Copyright © 2017 JBoss by Red Hat. All rights reserved.