| Constructor and Description |
|---|
AddressControlImpl(org.apache.activemq.artemis.api.core.SimpleString address,
PostOffice postOffice,
PagingManager pagingManager,
StorageManager storageManager,
HierarchicalRepository<Set<org.apache.activemq.artemis.core.security.Role>> securityRepository) |
| 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 |
|---|---|
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.apache.activemq.artemis.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(org.apache.activemq.artemis.api.core.SimpleString address,
ScheduledExecutorService scheduledExecutor,
long syncTimeout,
PagingManager pagingManager,
StorageManager storageManager,
org.apache.activemq.artemis.core.io.SequentialFileFactory fileFactory,
PagingStoreFactory storeFactory,
org.apache.activemq.artemis.api.core.SimpleString storeName,
AddressSettings addressSettings,
Executor executor,
boolean syncNonTransactional) |
| Modifier and Type | Method and Description |
|---|---|
org.apache.activemq.artemis.core.journal.JournalLoadInformation |
StorageManager.loadMessageJournal(PostOffice postOffice,
PagingManager pagingManager,
ResourceManager resourceManager,
Map<Long,QueueBindingInfo> queueInfos,
Map<org.apache.activemq.artemis.api.core.SimpleString,List<org.apache.activemq.artemis.api.core.Pair<byte[],Long>>> duplicateIDMap,
Set<org.apache.activemq.artemis.api.core.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 |
|---|---|
org.apache.activemq.artemis.core.journal.JournalLoadInformation |
AbstractJournalStorageManager.loadMessageJournal(PostOffice postOffice,
PagingManager pagingManager,
ResourceManager resourceManager,
Map<Long,QueueBindingInfo> queueInfos,
Map<org.apache.activemq.artemis.api.core.SimpleString,List<org.apache.activemq.artemis.api.core.Pair<byte[],Long>>> duplicateIDMap,
Set<org.apache.activemq.artemis.api.core.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 |
|---|---|
org.apache.activemq.artemis.core.journal.JournalLoadInformation |
NullStorageManager.loadMessageJournal(PostOffice postOffice,
PagingManager pagingManager,
ResourceManager resourceManager,
Map<Long,QueueBindingInfo> queueInfos,
Map<org.apache.activemq.artemis.api.core.SimpleString,List<org.apache.activemq.artemis.api.core.Pair<byte[],Long>>> duplicateIDMap,
Set<org.apache.activemq.artemis.api.core.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,
boolean enableWildCardRouting,
int idCacheSize,
boolean persistIDCache,
HierarchicalRepository<AddressSettings> addressSettingsRepository) |
| Modifier and Type | Method and Description |
|---|---|
PagingManager |
ActiveMQServer.getPagingManager() |
| Modifier and Type | Method and Description |
|---|---|
QueueConfig.Builder |
QueueConfig.Builder.pagingManager(PagingManager pagingManager) |
| Modifier and Type | Field and Description |
|---|---|
protected PagingManager |
PostOfficeJournalLoader.pagingManager |
protected PagingManager |
ServerSessionImpl.pagingManager |
| Modifier and Type | Method and Description |
|---|---|
protected PagingManager |
ActiveMQServerImpl.createPagingManager() |
PagingManager |
ActiveMQServerImpl.getPagingManager() |
| Modifier and Type | Method and Description |
|---|---|
JournalLoader |
Activation.createJournalLoader(PostOffice postOffice,
PagingManager pagingManager,
StorageManager storageManager,
QueueFactory queueFactory,
NodeManager nodeManager,
ManagementService managementService,
GroupingHandler groupingHandler,
Configuration configuration,
ActiveMQServer parentServer) |
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) |
| Constructor and Description |
|---|
BackupRecoveryJournalLoader(PostOffice postOffice,
PagingManager pagingManager,
StorageManager storageManager,
QueueFactory queueFactory,
NodeManager nodeManager,
ManagementService managementService,
GroupingHandler groupingHandler,
Configuration configuration,
ActiveMQServer parentServer,
org.apache.activemq.artemis.core.client.impl.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,
org.apache.activemq.artemis.spi.core.protocol.RemotingConnection remotingConnection,
StorageManager storageManager,
PostOffice postOffice,
ResourceManager resourceManager,
SecurityStore securityStore,
ManagementService managementService,
ActiveMQServer server,
org.apache.activemq.artemis.api.core.SimpleString managementAddress,
org.apache.activemq.artemis.api.core.SimpleString defaultAddress,
SessionCallback callback,
OperationContext context,
QueueCreator queueCreator,
PagingManager pagingManager) |
| Modifier and Type | Method and Description |
|---|---|
ActiveMQServerControlImpl |
ManagementService.registerServer(PostOffice postOffice,
SecurityStore securityStore,
StorageManager storageManager,
Configuration configuration,
HierarchicalRepository<AddressSettings> addressSettingsRepository,
HierarchicalRepository<Set<org.apache.activemq.artemis.core.security.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<org.apache.activemq.artemis.core.security.Role>> securityRepository,
ResourceManager resourceManager,
RemotingService remotingService,
ActiveMQServer messagingServer,
QueueFactory queueFactory,
ScheduledExecutorService scheduledThreadPool,
PagingManager pagingManager,
boolean backup) |
Copyright © 2023 The Apache Software Foundation. All rights reserved.