Modifier and Type | Class and Description |
---|---|
class |
AbstractSequentialFile |
Modifier and Type | Method and Description |
---|---|
SequentialFile |
SequentialFile.cloneFile() |
SequentialFile |
SequentialFileFactory.createSequentialFile(String fileName) |
Modifier and Type | Method and Description |
---|---|
void |
AbstractSequentialFileFactory.activateBuffer(SequentialFile file) |
void |
SequentialFileFactory.activateBuffer(SequentialFile file) |
void |
AbstractSequentialFile.copyTo(SequentialFile newFileName) |
void |
SequentialFile.copyTo(SequentialFile newFileName) |
void |
AbstractSequentialFileFactory.onIOError(Exception exception,
String message,
SequentialFile file) |
void |
SequentialFileFactory.onIOError(Exception exception,
String message,
SequentialFile file)
The SequentialFile will call this method when a disk IO Error happens during the live phase.
|
void |
IOCriticalErrorListener.onIOException(Throwable code,
String message,
SequentialFile file) |
Modifier and Type | Class and Description |
---|---|
class |
AIOSequentialFile
This class is implementing Runnable to reuse a callback to close it.
|
Modifier and Type | Method and Description |
---|---|
SequentialFile |
AIOSequentialFile.cloneFile() |
SequentialFile |
AIOSequentialFileFactory.createSequentialFile(String fileName) |
Modifier and Type | Method and Description |
---|---|
SequentialFile |
MappedSequentialFileFactory.createSequentialFile(String fileName) |
Modifier and Type | Class and Description |
---|---|
class |
NIOSequentialFile |
Modifier and Type | Method and Description |
---|---|
SequentialFile |
NIOSequentialFile.cloneFile() |
SequentialFile |
NIOSequentialFileFactory.createSequentialFile(String fileName) |
Modifier and Type | Method and Description |
---|---|
void |
NIOSequentialFile.copyTo(SequentialFile dstFile) |
Modifier and Type | Method and Description |
---|---|
static void |
FileIOUtil.copyData(SequentialFile from,
SequentialFile to,
ByteBuffer buffer) |
Modifier and Type | Field and Description |
---|---|
protected SequentialFile |
AbstractJournalUpdateTask.sequentialFile |
Modifier and Type | Method and Description |
---|---|
protected SequentialFile |
JournalImpl.createControlFile(List<JournalFile> files,
List<JournalFile> newFiles,
Pair<String,String> cleanupRename) |
SequentialFile |
JournalFile.getFile() |
SequentialFile |
JournalFileImpl.getFile() |
static SequentialFile |
AbstractJournalUpdateTask.readControlFile(SequentialFileFactory fileFactory,
List<String> dataFiles,
List<String> newFiles,
List<Pair<String,String>> renameFile) |
static SequentialFile |
AbstractJournalUpdateTask.writeControlFile(SequentialFileFactory fileFactory,
List<JournalFile> files,
List<JournalFile> newFiles,
List<Pair<String,String>> renames) |
protected SequentialFile |
JournalImpl.writeControlFile(SequentialFileFactory fileFactory,
List<JournalFile> files,
List<JournalFile> newFiles,
List<Pair<String,String>> renames) |
Modifier and Type | Method and Description |
---|---|
protected void |
JournalImpl.deleteControlFile(SequentialFile controlFile) |
static int |
JournalImpl.initFileHeader(SequentialFileFactory fileFactory,
SequentialFile sequentialFile,
int userVersion,
long fileID) |
Constructor and Description |
---|
JournalFileImpl(SequentialFile file,
long fileID,
int version) |
Modifier and Type | Method and Description |
---|---|
SequentialFile |
Page.getFile() |
Constructor and Description |
---|
Page(SimpleString storeName,
StorageManager storageManager,
SequentialFileFactory factory,
SequentialFile file,
int pageId) |
Modifier and Type | Method and Description |
---|---|
default SequentialFile |
StorageManager.createFileForLargeMessage(long messageID,
boolean durable) |
SequentialFile |
StorageManager.createFileForLargeMessage(long messageID,
StorageManager.LargeMessageExtension extension)
Instantiates a SequentialFile to be used for storing a
LargeServerMessage . |
Modifier and Type | Method and Description |
---|---|
void |
StorageManager.addBytesToLargeMessage(SequentialFile file,
long messageId,
ActiveMQBuffer bytes) |
void |
StorageManager.addBytesToLargeMessage(SequentialFile appendFile,
long messageID,
byte[] bytes) |
Modifier and Type | Method and Description |
---|---|
SequentialFile |
LargeBody.createFile() |
SequentialFile |
JournalStorageManager.createFileForLargeMessage(long messageID,
StorageManager.LargeMessageExtension extension) |
SequentialFile |
LargeBody.getAppendFile() |
SequentialFile |
LargeServerMessageImpl.getAppendFile() |
SequentialFile |
LargeBody.getReadingFile()
This will return its own File useful for reading the file on the large message while delivering, browsing..
|
SequentialFile |
LargeServerMessageInSync.getSyncFile() |
Modifier and Type | Method and Description |
---|---|
void |
JournalStorageManager.addBytesToLargeMessage(SequentialFile file,
long messageId,
ActiveMQBuffer bytes) |
void |
JournalStorageManager.addBytesToLargeMessage(SequentialFile file,
long messageId,
byte[] bytes) |
void |
LargeBody.replaceFile(SequentialFile file)
Meant for test-ability, be careful if you decide to use it.
|
Constructor and Description |
---|
LargeBody(LargeServerMessage message,
StorageManager storageManager,
SequentialFile file) |
LargeServerMessageImpl(byte type,
long id,
StorageManager storageManager,
SequentialFile fileCopy) |
LargeServerMessageImpl(LargeServerMessageImpl copy,
TypedProperties properties,
SequentialFile fileCopy,
long newID)
Copy constructor
|
Modifier and Type | Method and Description |
---|---|
SequentialFile |
NullStorageManager.createFileForLargeMessage(long messageID,
StorageManager.LargeMessageExtension extension) |
Modifier and Type | Method and Description |
---|---|
void |
NullStorageManager.addBytesToLargeMessage(SequentialFile file,
long messageId,
ActiveMQBuffer bytes) |
void |
NullStorageManager.addBytesToLargeMessage(SequentialFile appendFile,
long messageID,
byte[] bytes) |
Modifier and Type | Method and Description |
---|---|
void |
ReplicationManager.syncLargeMessageFile(SequentialFile file,
long size,
long id) |
void |
ReplicationManager.syncPages(SequentialFile file,
long id,
SimpleString queueName) |
Modifier and Type | Method and Description |
---|---|
SequentialFile |
LargeServerMessage.getAppendFile()
This will return the File suitable for appending the message
|
Modifier and Type | Method and Description |
---|---|
ActiveMQIOErrorException |
ActiveMQMessageBundle.cannotWriteToClosedFile(SequentialFile file) |
ActiveMQIOErrorException |
ActiveMQMessageBundle_$bundle.cannotWriteToClosedFile(SequentialFile file) |
void |
ActiveMQServerLogger.replicaSyncFile(SequentialFile jf,
Long size) |
void |
ActiveMQServerLogger_$logger.replicaSyncFile(SequentialFile jf,
Long size) |
Modifier and Type | Method and Description |
---|---|
void |
ActiveMQServerImpl.DefaultCriticalErrorListener.onIOException(Throwable cause,
String message,
SequentialFile file) |
Modifier and Type | Class and Description |
---|---|
class |
JDBCSequentialFile |
Modifier and Type | Method and Description |
---|---|
SequentialFile |
JDBCSequentialFile.cloneFile() |
SequentialFile |
JDBCSequentialFileFactory.createSequentialFile(String fileName) |
Modifier and Type | Method and Description |
---|---|
void |
JDBCSequentialFileFactory.activateBuffer(SequentialFile file) |
void |
JDBCSequentialFile.copyTo(SequentialFile cloneFile) |
void |
JDBCSequentialFileFactory.onIOError(Exception exception,
String message,
SequentialFile file) |
void |
JDBCSequentialFileFactory.sequentialFileClosed(SequentialFile file) |
Copyright © 2021 JBoss by Red Hat. All rights reserved.