final class ReplayWithFilter extends Product2[String, Set[ReplayPersistenceId]] 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[ReplayPersistenceId]], Product, Equals, AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. ReplayWithFilter
  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 ReplayWithFilter(streamId: String, persistenceIdOffsets: Set[ReplayPersistenceId], correlationId: UUID)

    Java API

    Java API

    Use the replayCorrelationId from the GrpcReadJournal.

  2. new ReplayWithFilter(streamId: String, persistenceIdOffsets: Set[ReplayPersistenceId])

    Java API

  3. new ReplayWithFilter(streamId: String, replayPersistenceIds: Set[ReplayPersistenceId])
  4. new ReplayWithFilter(streamId: String, replayPersistenceIds: Set[ReplayPersistenceId], correlationId: Option[UUID])

Value Members

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