| Constructor and Description |
|---|
ActiveMQServerControlImpl(PostOffice postOffice,
Configuration configuration,
ResourceManager resourceManager,
RemotingService remotingService,
ActiveMQServer messagingServer,
MessageCounterManager messageCounterManager,
StorageManager storageManager,
NotificationBroadcasterSupport broadcaster) |
| 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) |
| 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) |
| 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) |
| Modifier and Type | Method and Description |
|---|---|
ResourceManager |
ActiveMQServer.getResourceManager() |
| Modifier and Type | Method and Description |
|---|---|
ResourceManager |
ActiveMQServerImpl.getResourceManager() |
| Modifier and Type | Method and Description |
|---|---|
void |
PostOfficeJournalLoader.handlePreparedTransaction(Transaction tx,
List<MessageReference> referencesToAck,
Xid xid,
ResourceManager resourceManager) |
void |
JournalLoader.handlePreparedTransaction(Transaction tx,
List<MessageReference> referencesToAck,
Xid xid,
ResourceManager resourceManager) |
void |
PostOfficeJournalLoader.postLoad(org.apache.activemq.artemis.core.journal.Journal messageJournal,
ResourceManager resourceManager,
Map<org.apache.activemq.artemis.api.core.SimpleString,List<org.apache.activemq.artemis.api.core.Pair<byte[],Long>>> duplicateIDMap) |
void |
BackupRecoveryJournalLoader.postLoad(org.apache.activemq.artemis.core.journal.Journal messageJournal,
ResourceManager resourceManager,
Map<org.apache.activemq.artemis.api.core.SimpleString,List<org.apache.activemq.artemis.api.core.Pair<byte[],Long>>> duplicateIDMap) |
void |
JournalLoader.postLoad(org.apache.activemq.artemis.core.journal.Journal messageJournal,
ResourceManager resourceManager,
Map<org.apache.activemq.artemis.api.core.SimpleString,List<org.apache.activemq.artemis.api.core.Pair<byte[],Long>>> duplicateIDMap) |
long |
ScaleDownHandler.scaleDown(org.apache.activemq.artemis.api.core.client.ClientSessionFactory sessionFactory,
ResourceManager resourceManager,
Map<org.apache.activemq.artemis.api.core.SimpleString,List<org.apache.activemq.artemis.api.core.Pair<byte[],Long>>> duplicateIDMap,
org.apache.activemq.artemis.api.core.SimpleString managementAddress,
org.apache.activemq.artemis.api.core.SimpleString targetNodeId) |
void |
ScaleDownHandler.scaleDownTransactions(org.apache.activemq.artemis.api.core.client.ClientSessionFactory sessionFactory,
ResourceManager resourceManager,
String user,
String password) |
| Constructor and Description |
|---|
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) |
| Modifier and Type | Class and Description |
|---|---|
class |
ResourceManagerImpl |
Copyright © 2023 The Apache Software Foundation. All rights reserved.