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) |
Modifier and Type | Method and Description |
---|---|
ManagementService |
HornetQServer.getManagementService() |
Constructor and Description |
---|
ClusterConnectionImpl(ClusterManagerImpl manager,
DiscoveryGroupConfiguration dg,
TransportConfiguration connector,
SimpleString name,
SimpleString address,
int minLargeMessageSize,
long clientFailureCheckPeriod,
long connectionTTL,
long retryInterval,
double retryIntervalMultiplier,
long maxRetryInterval,
int reconnectAttempts,
long callTimeout,
boolean useDuplicateDetection,
boolean routeWhenNoConsumers,
int confirmationWindowSize,
ExecutorFactory executorFactory,
HornetQServer server,
PostOffice postOffice,
ManagementService managementService,
ScheduledExecutorService scheduledExecutor,
int maxHops,
UUID nodeUUID,
boolean backup,
String clusterUser,
String clusterPassword,
boolean allowDirectConnectionsOnly) |
ClusterConnectionImpl(ClusterManagerInternal manager,
TransportConfiguration[] tcConfigs,
TransportConfiguration connector,
SimpleString name,
SimpleString address,
int minLargeMessageSize,
long clientFailureCheckPeriod,
long connectionTTL,
long retryInterval,
double retryIntervalMultiplier,
long maxRetryInterval,
int reconnectAttempts,
long callTimeout,
boolean useDuplicateDetection,
boolean routeWhenNoConsumers,
int confirmationWindowSize,
ExecutorFactory executorFactory,
HornetQServer server,
PostOffice postOffice,
ManagementService managementService,
ScheduledExecutorService scheduledExecutor,
int maxHops,
UUID nodeUUID,
boolean backup,
String clusterUser,
String clusterPassword,
boolean allowDirectConnectionsOnly) |
ClusterManagerImpl(ExecutorFactory executorFactory,
HornetQServer server,
PostOffice postOffice,
ScheduledExecutorService scheduledExecutor,
ManagementService managementService,
Configuration configuration,
UUID nodeUUID,
boolean backup,
boolean clustered) |
Constructor and Description |
---|
LocalGroupingHandler(ManagementService managementService,
SimpleString name,
SimpleString address,
StorageManager storageManager,
int timeout) |
RemoteGroupingHandler(ManagementService managementService,
SimpleString name,
SimpleString address,
int timeout) |
Modifier and Type | Method and Description |
---|---|
ManagementService |
HornetQServerImpl.getManagementService() |
Constructor and Description |
---|
ServerConsumerImpl(long id,
ServerSession session,
QueueBinding binding,
Filter filter,
boolean started,
boolean browseOnly,
StorageManager storageManager,
SessionCallback callback,
boolean preAcknowledge,
boolean strictUpdateDeliveryCount,
ManagementService managementService) |
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) |
Modifier and Type | Class and Description |
---|---|
class |
ManagementServiceImpl |
Constructor and Description |
---|
JMSTopicControlImpl(HornetQDestination topic,
JMSServerManager jmsServerManager,
AddressControl addressControl,
ManagementService managementService) |
Constructor and Description |
---|
JMSManagementServiceImpl(ManagementService managementService,
HornetQServer server,
JMSServerManager jmsServerManager) |
Copyright © 2012 JBoss by Red Hat. All Rights Reserved.