Package | Description |
---|---|
org.hornetq.core.remoting.server.impl | |
org.hornetq.core.server | |
org.hornetq.core.server.cluster | |
org.hornetq.core.server.cluster.impl | |
org.hornetq.core.server.impl |
Constructor and Description |
---|
RemotingServiceImpl(ClusterManager clusterManager,
Configuration config,
HornetQServer server,
ManagementService managementService,
ScheduledExecutorService scheduledThreadPool,
Executor flushExecutor) |
Modifier and Type | Method and Description |
---|---|
ClusterManager |
HornetQServer.getClusterManager() |
Constructor and Description |
---|
ClusterManager.IncomingInterceptorLookingForExceptionMessage(ClusterManager manager,
Executor executor) |
Constructor and Description |
---|
ClusterConnectionBridge(ClusterConnection clusterConnection,
ClusterManager clusterManager,
ServerLocatorInternal targetLocator,
ServerLocatorInternal discoveryLocator,
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,
boolean activated,
StorageManager storageManager,
SimpleString managementAddress,
SimpleString managementNotificationAddress,
MessageFlowRecord flowRecord,
TransportConfiguration connector) |
ClusterConnectionImpl(ClusterManager 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,
long callFailoverTimeout,
boolean useDuplicateDetection,
boolean routeWhenNoConsumers,
int confirmationWindowSize,
ExecutorFactory executorFactory,
ExecutorService threadPool,
HornetQServer server,
PostOffice postOffice,
ManagementService managementService,
ScheduledExecutorService scheduledExecutor,
int maxHops,
NodeManager nodeManager,
boolean backup,
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 reconnectAttempts,
long callTimeout,
long callFailoverTimeout,
boolean useDuplicateDetection,
boolean routeWhenNoConsumers,
int confirmationWindowSize,
ExecutorFactory executorFactory,
ExecutorService threadPool,
HornetQServer server,
PostOffice postOffice,
ManagementService managementService,
ScheduledExecutorService scheduledExecutor,
int maxHops,
NodeManager nodeManager,
boolean backup,
String clusterUser,
String clusterPassword,
boolean allowDirectConnectionsOnly,
long clusterNotificationInterval,
int clusterNotificationAttempts) |
Modifier and Type | Method and Description |
---|---|
ClusterManager |
HornetQServerImpl.getClusterManager() |
Copyright © 2018 JBoss by Red Hat. All rights reserved.