Uses of Record Class
com.loomcache.server.journal.JournalEntry

Packages that use JournalEntry

Package	Description
com.loomcache.server.journal

Uses of JournalEntry in com.loomcache.server.journal

Methods in com.loomcache.server.journal that return JournalEntry

Modifier and Type	Method	Description
@Nullable JournalEntry	JournalSubscription.poll()	Poll the next entry from this subscription's buffer without blocking.

Methods in com.loomcache.server.journal that return types with arguments of type JournalEntry

Modifier and Type	Method	Description
List<JournalEntry>	EventJournal.read(long fromSequence, int maxCount)	Read entries from a starting sequence.
List<JournalEntry>	EventJournal.readByEventType(String eventType, long fromSequence, int maxCount)	Read entries filtered by event type.
List<JournalEntry>	EventJournal.readByKey(String key, long fromSequence, int maxCount)	Read entries filtered by key.

Methods in com.loomcache.server.journal with parameters of type JournalEntry

Modifier and Type	Method	Description
void	JournalSubscription.bufferDuringReplay(JournalEntry entry)	Buffer a live entry that arrived during replay.
void	JournalSubscription.markDelivered(JournalEntry entry)	Mark an entry as delivered and update stats.
boolean	JournalSubscription.offer(JournalEntry entry)	Try to offer an entry to this subscription's buffer.
void	EventListener.onEntry(JournalEntry entry)	Called when a new journal entry is available.
default void	EventListener.onError(JournalEntry entry, Throwable error)	Called when an error occurs during event delivery.
boolean	RetentionPolicy.Composite.shouldRetain(JournalEntry entry, long currentTimeNanos)
boolean	RetentionPolicy.shouldRetain(JournalEntry entry, long currentTimeNanos)	Check if an entry should be retained.
boolean	RetentionPolicy.SizeBased.shouldRetain(JournalEntry entry, long currentTimeNanos)
boolean	RetentionPolicy.TimeBased.shouldRetain(JournalEntry entry, long currentTimeNanos)