final class Replay extends Product2[String, Set[PersistenceIdOffset]] with SubscriberCommand with Serializable

Explicit request to replay events for given entities.

Use the replayCorrelationId from the GrpcReadJournal.

Source
ConsumerFilter.scala
Linear Supertypes
Serializable, SubscriberCommand, Command, Product2[String, Set[PersistenceIdOffset]], Product, Equals, AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. Replay
  2. Serializable
  3. SubscriberCommand
  4. Command
  5. Product2
  6. Product
  7. Equals
  8. AnyRef
  9. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Instance Constructors

  1. new Replay(streamId: String, persistenceIdOffsets: Set[PersistenceIdOffset], correlationId: UUID)

    Java API

    Java API

    Use the replayCorrelationId from the GrpcReadJournal.

  2. new Replay(streamId: String, persistenceIdOffsets: Set[PersistenceIdOffset])

    Java API

  3. new Replay(streamId: String, persistenceIdOffsets: Set[PersistenceIdOffset])
  4. new Replay(streamId: String, persistenceIdOffsets: Set[PersistenceIdOffset], correlationId: Option[UUID])

Value Members

  1. def _1: String
    Definition Classes
    Replay → Product2
  2. def _2: Set[PersistenceIdOffset]
    Definition Classes
    Replay → Product2
  3. def canEqual(that: Any): Boolean
    Definition Classes
    Replay → Equals
  4. def copy(streamId: String = streamId, persistenceIdOffsets: Set[PersistenceIdOffset] = persistenceIdOffsets): Replay
  5. val correlationId: Option[UUID]
  6. def equals(obj: Any): Boolean
    Definition Classes
    Replay → Equals → AnyRef → Any
  7. def hashCode(): Int
    Definition Classes
    Replay → AnyRef → Any
  8. val persistenceIdOffsets: Set[PersistenceIdOffset]
  9. def productArity: Int
    Definition Classes
    Product2 → Product
  10. def productElement(n: Int): Any
    Definition Classes
    Product2 → Product
    Annotations
    @throws(classOf[java.lang.IndexOutOfBoundsException])
  11. def productElementName(n: Int): String
    Definition Classes
    Product
  12. def productElementNames: Iterator[String]
    Definition Classes
    Product
  13. def productIterator: Iterator[Any]
    Definition Classes
    Product
  14. def productPrefix: String
    Definition Classes
    Replay → Product
  15. val streamId: String
    Definition Classes
    Replay → SubscriberCommand
  16. def toReplayWithFilter: ReplayWithFilter
  17. def toString(): String
    Definition Classes
    Replay → AnyRef → Any