Modifier and Type | Field and Description |
---|---|
protected PagingManager |
DBOption.pagingmanager |
Constructor and Description |
---|
AddressControlImpl(AddressInfo addressInfo,
PostOffice postOffice,
PagingManager pagingManager,
StorageManager storageManager,
HierarchicalRepository<Set<Role>> securityRepository,
SecurityStore securityStore,
ManagementService managementService) |
Modifier and Type | Method and Description |
---|---|
PagingManager |
PagingManager.addSize(int size)
Add size at the global count level.
|
PagingManager |
PagingStore.getPagingManager() |
Modifier and Type | Method and Description |
---|---|
boolean |
PageTransactionInfo.checkSize(StorageManager storageManager,
PagingManager pagingManager) |
boolean |
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() |
PagingManager |
PagingStoreFactoryNIO.getPagingManager() |
Modifier and Type | Method and Description |
---|---|
boolean |
PageTransactionInfoImpl.checkSize(StorageManager storageManager,
PagingManager pagingManager) |
boolean |
PageTransactionInfoImpl.internalCheckSize(StorageManager storageManager,
PagingManager pagingManager,
int size) |
protected org.apache.activemq.artemis.core.paging.impl.PageTransactionInfoImpl.UpdatePageTXOperation |
PageTransactionInfoImpl.internalUpdatePageManager(StorageManager storageManager,
PagingManager pagingManager,
Transaction tx,
int increment) |
boolean |
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 |
PagingStoreFactoryDatabase.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,
ArtemisExecutor executor,
boolean syncNonTransactional) |
Modifier and Type | Method and Description |
---|---|
JournalLoadInformation |
StorageManager.loadMessageJournal(PostOffice postOffice,
PagingManager pagingManager,
ResourceManager resourceManager,
Map<Long,QueueBindingInfo> queueInfos,
Map<SimpleString,List<Pair<byte[],Long>>> duplicateIDMap,
Set<Pair<Long,Long>> pendingLargeMessages,
List<PageCountPending> pendingNonTXPageCounter,
JournalLoader journalLoader) |
void |
StorageManager.startReplication(ReplicationManager replicationManager,
PagingManager pagingManager,
String nodeID,
boolean autoFailBack,
long initialReplicationSyncTimeout) |
Modifier and Type | Method and Description |
---|---|
void |
AbstractJournalStorageManager.checkInvalidPageTransactions(PagingManager pagingManager,
Set<PageTransactionInfo> invalidPageTransactions) |
JournalLoadInformation |
AbstractJournalStorageManager.loadMessageJournal(PostOffice postOffice,
PagingManager pagingManager,
ResourceManager resourceManager,
Map<Long,QueueBindingInfo> queueInfos,
Map<SimpleString,List<Pair<byte[],Long>>> duplicateIDMap,
Set<Pair<Long,Long>> pendingLargeMessages,
List<PageCountPending> pendingNonTXPageCounter,
JournalLoader journalLoader) |
void |
JournalStorageManager.startReplication(ReplicationManager replicationManager,
PagingManager pagingManager,
String nodeID,
boolean autoFailBack,
long initialReplicationSyncTimeout) |
Modifier and Type | Method and Description |
---|---|
JournalLoadInformation |
NullStorageManager.loadMessageJournal(PostOffice postOffice,
PagingManager pagingManager,
ResourceManager resourceManager,
Map<Long,QueueBindingInfo> queueInfos,
Map<SimpleString,List<Pair<byte[],Long>>> duplicateIDMap,
Set<Pair<Long,Long>> pendingLargeMessages,
List<PageCountPending> pendingNonTXPageCounter,
JournalLoader journalLoader) |
void |
NullStorageManager.startReplication(ReplicationManager replicationManager,
PagingManager pagingManager,
String nodeID,
boolean autoFailBack,
long initialReplicationSyncTimeout) |
Constructor and Description |
---|
PostOfficeImpl(ActiveMQServer server,
StorageManager storageManager,
PagingManager pagingManager,
QueueFactory bindableFactory,
ManagementService managementService,
long reaperPeriod,
int reaperPriority,
WildcardConfiguration wildcardConfiguration,
int idCacheSize,
boolean persistIDCache,
HierarchicalRepository<AddressSettings> addressSettingsRepository) |
Modifier and Type | Method and Description |
---|---|
PagingManager |
ActiveMQServer.createPagingManager() |
PagingManager |
ActiveMQServer.getPagingManager() |
Modifier and Type | Method and Description |
---|---|
QueueConfig.Builder |
QueueConfig.Builder.pagingManager(PagingManager pagingManager) |
Modifier and Type | Field and Description |
---|---|
protected PagingManager |
ServerSessionImpl.pagingManager |
protected PagingManager |
PostOfficeJournalLoader.pagingManager |
Modifier and Type | Method and Description |
---|---|
PagingManager |
ActiveMQServerImpl.createPagingManager() |
PagingManager |
ActiveMQServerImpl.getPagingManager() |
Modifier and Type | Method and Description |
---|---|
JournalLoader |
SharedStoreBackupActivation.createJournalLoader(PostOffice postOffice,
PagingManager pagingManager,
StorageManager storageManager,
QueueFactory queueFactory,
NodeManager nodeManager,
ManagementService managementService,
GroupingHandler groupingHandler,
Configuration configuration,
ActiveMQServer parentServer) |
JournalLoader |
SharedNothingBackupActivation.createJournalLoader(PostOffice postOffice,
PagingManager pagingManager,
StorageManager storageManager,
QueueFactory queueFactory,
NodeManager nodeManager,
ManagementService managementService,
GroupingHandler groupingHandler,
Configuration configuration,
ActiveMQServer parentServer) |
JournalLoader |
Activation.createJournalLoader(PostOffice postOffice,
PagingManager pagingManager,
StorageManager storageManager,
QueueFactory queueFactory,
NodeManager nodeManager,
ManagementService managementService,
GroupingHandler groupingHandler,
Configuration configuration,
ActiveMQServer parentServer) |
Constructor and Description |
---|
BackupRecoveryJournalLoader(PostOffice postOffice,
PagingManager pagingManager,
StorageManager storageManager,
QueueFactory queueFactory,
NodeManager nodeManager,
ManagementService managementService,
GroupingHandler groupingHandler,
Configuration configuration,
ActiveMQServer parentServer,
ServerLocatorInternal locator,
ClusterController clusterController) |
PostOfficeJournalLoader(PostOffice postOffice,
PagingManager pagingManager,
StorageManager storageManager,
QueueFactory queueFactory,
NodeManager nodeManager,
ManagementService managementService,
GroupingHandler groupingHandler,
Configuration configuration) |
PostOfficeJournalLoader(PostOffice postOffice,
PagingManager pagingManager,
StorageManager storageManager,
QueueFactory queueFactory,
NodeManager nodeManager,
ManagementService managementService,
GroupingHandler groupingHandler,
Configuration configuration,
Map<Long,Queue> queues) |
ScaleDownHandler(PagingManager pagingManager,
PostOffice postOffice,
NodeManager nodeManager,
ClusterController clusterController,
StorageManager storageManager) |
ServerInfo(ActiveMQServer server,
PagingManager pagingManager) |
ServerSessionImpl(String name,
String username,
String password,
String validatedUser,
int minLargeMessageSize,
boolean autoCommitSends,
boolean autoCommitAcks,
boolean preAcknowledge,
boolean strictUpdateDeliveryCount,
boolean xa,
RemotingConnection remotingConnection,
StorageManager storageManager,
PostOffice postOffice,
ResourceManager resourceManager,
SecurityStore securityStore,
ManagementService managementService,
ActiveMQServer server,
SimpleString managementAddress,
SimpleString defaultAddress,
SessionCallback callback,
OperationContext context,
PagingManager pagingManager,
Map<SimpleString,RoutingType> prefixes) |
Modifier and Type | Method and Description |
---|---|
ActiveMQServerControlImpl |
ManagementService.registerServer(PostOffice postOffice,
SecurityStore securityStore,
StorageManager storageManager,
Configuration configuration,
HierarchicalRepository<AddressSettings> addressSettingsRepository,
HierarchicalRepository<Set<Role>> securityRepository,
ResourceManager resourceManager,
RemotingService remotingService,
ActiveMQServer messagingServer,
QueueFactory queueFactory,
ScheduledExecutorService scheduledThreadPool,
PagingManager pagingManager,
boolean backup) |
Modifier and Type | Method and Description |
---|---|
ActiveMQServerControlImpl |
ManagementServiceImpl.registerServer(PostOffice postOffice,
SecurityStore securityStore,
StorageManager storageManager1,
Configuration configuration,
HierarchicalRepository<AddressSettings> addressSettingsRepository,
HierarchicalRepository<Set<Role>> securityRepository,
ResourceManager resourceManager,
RemotingService remotingService,
ActiveMQServer messagingServer,
QueueFactory queueFactory,
ScheduledExecutorService scheduledThreadPool,
PagingManager pagingManager,
boolean backup) |
Copyright © 2018 JBoss by Red Hat. All rights reserved.