Constructor and Description |
---|
AddressControlImpl(SimpleString address,
PostOffice postOffice,
PagingManager pagingManager,
StorageManager storageManager,
HierarchicalRepository<Set<Role>> securityRepository) |
HornetQServerControlImpl(PostOffice postOffice,
Configuration configuration,
ResourceManager resourceManager,
RemotingService remotingService,
HornetQServer messagingServer,
MessageCounterManager messageCounterManager,
StorageManager storageManager,
NotificationBroadcasterSupport broadcaster) |
QueueControlImpl(Queue queue,
String address,
PostOffice postOffice,
StorageManager storageManager,
HierarchicalRepository<AddressSettings> addressSettingsRepository) |
Modifier and Type | Method and Description |
---|---|
void |
PagingStoreFactory.setPostOffice(PostOffice office) |
void |
PagingManager.setPostOffice(PostOffice postOffice)
An injection point for the PostOffice to inject itself
|
Modifier and Type | Method and Description |
---|---|
protected PostOffice |
PagingStoreFactoryNIO.getPostOffice() |
Modifier and Type | Method and Description |
---|---|
void |
PagingStoreFactoryNIO.setPostOffice(PostOffice postOffice) |
void |
PagingManagerImpl.setPostOffice(PostOffice postOffice)
this will be set by the postOffice itself.
|
Modifier and Type | Method and Description |
---|---|
JournalLoadInformation |
StorageManager.loadMessageJournal(PostOffice postOffice,
PagingManager pagingManager,
ResourceManager resourceManager,
Map<Long,Queue> queues,
Map<Long,QueueBindingInfo> queueInfos,
Map<SimpleString,List<Pair<byte[],Long>>> duplicateIDMap,
Set<Pair<Long,Long>> pendingLargeMessages) |
Modifier and Type | Method and Description |
---|---|
JournalLoadInformation |
JournalStorageManager.loadMessageJournal(PostOffice postOffice,
PagingManager pagingManager,
ResourceManager resourceManager,
Map<Long,Queue> queues,
Map<Long,QueueBindingInfo> queueInfos,
Map<SimpleString,List<Pair<byte[],Long>>> duplicateIDMap,
Set<Pair<Long,Long>> pendingLargeMessages) |
Modifier and Type | Method and Description |
---|---|
JournalLoadInformation |
NullStorageManager.loadMessageJournal(PostOffice postOffice,
PagingManager pagingManager,
ResourceManager resourceManager,
Map<Long,Queue> queues,
Map<Long,QueueBindingInfo> queueInfos,
Map<SimpleString,List<Pair<byte[],Long>>> duplicateIDMap,
Set<Pair<Long,Long>> pendingLM) |
Modifier and Type | Class and Description |
---|---|
class |
PostOfficeImpl
A PostOfficeImpl
|
Modifier and Type | Method and Description |
---|---|
PostOffice |
HornetQServer.getPostOffice() |
Modifier and Type | Method and Description |
---|---|
ConnectorService |
ConnectorServiceFactory.createConnectorService(String connectorName,
Map<String,Object> configuration,
StorageManager storageManager,
PostOffice postOffice,
ScheduledExecutorService scheduledThreadPool) |
void |
QueueFactory.setPostOffice(PostOffice postOffice)
This is required for delete-all-reference to work correctly with paging
|
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) |
Redistributor(Queue queue,
StorageManager storageManager,
PostOffice postOffice,
Executor executor,
int batchSize) |
Modifier and Type | Field and Description |
---|---|
PostOffice |
ServerSessionImpl.postOffice |
Modifier and Type | Method and Description |
---|---|
PostOffice |
HornetQServerImpl.getPostOffice() |
Modifier and Type | Method and Description |
---|---|
void |
QueueFactoryImpl.setPostOffice(PostOffice postOffice) |
Constructor and Description |
---|
ConnectorsService(Configuration configuration,
StorageManager storageManager,
ScheduledExecutorService scheduledPool,
PostOffice postOffice) |
DivertImpl(SimpleString forwardAddress,
SimpleString uniqueName,
SimpleString routingName,
boolean exclusive,
Filter filter,
Transformer transformer,
PostOffice postOffice,
StorageManager storageManager) |
LastValueQueue(long persistenceID,
SimpleString address,
SimpleString name,
Filter filter,
PageSubscription pageSubscription,
boolean durable,
boolean temporary,
ScheduledExecutorService scheduledExecutor,
PostOffice postOffice,
StorageManager storageManager,
HierarchicalRepository<AddressSettings> addressSettingsRepository,
Executor executor) |
QueueImpl(long id,
SimpleString address,
SimpleString name,
Filter filter,
boolean durable,
boolean temporary,
ScheduledExecutorService scheduledExecutor,
PostOffice postOffice,
StorageManager storageManager,
HierarchicalRepository<AddressSettings> addressSettingsRepository,
Executor executor) |
QueueImpl(long id,
SimpleString address,
SimpleString name,
Filter filter,
PageSubscription pageSubscription,
boolean durable,
boolean temporary,
ScheduledExecutorService scheduledExecutor,
PostOffice postOffice,
StorageManager storageManager,
HierarchicalRepository<AddressSettings> addressSettingsRepository,
Executor executor) |
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 | 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 storageManager,
Configuration configuration,
HierarchicalRepository<AddressSettings> addressSettingsRepository,
HierarchicalRepository<Set<Role>> securityRepository,
ResourceManager resourceManager,
RemotingService remotingService,
HornetQServer messagingServer,
QueueFactory queueFactory,
ScheduledExecutorService scheduledThreadPool,
PagingManager pagingManager,
boolean backup) |
Copyright © 2012 JBoss by Red Hat. All Rights Reserved.