Constructor and Description |
---|
QueueDeployer(DeploymentManager deploymentManager,
HornetQServer server) |
Constructor and Description |
---|
HornetQServerControlImpl(PostOffice postOffice,
Configuration configuration,
ResourceManager resourceManager,
RemotingService remotingService,
HornetQServer messagingServer,
MessageCounterManager messageCounterManager,
StorageManager storageManager,
NotificationBroadcasterSupport broadcaster) |
Modifier and Type | Method and Description |
---|---|
HornetQServer |
PostOfficeImpl.getServer() |
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) |
Modifier and Type | Method and Description |
---|---|
ProtocolManager |
CoreProtocolManagerFactory.createProtocolManager(HornetQServer server,
List<Interceptor> incomingInterceptors,
List<Interceptor> outgoingInterceptors) |
Constructor and Description |
---|
HornetQPacketHandler(org.hornetq.core.protocol.core.impl.CoreProtocolManager protocolManager,
HornetQServer server,
Channel channel1,
CoreRemotingConnection connection) |
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 |
---|---|
static HornetQServer |
HornetQServers.newHornetQServer(Configuration config) |
static HornetQServer |
HornetQServers.newHornetQServer(Configuration config,
boolean enablePersistence) |
static HornetQServer |
HornetQServers.newHornetQServer(Configuration config,
MBeanServer mbeanServer) |
static HornetQServer |
HornetQServers.newHornetQServer(Configuration config,
MBeanServer mbeanServer,
boolean enablePersistence) |
static HornetQServer |
HornetQServers.newHornetQServer(Configuration config,
MBeanServer mbeanServer,
boolean enablePersistence,
String user,
String password) |
static HornetQServer |
HornetQServers.newHornetQServer(Configuration config,
MBeanServer mbeanServer,
HornetQSecurityManager securityManager) |
static HornetQServer |
HornetQServers.newHornetQServer(Configuration config,
MBeanServer mbeanServer,
HornetQSecurityManager securityManager,
boolean enablePersistence) |
static HornetQServer |
HornetQServers.newHornetQServer(Configuration config,
String defUser,
String defPass) |
Modifier and Type | Method and Description |
---|---|
String |
HornetQMessageBundle.activationForServer(HornetQServer server) |
void |
HornetQServerLogger.backupActivationDidntFinish(HornetQServer server) |
void |
HornetQServerLogger.becomingLive(HornetQServer server) |
void |
HornetQServerLogger.errorRestartingBackupServer(Exception e,
HornetQServer backup) |
void |
Queue.setConsumersRefCount(HornetQServer server)
This will set a reference counter for every consumer present on the queue.
|
Modifier and Type | Method and Description |
---|---|
HornetQServer |
ClusterConnection.getServer() |
Constructor and Description |
---|
BackupManager(HornetQServer server,
ExecutorFactory executorFactory,
ScheduledExecutorService scheduledExecutor,
NodeManager nodeManager,
Configuration configuration,
ClusterManager clusterManager) |
ClusterManager(ExecutorFactory executorFactory,
HornetQServer server,
PostOffice postOffice,
ScheduledExecutorService scheduledExecutor,
ManagementService managementService,
Configuration configuration,
NodeManager nodeManager,
boolean backup) |
Modifier and Type | Method and Description |
---|---|
HornetQServer |
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,
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 HornetQServer |
EmbeddedHornetQ.hornetQServer |
Modifier and Type | Method and Description |
---|---|
HornetQServer |
EmbeddedHornetQ.getHornetQServer() |
Modifier and Type | Class and Description |
---|---|
class |
HornetQServerImpl
The HornetQ server implementation
|
Modifier and Type | Method and Description |
---|---|
void |
QueueImpl.setConsumersRefCount(HornetQServer server) |
Modifier and Type | Method and Description |
---|---|
protected void |
HornetQServerImpl.startBackupServers(Configuration configuration,
Map<String,HornetQServer> backupServers) |
Constructor and Description |
---|
HornetQServerImpl(Configuration configuration,
HornetQServer parentServer) |
HornetQServerImpl(Configuration configuration,
MBeanServer mbeanServer,
HornetQSecurityManager securityManager,
HornetQServer parentServer) |
ServerInfo(HornetQServer server,
PagingManager pagingManager) |
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) |
TransientQueueManagerImpl(HornetQServer server,
SimpleString queueName) |
Modifier and Type | Method and Description |
---|---|
HornetQServerControlImpl |
ManagementService.registerServer(PostOffice postOffice,
StorageManager storageManager,
Configuration configuration,
HierarchicalRepository<AddressSettings> addressSettingsRepository,
HierarchicalRepository<Set<Role>> securityRepository,
ResourceManager resourceManager,
RemotingService remotingService,
HornetQServer messagingServer,
QueueFactory queueFactory,
ScheduledExecutorService scheduledThreadPool,
PagingManager pagingManager,
boolean backup) |
Modifier and Type | Method and Description |
---|---|
HornetQServerControlImpl |
ManagementServiceImpl.registerServer(PostOffice postOffice,
StorageManager storageManager1,
Configuration configuration,
HierarchicalRepository<AddressSettings> addressSettingsRepository,
HierarchicalRepository<Set<Role>> securityRepository,
ResourceManager resourceManager,
RemotingService remotingService,
HornetQServer messagingServer,
QueueFactory queueFactory,
ScheduledExecutorService scheduledThreadPool,
PagingManager pagingManager,
boolean backup) |
Modifier and Type | Method and Description |
---|---|
ProtocolManager |
ProtocolManagerFactory.createProtocolManager(HornetQServer server,
List<Interceptor> incomingInterceptors,
List<Interceptor> outgoingInterceptors) |
Copyright © 2017 JBoss, a division of Red Hat. All Rights Reserved.