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) |
Constructor and Description |
---|
AddressView(ActiveMQServer server) |
ConnectionView(ActiveMQServer server) |
ConsumerView(ActiveMQServer server) |
ProducerView(ActiveMQServer server) |
QueueView(ActiveMQServer server) |
Constructor and Description |
---|
AddressFilterPredicate(ActiveMQServer server) |
ConnectionFilterPredicate(ActiveMQServer server) |
ConsumerFilterPredicate(ActiveMQServer server) |
ProducerFilterPredicate(ActiveMQServer server) |
QueueFilterPredicate(ActiveMQServer server) |
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,
WildcardConfiguration wildcardConfiguration,
int idCacheSize,
boolean persistIDCache,
HierarchicalRepository<AddressSettings> addressSettingsRepository) |
Constructor and Description |
---|
ServerSessionPacketHandler(ActiveMQServer server,
CoreProtocolManager manager,
ServerSession session,
StorageManager storageManager,
Channel channel) |
Modifier and Type | Field and Description |
---|---|
protected ActiveMQServer |
CoreProtocolManager.server |
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) |
static ActiveMQServer |
ActiveMQServers.newActiveMQServer(String configURL,
MBeanServer mbeanServer,
ActiveMQSecurityManager securityManager) |
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 |
---|
BridgeImpl(ServerLocatorInternal serverLocator,
int initialConnectAttempts,
int reconnectAttempts,
int reconnectAttemptsSameNode,
long retryInterval,
double retryMultiplier,
long maxRetryInterval,
UUID nodeUUID,
SimpleString name,
Queue queue,
Executor executor,
Filter filter,
SimpleString forwardingAddress,
ScheduledExecutorService scheduledExecutor,
Transformer transformer,
boolean useDuplicateDetection,
String user,
String password,
ActiveMQServer server) |
ClusterConnectionBridge(ClusterConnection clusterConnection,
ClusterManager clusterManager,
ServerLocatorInternal targetLocator,
ServerLocatorInternal discoveryLocator,
int initialConnectAttempts,
int reconnectAttempts,
long retryInterval,
double retryMultiplier,
long maxRetryInterval,
UUID nodeUUID,
long targetNodeEventUID,
String targetNodeID,
SimpleString name,
Queue queue,
Executor executor,
Filter filterString,
SimpleString forwardingAddress,
ScheduledExecutorService scheduledExecutor,
Transformer transformer,
boolean useDuplicateDetection,
String user,
String password,
ActiveMQServer server,
SimpleString managementAddress,
SimpleString managementNotificationAddress,
MessageFlowRecord flowRecord,
TransportConfiguration connector,
String storeAndForwardPrefix) |
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 |
protected ActiveMQServer |
QueueFactoryImpl.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) |
LastValueQueue(long persistenceID,
SimpleString address,
SimpleString name,
Filter filter,
PageSubscription pageSubscription,
SimpleString user,
boolean durable,
boolean temporary,
boolean autoCreated,
RoutingType routingType,
Integer maxConsumers,
Boolean exclusive,
Boolean purgeOnNoConsumers,
ScheduledExecutorService scheduledExecutor,
PostOffice postOffice,
StorageManager storageManager,
HierarchicalRepository<AddressSettings> addressSettingsRepository,
ArtemisExecutor executor,
ActiveMQServer server,
QueueFactory factory) |
QueueFactoryImpl(ExecutorFactory executorFactory,
ScheduledExecutorService scheduledExecutor,
HierarchicalRepository<AddressSettings> addressSettingsRepository,
StorageManager storageManager,
ActiveMQServer server) |
QueueImpl(long id,
SimpleString address,
SimpleString name,
Filter filter,
PageSubscription pageSubscription,
SimpleString user,
boolean durable,
boolean temporary,
boolean autoCreated,
RoutingType routingType,
Integer maxConsumers,
Boolean exclusive,
Boolean purgeOnNoConsumers,
ScheduledExecutorService scheduledExecutor,
PostOffice postOffice,
StorageManager storageManager,
HierarchicalRepository<AddressSettings> addressSettingsRepository,
ArtemisExecutor executor,
ActiveMQServer server,
QueueFactory factory) |
QueueImpl(long id,
SimpleString address,
SimpleString name,
Filter filter,
PageSubscription pageSubscription,
SimpleString user,
boolean durable,
boolean temporary,
boolean autoCreated,
RoutingType routingType,
Integer maxConsumers,
Boolean purgeOnNoConsumers,
ScheduledExecutorService scheduledExecutor,
PostOffice postOffice,
StorageManager storageManager,
HierarchicalRepository<AddressSettings> addressSettingsRepository,
ArtemisExecutor executor,
ActiveMQServer server,
QueueFactory factory) |
QueueImpl(long id,
SimpleString address,
SimpleString name,
Filter filter,
PageSubscription pageSubscription,
SimpleString user,
boolean durable,
boolean temporary,
boolean autoCreated,
ScheduledExecutorService scheduledExecutor,
PostOffice postOffice,
StorageManager storageManager,
HierarchicalRepository<AddressSettings> addressSettingsRepository,
ArtemisExecutor executor,
ActiveMQServer server,
QueueFactory factory) |
QueueImpl(long id,
SimpleString address,
SimpleString name,
Filter filter,
SimpleString user,
boolean durable,
boolean temporary,
boolean autoCreated,
ScheduledExecutorService scheduledExecutor,
PostOffice postOffice,
StorageManager storageManager,
HierarchicalRepository<AddressSettings> addressSettingsRepository,
ArtemisExecutor executor,
ActiveMQServer server,
QueueFactory factory) |
QueueManagerImpl(ActiveMQServer server,
SimpleString queueName) |
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,
PagingManager pagingManager,
Map<SimpleString,RoutingType> prefixes) |
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 |
---|---|
default void |
ActiveMQServerPlugin.registered(ActiveMQServer server)
The plugin has been registered with the server
|
default void |
ActiveMQServerPlugin.unregistered(ActiveMQServer server)
The plugin has been unregistered with the server
|
Modifier and Type | Method and Description |
---|---|
void |
NotificationActiveMQServerPlugin.registered(ActiveMQServer server) |
void |
NotificationActiveMQServerPlugin.unregistered(ActiveMQServer server) |
Modifier and Type | Method and Description |
---|---|
ActiveMQServer |
FileBroker.getServer() |
ActiveMQServer |
Broker.getServer() |
Modifier and Type | Method and Description |
---|---|
ActiveMQServer |
JMSServerManager.getActiveMQServer()
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
ActiveMQServer |
JMSServerManagerImpl.getActiveMQServer()
Deprecated.
|
Constructor and Description |
---|
JMSServerManagerImpl(ActiveMQServer server)
Deprecated.
|
JMSServerManagerImpl(ActiveMQServer server,
BindingRegistry registry)
Deprecated.
This constructor is used by the Application Server's integration
|
JMSServerManagerImpl(ActiveMQServer server,
JMSConfiguration configuration)
Deprecated.
|
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 © 2018 JBoss by Red Hat. All rights reserved.