Uses of Record Class
com.loomcache.server.journal.JournalEntry
Packages that use JournalEntry
-
Uses of JournalEntry in com.loomcache.server.journal
Methods in com.loomcache.server.journal that return JournalEntryModifier and TypeMethodDescription@Nullable JournalEntryJournalSubscription.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 JournalEntryModifier and TypeMethodDescriptionEventJournal.read(long fromSequence, int maxCount) Read entries from a starting sequence.EventJournal.readByEventType(String eventType, long fromSequence, int maxCount) Read entries filtered by event type.Read entries filtered by key.Methods in com.loomcache.server.journal with parameters of type JournalEntryModifier and TypeMethodDescriptionvoidJournalSubscription.bufferDuringReplay(JournalEntry entry) Buffer a live entry that arrived during replay.voidJournalSubscription.markDelivered(JournalEntry entry) Mark an entry as delivered and update stats.booleanJournalSubscription.offer(JournalEntry entry) Try to offer an entry to this subscription's buffer.voidEventListener.onEntry(JournalEntry entry) Called when a new journal entry is available.default voidEventListener.onError(JournalEntry entry, Throwable error) Called when an error occurs during event delivery.booleanRetentionPolicy.Composite.shouldRetain(JournalEntry entry, long currentTimeNanos) booleanRetentionPolicy.shouldRetain(JournalEntry entry, long currentTimeNanos) Check if an entry should be retained.booleanRetentionPolicy.SizeBased.shouldRetain(JournalEntry entry, long currentTimeNanos) booleanRetentionPolicy.TimeBased.shouldRetain(JournalEntry entry, long currentTimeNanos)