Modifier and Type | Method and Description |
---|---|
static void |
CompactJournal.compactJournal(File directory,
String journalPrefix,
String journalSuffix,
int minFiles,
int poolFiles,
int fileSize,
IOCriticalErrorListener listener,
byte... replaceableRecords) |
Modifier and Type | Field and Description |
---|---|
protected IOCriticalErrorListener |
AbstractSequentialFileFactory.critialErrorListener |
Constructor and Description |
---|
AbstractSequentialFileFactory(File journalDir,
boolean buffered,
int bufferSize,
int bufferTimeout,
int maxIO,
boolean logRates,
IOCriticalErrorListener criticalErrorListener,
CriticalAnalyzer criticalAnalyzer) |
Constructor and Description |
---|
AIOSequentialFileFactory(File journalDir,
int bufferSize,
int bufferTimeout,
int maxIO,
boolean logRates,
IOCriticalErrorListener listener,
CriticalAnalyzer analyzer) |
AIOSequentialFileFactory(File journalDir,
IOCriticalErrorListener listener,
int maxIO) |
Constructor and Description |
---|
MappedSequentialFileFactory(File directory,
int capacity,
boolean buffered,
int bufferSize,
int bufferTimeout,
IOCriticalErrorListener criticalErrorListener) |
Constructor and Description |
---|
NIOSequentialFileFactory(File journalDir,
boolean buffered,
int bufferSize,
int bufferTimeout,
int maxIO,
boolean logRates,
IOCriticalErrorListener listener,
CriticalAnalyzer analyzer) |
NIOSequentialFileFactory(File journalDir,
boolean buffered,
IOCriticalErrorListener listener,
int maxIO) |
NIOSequentialFileFactory(File journalDir,
IOCriticalErrorListener listener,
int maxIO) |
Constructor and Description |
---|
JournalImpl(ExecutorFactory ioExecutors,
int fileSize,
int minFiles,
int poolSize,
int compactMinFiles,
int compactPercentage,
int journalFileOpenTimeout,
SequentialFileFactory fileFactory,
String filePrefix,
String fileExtension,
int maxAIO,
int userVersion,
IOCriticalErrorListener criticalErrorListener,
int maxAtticFiles) |
Modifier and Type | Method and Description |
---|---|
IOCriticalErrorListener |
PagingStoreFactoryNIO.getCritialErrorListener() |
Constructor and Description |
---|
PagingStoreFactoryDatabase(DatabaseStorageConfiguration dbConf,
StorageManager storageManager,
long syncTimeout,
ScheduledExecutorService scheduledExecutor,
ExecutorFactory executorFactory,
boolean syncNonTransactional,
IOCriticalErrorListener criticalErrorListener) |
PagingStoreFactoryDatabase(DatabaseStorageConfiguration dbConf,
StorageManager storageManager,
long syncTimeout,
ScheduledExecutorService scheduledExecutor,
ExecutorFactory executorFactory,
boolean syncNonTransactional,
IOCriticalErrorListener criticalErrorListener,
boolean readWholePage) |
PagingStoreFactoryNIO(StorageManager storageManager,
File directory,
long syncTimeout,
ScheduledExecutorService scheduledExecutor,
ExecutorFactory executorFactory,
boolean syncNonTransactional,
IOCriticalErrorListener critialErrorListener) |
PagingStoreFactoryNIO(StorageManager storageManager,
File directory,
long syncTimeout,
ScheduledExecutorService scheduledExecutor,
ExecutorFactory executorFactory,
boolean syncNonTransactional,
IOCriticalErrorListener critialErrorListener,
boolean readWholePage) |
Modifier and Type | Field and Description |
---|---|
protected IOCriticalErrorListener |
AbstractJournalStorageManager.ioCriticalErrorListener |
Modifier and Type | Method and Description |
---|---|
protected Journal |
JournalStorageManager.createMessageJournal(Configuration config,
IOCriticalErrorListener criticalErrorListener,
int fileSize) |
protected void |
JDBCJournalStorageManager.init(Configuration config,
IOCriticalErrorListener criticalErrorListener) |
protected abstract void |
AbstractJournalStorageManager.init(Configuration config,
IOCriticalErrorListener criticalErrorListener)
Called during initialization.
|
protected void |
JournalStorageManager.init(Configuration config,
IOCriticalErrorListener criticalErrorListener) |
Constructor and Description |
---|
NullStorageManager(IOCriticalErrorListener ioCriticalErrorListener) |
Modifier and Type | Method and Description |
---|---|
void |
ReplicationManager.sendSynchronizationDone(String nodeID,
long initialReplicationSyncTimeout,
IOCriticalErrorListener criticalErrorListener)
Informs backup that data synchronization is done.
|
Constructor and Description |
---|
ReplicationEndpoint(ActiveMQServerImpl server,
IOCriticalErrorListener criticalErrorListener,
boolean wantedFailBack,
SharedNothingBackupActivation activation) |
Modifier and Type | Method and Description |
---|---|
LiveActivation |
ColocatedPolicy.createActivation(ActiveMQServerImpl server,
boolean wasLive,
Map<String,Object> activationParams,
IOCriticalErrorListener ioCriticalErrorListener) |
T |
HAPolicy.createActivation(ActiveMQServerImpl server,
boolean wasLive,
Map<String,Object> activationParams,
IOCriticalErrorListener shutdownOnCriticalIO) |
Activation |
LiveOnlyPolicy.createActivation(ActiveMQServerImpl server,
boolean wasLive,
Map<String,Object> activationParams,
IOCriticalErrorListener ioCriticalErrorListener) |
Activation |
ReplicaPolicy.createActivation(ActiveMQServerImpl server,
boolean wasLive,
Map<String,Object> activationParams,
IOCriticalErrorListener ioCriticalErrorListener) |
LiveActivation |
ReplicatedPolicy.createActivation(ActiveMQServerImpl server,
boolean wasLive,
Map<String,Object> activationParams,
IOCriticalErrorListener ioCriticalErrorListener) |
LiveActivation |
SharedStoreMasterPolicy.createActivation(ActiveMQServerImpl server,
boolean wasLive,
Map<String,Object> activationParams,
IOCriticalErrorListener ioCriticalErrorListener) |
Activation |
SharedStoreSlavePolicy.createActivation(ActiveMQServerImpl server,
boolean wasLive,
Map<String,Object> activationParams,
IOCriticalErrorListener ioCriticalErrorListener) |
Constructor and Description |
---|
FileStoreMonitor(ScheduledExecutorService scheduledExecutorService,
Executor executor,
long checkPeriod,
TimeUnit timeUnit,
double maxUsage,
IOCriticalErrorListener ioCriticalErrorListener) |
Modifier and Type | Class and Description |
---|---|
class |
ActiveMQServerImpl.DefaultCriticalErrorListener |
Modifier and Type | Field and Description |
---|---|
protected IOCriticalErrorListener |
ActiveMQServerImpl.ioCriticalErrorListener |
Constructor and Description |
---|
SharedNothingBackupActivation(ActiveMQServerImpl activeMQServer,
boolean attemptFailBack,
Map<String,Object> activationParams,
IOCriticalErrorListener ioCriticalErrorListener,
ReplicaPolicy replicaPolicy,
NetworkHealthCheck networkHealthCheck) |
SharedStoreBackupActivation(ActiveMQServerImpl server,
SharedStoreSlavePolicy sharedStoreSlavePolicy,
IOCriticalErrorListener ioCriticalErrorListener) |
SharedStoreLiveActivation(ActiveMQServerImpl server,
SharedStoreMasterPolicy sharedStoreMasterPolicy,
IOCriticalErrorListener ioCriticalErrorListener) |
Constructor and Description |
---|
JDBCSequentialFileFactory(JDBCConnectionProvider connectionProvider,
SQLProvider sqlProvider,
Executor executor,
IOCriticalErrorListener criticalErrorListener) |
Constructor and Description |
---|
JDBCJournalImpl(JDBCConnectionProvider connectionProvider,
SQLProvider provider,
ScheduledExecutorService scheduledExecutorService,
Executor completeExecutor,
IOCriticalErrorListener criticalIOErrorListener,
long syncDelay) |
Copyright © 2021 JBoss by Red Hat. All rights reserved.