| Package | Description |
|---|---|
| com.atlassian.confluence.api.model.journal | |
| com.atlassian.confluence.api.service.journal | |
| com.atlassian.confluence.impl.journal |
Provides implementation of Journal Service.
|
| com.atlassian.confluence.plugin.descriptor | |
| com.atlassian.confluence.search | |
| com.atlassian.confluence.search.lucene.tasks | |
| com.atlassian.confluence.search.queue |
| Modifier and Type | Method and Description |
|---|---|
JournalIdentifier |
JournalEntry.getJournalId() |
| Constructor and Description |
|---|
JournalEntry(JournalIdentifier journalId,
String type,
String message)
Creates a new journal entry for persisting.
|
JournalEntry(long id,
JournalIdentifier journalId,
Date creationDate,
String type,
String message)
Creates a new journal entry describing an entry that has been persisted
|
| Modifier and Type | Method and Description |
|---|---|
int |
JournalService.countEntries(JournalIdentifier journalId)
Counts the number of entries in a journal.
|
Iterable<JournalEntry> |
JournalService.peek(JournalIdentifier journalId,
int maxEntries)
Return a copy of journal entries that are waiting to be processed.
|
<V> V |
JournalService.processEntries(JournalIdentifier journalId,
int maxEntries,
com.google.common.base.Function<Iterable<JournalEntry>,EntryProcessorResult<V>> entryProcessor)
Processes journal entries that were added since the last time this
method was called for this journal on this cluster node.
|
void |
JournalService.reset(JournalIdentifier journalId)
Resets the state of the journal so that all entries currently in the
journal will be skipped.
|
| Modifier and Type | Method and Description |
|---|---|
JournalIdentifier |
JournalEntry.getJournalId() |
JournalIdentifier |
JournalIdentifierUserType.nullSafeGet(ResultSet rs,
String[] columns,
Object owner) |
| Modifier and Type | Method and Description |
|---|---|
int |
JournalManager.countEntries(JournalIdentifier journalId)
Counts the number of entries in a journal.
|
int |
DefaultJournalService.countEntries(JournalIdentifier journalId) |
int |
DefaultJournalManager.countEntries(JournalIdentifier journalId) |
int |
JournalDao.countEntries(JournalIdentifier journalId,
long afterId,
long ignoreWithinMillis)
Counts the number of entries in a journal.
|
int |
HibernateJournalDao.countEntries(JournalIdentifier journalId,
long afterId,
long ignoreWithinMillis) |
List<JournalEntry> |
JournalDao.findEntries(JournalIdentifier journalId,
long afterId,
long ignoreWithinMillis,
int maxEntries)
Finds journal entries that were added after an entry with the given id
but earlier than given milliseconds ago.
|
List<JournalEntry> |
HibernateJournalDao.findEntries(JournalIdentifier journalId,
long afterId,
long ignoreWithinMillis,
int maxEntries) |
com.atlassian.fugue.Option<JournalEntry> |
JournalDao.findLatestEntry(JournalIdentifier journalId,
long ignoreWithinMillis)
Finds the latest journal entry if any.
|
com.atlassian.fugue.Option<JournalEntry> |
HibernateJournalDao.findLatestEntry(JournalIdentifier journalId,
long ignoreWithinMillis) |
com.atlassian.fugue.Option<JournalEntry> |
JournalDao.findMostRecentEntryByMessage(JournalIdentifier journalId,
String message)
Finds the most recent journal entry (if any) for the given journal that
exactly matches the given journal entry message.
|
com.atlassian.fugue.Option<JournalEntry> |
HibernateJournalDao.findMostRecentEntryByMessage(JournalIdentifier journalId,
String message) |
long |
JournalStateStore.getMostRecentId(JournalIdentifier journalId)
Returns the most recent id for a journal or 0 if no id has
been stored yet.
|
long |
FilesystemJournalStateStore.getMostRecentId(JournalIdentifier journalId) |
long |
CachingJournalStateStore.getMostRecentId(JournalIdentifier journalId) |
long |
BandanaJournalStateStore.getMostRecentId(JournalIdentifier journalId) |
Iterable<JournalEntry> |
JournalManager.peek(JournalIdentifier journalId,
int maxEntries)
Return a copy of journal entries that are waiting to be processed.
|
Iterable<JournalEntry> |
DefaultJournalService.peek(JournalIdentifier journalId,
int maxEntries) |
Iterable<JournalEntry> |
DefaultJournalManager.peek(JournalIdentifier journalId,
int maxEntries) |
<V> V |
JournalManager.processEntries(JournalIdentifier journalId,
int maxEntries,
com.google.common.base.Function<Iterable<JournalEntry>,EntryProcessorResult<V>> entryProcessor)
Processes journal entries that were added since the last time this
method was called for this journal on this cluster node.
|
<V> V |
DefaultJournalService.processEntries(JournalIdentifier journalId,
int maxEntries,
com.google.common.base.Function<Iterable<JournalEntry>,EntryProcessorResult<V>> entryProcessor) |
<V> V |
DefaultJournalManager.processEntries(JournalIdentifier journalId,
int maxEntries,
com.google.common.base.Function<Iterable<JournalEntry>,EntryProcessorResult<V>> entryProcessor) |
void |
JournalManager.reset(JournalIdentifier journalId)
Resets the state of the journal so that all entries currently in the
journal will be skipped.
|
void |
DefaultJournalService.reset(JournalIdentifier journalId) |
void |
DefaultJournalManager.reset(JournalIdentifier journalId) |
void |
JournalEntry.setJournalId(JournalIdentifier journalId) |
void |
JournalStateStore.setMostRecentId(JournalIdentifier journalId,
long id)
Set the most recent identifier for a journal.
|
void |
FilesystemJournalStateStore.setMostRecentId(JournalIdentifier journalId,
long id) |
void |
CachingJournalStateStore.setMostRecentId(JournalIdentifier journalId,
long id) |
void |
BandanaJournalStateStore.setMostRecentId(JournalIdentifier journalId,
long id) |
| Constructor and Description |
|---|
JournalEntry(JournalIdentifier journalId,
String type,
String message)
Creates a new journal entry.
|
| Modifier and Type | Method and Description |
|---|---|
JournalIdentifier |
IndexRecovererModuleDescriptor.getJournalId()
Deprecated.
|
| Modifier and Type | Method and Description |
|---|---|
Optional<JournalEntry> |
ConvertibleToJournalEntry.convertToJournalEntry(JournalIdentifier journalId)
Convert to journal entry.
|
| Modifier and Type | Field and Description |
|---|---|
static JournalIdentifier |
AbstractJournalIndexTaskQueue.JOURNAL_ID |
| Modifier and Type | Method and Description |
|---|---|
static Optional<JournalEntry> |
JournalEntryFactory.createJournalEntry(JournalIdentifier journalId,
JournalEntryType journalEntryType,
String message) |
Copyright © 2003–2016 Atlassian. All rights reserved.