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 |
---|---|
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) |
Modifier and Type | Method and Description |
---|---|
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) |
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) |
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 |
JournalLoader.handlePreparedTransaction(Transaction tx,
List<MessageReference> referencesToAck,
Xid xid,
ResourceManager resourceManager) |
void |
PostOfficeJournalLoader.handlePreparedTransaction(Transaction tx,
List<MessageReference> referencesToAck,
Xid xid,
ResourceManager resourceManager) |
void |
BackupRecoveryJournalLoader.postLoad(Journal messageJournal,
ResourceManager resourceManager,
Map<SimpleString,List<Pair<byte[],Long>>> duplicateIDMap) |
void |
JournalLoader.postLoad(Journal messageJournal,
ResourceManager resourceManager,
Map<SimpleString,List<Pair<byte[],Long>>> duplicateIDMap) |
void |
PostOfficeJournalLoader.postLoad(Journal messageJournal,
ResourceManager resourceManager,
Map<SimpleString,List<Pair<byte[],Long>>> duplicateIDMap) |
long |
ScaleDownHandler.scaleDown(ClientSessionFactory sessionFactory,
ResourceManager resourceManager,
Map<SimpleString,List<Pair<byte[],Long>>> duplicateIDMap,
SimpleString managementAddress,
SimpleString targetNodeId) |
void |
ScaleDownHandler.scaleDownTransactions(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,
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) |
Modifier and Type | Class and Description |
---|---|
class |
ResourceManagerImpl |
Copyright © 2020 JBoss by Red Hat. All rights reserved.