Constructor and Description |
---|
AddressControlImpl(SimpleString address,
PostOffice postOffice,
PagingManager pagingManager,
StorageManager storageManager,
HierarchicalRepository<Set<Role>> securityRepository) |
Modifier and Type | Method and Description |
---|---|
PagingManager |
PagingStore.getPagingManager() |
Modifier and Type | Method and Description |
---|---|
void |
PageTransactionInfo.onUpdate(int update,
StorageManager storageManager,
PagingManager pagingManager) |
void |
PageTransactionInfo.reloadUpdate(StorageManager storageManager,
PagingManager pagingManager,
Transaction tx,
int increment) |
void |
PagingStoreFactory.setPagingManager(PagingManager manager) |
void |
PageTransactionInfo.store(StorageManager storageManager,
PagingManager pagingManager,
Transaction tx) |
void |
PageTransactionInfo.storeUpdate(StorageManager storageManager,
PagingManager pagingManager,
Transaction tx) |
Modifier and Type | Class and Description |
---|---|
class |
PagingManagerImpl |
Modifier and Type | Method and Description |
---|---|
PagingManager |
PagingStoreImpl.getPagingManager() |
Modifier and Type | Method and Description |
---|---|
protected org.hornetq.core.paging.impl.PageTransactionInfoImpl.UpdatePageTXOperation |
PageTransactionInfoImpl.internalUpdatePageManager(StorageManager storageManager,
PagingManager pagingManager,
Transaction tx,
int increment) |
void |
PageTransactionInfoImpl.onUpdate(int update,
StorageManager storageManager,
PagingManager pagingManager) |
void |
PageTransactionInfoImpl.reloadUpdate(StorageManager storageManager,
PagingManager pagingManager,
Transaction tx,
int increment) |
void |
PagingStoreFactoryNIO.setPagingManager(PagingManager pagingManager) |
void |
PageTransactionInfoImpl.store(StorageManager storageManager,
PagingManager pagingManager,
Transaction tx) |
void |
PageTransactionInfoImpl.storeUpdate(StorageManager storageManager,
PagingManager pagingManager,
Transaction tx) |
Constructor and Description |
---|
PagingStoreImpl(SimpleString address,
ScheduledExecutorService scheduledExecutor,
long syncTimeout,
PagingManager pagingManager,
StorageManager storageManager,
SequentialFileFactory fileFactory,
PagingStoreFactory storeFactory,
SimpleString storeName,
AddressSettings addressSettings,
Executor executor,
boolean syncNonTransactional) |
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,
List<PageCountPending> pendingNonTXPageCounter) |
void |
StorageManager.startReplication(ReplicationManager replicationManager,
PagingManager pagingManager,
String nodeID,
boolean autoFailBack) |
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,
List<PageCountPending> pendingNonTXPageCounter) |
void |
JournalStorageManager.startReplication(ReplicationManager replicationManager,
PagingManager pagingManager,
String nodeID,
boolean autoFailBack)
Starts replication at the live-server side.
|
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>> pendingLargeMessages,
List<PageCountPending> pendingNonTXPageCounter) |
void |
NullStorageManager.startReplication(ReplicationManager replicationManager,
PagingManager pagingManager,
String nodeID,
boolean autoFailBack) |
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 |
---|---|
PagingManager |
HornetQServer.getPagingManager() |
Modifier and Type | Method and Description |
---|---|
PagingManager |
HornetQServerImpl.getPagingManager() |
Constructor and Description |
---|
ServerInfo(HornetQServer server,
PagingManager pagingManager) |
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) |
Copyright © 2018 JBoss by Red Hat. All rights reserved.