@ThreadSafe public final class FilesQueue extends Queue.Abstract
Modifier and Type | Class and Description |
---|---|
static class |
Queue.Abstract
Abstract queue.
|
static interface |
Queue.Receiver
Receiver.
|
static interface |
Queue.Sender
Sender.
|
Modifier and Type | Field and Description |
---|---|
static String |
BACKUP_PROPERTY
True will backup messages.
|
static String |
BACKUP_SUFFIX_PROPERTY
Property for file suffix of backup entries.
|
static String |
BAD_SUFFIX_PROPERTY
Property for file suffix of bad queue entries.
|
static String |
COMPRESSED_PROPERTY
True will compress message files.
|
static String |
COMPRESSED_SUFFIX_PROPERTY
Property for file suffix of compressed files.
|
static String |
DATA_SUFFIX_PROPERTY
Property for file suffix of queue data entries.
|
static String |
DEFAULT_BACKUP_SUFFIX
Default file suffix of backup entries.
|
static String |
DEFAULT_BAD_SUFFIX
Default file suffix of bad entries.
|
static String |
DEFAULT_COMPRESSED_SUFFIX
Default file suffix of compressed files.
|
static String |
DEFAULT_DATA_SUFFIX
Default file suffix of data entries.
|
static String |
DEFAULT_LOCK_SUFFIX
Default file suffix of the lock file.
|
static String |
DEFAULT_NEXT_SUFFIX
Default file suffix of next data entries.
|
static String |
DEFAULT_QUEUE_FILE_RETRIES |
static String |
DEFAULT_QUEUE_FILE_RETRY_DELAY |
static String |
DEFAULT_TRANS_SUFFIX
Default file suffix of transaction data entries.
|
static String |
DIRECTORY_PROPERTY
The directory property.
|
static String |
ENTRY_PREFIX_PROPERTY
Property for the prefix of queue entries.
|
static String |
LOCK_DISABLED_PROPERTY
The lock disabled property.
|
static String |
LOCK_SUFFIX_PROPERTY
Property for suffix of the lock file.
|
static String |
MERGE_LIMIT_PROPERTY
Merge limit property.
|
static String |
MERGE_SPLIT_PROPERTY
Merge split property.
|
static String |
NEXT_SUFFIX_PROPERTY
Property for file suffix of the next queue entry.
|
static String |
QUEUE_FILE_RETRIES
Queue file access retries system property.
|
static String |
QUEUE_FILE_RETRY_DELAY
Queue file access retry delay system property.
|
static String |
ROOT_PROPERTY
Property for the root directory of the SOM queues.
|
static String |
TRANS_SUFFIX_PROPERTY
Property for file suffix of queue transaction entries.
|
AUTOCOMMIT_PROPERTY, AUTOCOMMIT_THRESHOLD_PROPERTY, AUTOCOMMIT_TIMEOUT_PROPERTY
Modifier and Type | Method and Description |
---|---|
Optional<String> |
getBackupSuffix()
Gets the 'backup' suffix.
|
String |
getBadSuffix()
Gets the 'bad' suffix.
|
String |
getDataSuffix()
Gets the 'data' suffix.
|
File |
getDirectoryFile()
Gets the queue directory.
|
QueueInfo |
getInfo() |
String |
getNextSuffix()
Gets the 'next' suffix.
|
String |
getTransSuffix()
Gets the 'trans' suffix.
|
File[] |
listEntryFiles(String withSuffix)
Lists entry files with the specified suffix.
|
Queue.Receiver |
newReceiver() |
Queue.Sender |
newSender() |
protected void |
onReceiverClosed(Queue.Receiver receiver)
Called when the receiver is closed.
|
boolean |
setUp(KeyedValues somProperties)
Sets up this queue.
|
void |
tearDown()
Tears down what has been set up.
|
getAutocommitThreshold, getName, getStats, getThisLogger, getTimeoutMonitor, hasReceiver, isAutocommit, onNewReceiver, onNewSender, onSenderClosed
public static final String BACKUP_PROPERTY
public static final String BACKUP_SUFFIX_PROPERTY
public static final String BAD_SUFFIX_PROPERTY
public static final String COMPRESSED_PROPERTY
public static final String COMPRESSED_SUFFIX_PROPERTY
public static final String DATA_SUFFIX_PROPERTY
public static final String DEFAULT_BACKUP_SUFFIX
public static final String DEFAULT_BAD_SUFFIX
public static final String DEFAULT_COMPRESSED_SUFFIX
public static final String DEFAULT_DATA_SUFFIX
public static final String DEFAULT_LOCK_SUFFIX
public static final String DEFAULT_NEXT_SUFFIX
public static final String DEFAULT_QUEUE_FILE_RETRIES
public static final String DEFAULT_QUEUE_FILE_RETRY_DELAY
public static final String DEFAULT_TRANS_SUFFIX
public static final String DIRECTORY_PROPERTY
public static final String ENTRY_PREFIX_PROPERTY
public static final String LOCK_DISABLED_PROPERTY
public static final String LOCK_SUFFIX_PROPERTY
public static final String MERGE_LIMIT_PROPERTY
public static final String MERGE_SPLIT_PROPERTY
public static final String NEXT_SUFFIX_PROPERTY
public static final String QUEUE_FILE_RETRIES
public static final String QUEUE_FILE_RETRY_DELAY
public static final String ROOT_PROPERTY
public static final String TRANS_SUFFIX_PROPERTY
@Nonnull @CheckReturnValue public Optional<String> getBackupSuffix()
@Nonnull @CheckReturnValue public String getBadSuffix()
@Nonnull @CheckReturnValue public String getDataSuffix()
@Nonnull @CheckReturnValue public File getDirectoryFile()
public QueueInfo getInfo()
@Nonnull @CheckReturnValue public String getNextSuffix()
@Nonnull @CheckReturnValue public String getTransSuffix()
public File[] listEntryFiles(@Nonnull String withSuffix)
withSuffix
- The suffix.public Queue.Receiver newReceiver()
public Queue.Sender newSender()
public boolean setUp(KeyedValues somProperties)
setUp
in class Queue.Abstract
somProperties
- The SOM properties.public void tearDown()
tearDown
in class Queue.Abstract
protected void onReceiverClosed(Queue.Receiver receiver)
onReceiverClosed
in class Queue.Abstract
receiver
- The receiver.Copyright © 2003-2019 Serge Brisson. All Rights Reserved.