Constructor and Description |
---|
PostOfficeImpl(HornetQServer server,
StorageManager storageManager,
PagingManager pagingManager,
QueueFactory bindableFactory,
ManagementService managementService,
long reaperPeriod,
int reaperPriority,
boolean enableWildCardRouting,
int idCacheSize,
boolean persistIDCache,
HierarchicalRepository<AddressSettings> addressSettingsRepository) |
Constructor and Description |
---|
RemotingServiceImpl(ClusterManager clusterManager,
Configuration config,
HornetQServer server,
ManagementService managementService,
ScheduledExecutorService scheduledThreadPool,
List<ProtocolManagerFactory> protocolManagerFactories,
Executor flushExecutor) |
Modifier and Type | Method and Description |
---|---|
ManagementService |
HornetQServer.getManagementService() |
Constructor and Description |
---|
ClusterManager(ExecutorFactory executorFactory,
HornetQServer server,
PostOffice postOffice,
ScheduledExecutorService scheduledExecutor,
ManagementService managementService,
Configuration configuration,
NodeManager nodeManager,
boolean backup) |
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,
boolean routeWhenNoConsumers,
int confirmationWindowSize,
ExecutorFactory executorFactory,
HornetQServer 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,
boolean routeWhenNoConsumers,
int confirmationWindowSize,
ExecutorFactory executorFactory,
HornetQServer 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 ManagementService |
GroupHandlingAbstract.managementService |
Constructor and Description |
---|
GroupHandlingAbstract(Executor executor,
ManagementService managementService,
SimpleString address) |
LocalGroupingHandler(ExecutorFactory executorFactory,
ScheduledExecutorService scheduledExecutor,
ManagementService managementService,
SimpleString name,
SimpleString address,
StorageManager storageManager,
long timeout,
long groupTimeout,
long reaperPeriod) |
RemoteGroupingHandler(ExecutorFactory executorFactory,
ManagementService managementService,
SimpleString name,
SimpleString address,
long timeout,
long groupTimeout) |
RemoteGroupingHandler(ManagementService managementService,
SimpleString name,
SimpleString address,
long timeout,
long groupTimeout) |
Modifier and Type | Method and Description |
---|---|
ManagementService |
HornetQServerImpl.getManagementService() |
Constructor and Description |
---|
PostOfficeJournalLoader(PostOffice postOffice,
PagingManager pagingManager,
StorageManager storageManager,
QueueFactory queueFactory,
NodeManager nodeManager,
ManagementService managementService,
GroupingHandler groupingHandler,
Configuration configuration) |
PostOfficeJournalLoader(PostOffice postOffice,
PagingManager pagingManager,
StorageManager storageManager,
QueueFactory queueFactory,
NodeManager nodeManager,
ManagementService managementService,
GroupingHandler groupingHandler,
Configuration configuration,
Map<Long,Queue> queues) |
ServerConsumerImpl(long id,
ServerSession session,
QueueBinding binding,
Filter filter,
boolean started,
boolean browseOnly,
StorageManager storageManager,
SessionCallback callback,
boolean preAcknowledge,
boolean strictUpdateDeliveryCount,
ManagementService managementService) |
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) |
ServerSessionImpl(String name,
String username,
String password,
int minLargeMessageSize,
boolean autoCommitSends,
boolean autoCommitAcks,
boolean preAcknowledge,
boolean strictUpdateDeliveryCount,
boolean xa,
RemotingConnection remotingConnection,
StorageManager storageManager,
PostOffice postOffice,
ResourceManager resourceManager,
SecurityStore securityStore,
ManagementService managementService,
HornetQServer server,
SimpleString managementAddress,
SimpleString defaultAddress,
SessionCallback callback,
OperationContext context) |
Modifier and Type | Class and Description |
---|---|
class |
ManagementServiceImpl |
Copyright © 2017 JBoss, a division of Red Hat. All Rights Reserved.