Package org.apache.pekko.persistence.query.typed.scaladsl

Interface LoadEventQuery

All Superinterfaces:
ReadJournal
public interface LoadEventQuery extends ReadJournal
EventsBySliceQuery that is using a timestamp based offset should also implement this query.

API May Change

  • Method Summary

    Modifier and Type
    Method
    Description
    <Event> scala.concurrent.Future<EventEnvelope<Event>>
    loadEnvelope(String persistenceId, long sequenceNr)
    Load a single event on demand.

  • Method Details

    • loadEnvelope

      <Event> scala.concurrent.Future<EventEnvelope<Event>> loadEnvelope(String persistenceId, long sequenceNr)
      Load a single event on demand. The Future is completed with a NoSuchElementException if the event for the given persistenceId and sequenceNr doesn't exist.