Class/Object

com.rbmhtechnology.eventuate

DurableEvent

Related Docs: object DurableEvent | package eventuate

Permalink

case class DurableEvent(payload: Any, emitterId: String = DurableEvent.UndefinedEmittedId, emitterAggregateId: Option[String] = None, customDestinationAggregateIds: Set[String] = Set(), systemTimestamp: Long = 0L, vectorTimestamp: VectorTime = VectorTime.Zero, processId: String = DurableEvent.UndefinedLogId, localLogId: String = DurableEvent.UndefinedLogId, localSequenceNr: Long = DurableEvent.UndefinedSequenceNr, deliveryId: Option[String] = None, persistOnEventSequenceNr: Option[Long] = None, persistOnEventId: Option[EventId] = None) extends Product with Serializable

Provider API.

Event storage format. Fields localLogId and localSequenceNr differ among replicas, all other fields are not changed during event replication.

payload

Application-defined event.

emitterId

Id of emitter (EventsourcedActor or EventsourcedProcessor).

emitterAggregateId

Aggregate id of emitter (EventsourcedActor or EventsourcedProcessor). This is also the default routing destination of this event. If defined, the event is routed to event- sourced actors, views, writers and processors with a matching aggregateId. In any case, the event is routed to event-sourced actors, views, writers and processors with an undefined aggregateId.

customDestinationAggregateIds

Aggregate ids of additional, custom routing destinations. If non-empty, the event is additionally routed to event-sourced actors, views, writers and processors with a matching aggregateId.

systemTimestamp

Wall-clock timestamp, generated by the source of concurrent activity that is identified by processId.

vectorTimestamp

Vector timestamp, generated by the source of concurrent activity that is identified by processId.

processId

Id of the causality-tracking source of concurrent activity. This is the id of the local event log that initially wrote the event.

localLogId

Id of the local event log.

localSequenceNr

Sequence number in the local event log.

deliveryId

Delivery id chosen by an application that persisted this event with ConfirmedDelivery.persistConfirmation.

persistOnEventSequenceNr

Sequence number of the event that caused the emission of this event in an event handler. Defined if an EventsourcedActor with a PersistOnEvent mixin emitted this event with persistOnEvent. Actually superseded by persistOnEventId, but still has to be maintained for backwards compatibility. It is required for confirmation of old com.rbmhtechnology.eventuate.PersistOnEvent.PersistOnEventRequests from a snapshot that do not have com.rbmhtechnology.eventuate.PersistOnEvent.PersistOnEventRequest.persistOnEventId set.

persistOnEventId

event id of the event that caused the emission of this event in an event handler. Defined if an EventsourcedActor with a PersistOnEvent mixin emitted this event with persistOnEvent.

Linear Supertypes
Serializable, Serializable, Product, Equals, AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. DurableEvent
  2. Serializable
  3. Serializable
  4. Product
  5. Equals
  6. AnyRef
  7. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Instance Constructors

  1. new DurableEvent(payload: Any, emitterId: String = DurableEvent.UndefinedEmittedId, emitterAggregateId: Option[String] = None, customDestinationAggregateIds: Set[String] = Set(), systemTimestamp: Long = 0L, vectorTimestamp: VectorTime = VectorTime.Zero, processId: String = DurableEvent.UndefinedLogId, localLogId: String = DurableEvent.UndefinedLogId, localSequenceNr: Long = DurableEvent.UndefinedSequenceNr, deliveryId: Option[String] = None, persistOnEventSequenceNr: Option[Long] = None, persistOnEventId: Option[EventId] = None)

    Permalink

    payload

    Application-defined event.

    emitterId

    Id of emitter (EventsourcedActor or EventsourcedProcessor).

    emitterAggregateId

    Aggregate id of emitter (EventsourcedActor or EventsourcedProcessor). This is also the default routing destination of this event. If defined, the event is routed to event- sourced actors, views, writers and processors with a matching aggregateId. In any case, the event is routed to event-sourced actors, views, writers and processors with an undefined aggregateId.

    customDestinationAggregateIds

    Aggregate ids of additional, custom routing destinations. If non-empty, the event is additionally routed to event-sourced actors, views, writers and processors with a matching aggregateId.

    systemTimestamp

    Wall-clock timestamp, generated by the source of concurrent activity that is identified by processId.

    vectorTimestamp

    Vector timestamp, generated by the source of concurrent activity that is identified by processId.

    processId

    Id of the causality-tracking source of concurrent activity. This is the id of the local event log that initially wrote the event.

    localLogId

    Id of the local event log.

    localSequenceNr

    Sequence number in the local event log.

    deliveryId

    Delivery id chosen by an application that persisted this event with ConfirmedDelivery.persistConfirmation.

    persistOnEventSequenceNr

    Sequence number of the event that caused the emission of this event in an event handler. Defined if an EventsourcedActor with a PersistOnEvent mixin emitted this event with persistOnEvent. Actually superseded by persistOnEventId, but still has to be maintained for backwards compatibility. It is required for confirmation of old com.rbmhtechnology.eventuate.PersistOnEvent.PersistOnEventRequests from a snapshot that do not have com.rbmhtechnology.eventuate.PersistOnEvent.PersistOnEventRequest.persistOnEventId set.

    persistOnEventId

    event id of the event that caused the emission of this event in an event handler. Defined if an EventsourcedActor with a PersistOnEvent mixin emitted this event with persistOnEvent.

Value Members

  1. final def !=(arg0: Any): Boolean

    Permalink
    Definition Classes
    AnyRef → Any
  2. final def ##(): Int

    Permalink
    Definition Classes
    AnyRef → Any
  3. final def ==(arg0: Any): Boolean

    Permalink
    Definition Classes
    AnyRef → Any
  4. final def asInstanceOf[T0]: T0

    Permalink
    Definition Classes
    Any
  5. def before(vectorTime: VectorTime): Boolean

    Permalink

    Returns true if this event happened before or at the given vectorTime.

  6. def clone(): AnyRef

    Permalink
    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  7. val customDestinationAggregateIds: Set[String]

    Permalink

    Aggregate ids of additional, custom routing destinations.

    Aggregate ids of additional, custom routing destinations. If non-empty, the event is additionally routed to event-sourced actors, views, writers and processors with a matching aggregateId.

  8. def defaultDestinationAggregateId: Option[String]

    Permalink

    The default routing destination of this event is its emitterAggregateId.

    The default routing destination of this event is its emitterAggregateId. If defined, the event is routed to event-sourced actors, views, writers and processors with a matching aggregateId. In any case, the event is routed to event-sourced actors, views, writers and processors with an undefined aggregateId.

  9. val deliveryId: Option[String]

    Permalink

    Delivery id chosen by an application that persisted this event with ConfirmedDelivery.persistConfirmation.

  10. def destinationAggregateIds: Set[String]

    Permalink

    The union of defaultDestinationAggregateId and customDestinationAggregateIds.

  11. val emitterAggregateId: Option[String]

    Permalink

    Aggregate id of emitter (EventsourcedActor or EventsourcedProcessor).

    Aggregate id of emitter (EventsourcedActor or EventsourcedProcessor). This is also the default routing destination of this event. If defined, the event is routed to event- sourced actors, views, writers and processors with a matching aggregateId. In any case, the event is routed to event-sourced actors, views, writers and processors with an undefined aggregateId.

  12. val emitterId: String

    Permalink

    Id of emitter (EventsourcedActor or EventsourcedProcessor).

  13. final def eq(arg0: AnyRef): Boolean

    Permalink
    Definition Classes
    AnyRef
  14. def finalize(): Unit

    Permalink
    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( classOf[java.lang.Throwable] )
  15. final def getClass(): Class[_]

    Permalink
    Definition Classes
    AnyRef → Any
  16. val id: EventId

    Permalink

    Unique event identifier.

  17. final def isInstanceOf[T0]: Boolean

    Permalink
    Definition Classes
    Any
  18. val localLogId: String

    Permalink

    Id of the local event log.

  19. val localSequenceNr: Long

    Permalink

    Sequence number in the local event log.

  20. final def ne(arg0: AnyRef): Boolean

    Permalink
    Definition Classes
    AnyRef
  21. final def notify(): Unit

    Permalink
    Definition Classes
    AnyRef
  22. final def notifyAll(): Unit

    Permalink
    Definition Classes
    AnyRef
  23. val payload: Any

    Permalink

    Application-defined event.

  24. val persistOnEventId: Option[EventId]

    Permalink

    event id of the event that caused the emission of this event in an event handler.

    event id of the event that caused the emission of this event in an event handler. Defined if an EventsourcedActor with a PersistOnEvent mixin emitted this event with persistOnEvent.

  25. val persistOnEventSequenceNr: Option[Long]

    Permalink

    Sequence number of the event that caused the emission of this event in an event handler.

    Sequence number of the event that caused the emission of this event in an event handler. Defined if an EventsourcedActor with a PersistOnEvent mixin emitted this event with persistOnEvent. Actually superseded by persistOnEventId, but still has to be maintained for backwards compatibility. It is required for confirmation of old com.rbmhtechnology.eventuate.PersistOnEvent.PersistOnEventRequests from a snapshot that do not have com.rbmhtechnology.eventuate.PersistOnEvent.PersistOnEventRequest.persistOnEventId set.

  26. val processId: String

    Permalink

    Id of the causality-tracking source of concurrent activity.

    Id of the causality-tracking source of concurrent activity. This is the id of the local event log that initially wrote the event.

  27. def replicable(vectorTime: VectorTime, filter: ReplicationFilter): Boolean

    Permalink

    Returns true if this event did not happen before or at the given vectorTime and passes the given replication filter.

  28. final def synchronized[T0](arg0: ⇒ T0): T0

    Permalink
    Definition Classes
    AnyRef
  29. val systemTimestamp: Long

    Permalink

    Wall-clock timestamp, generated by the source of concurrent activity that is identified by processId.

  30. val vectorTimestamp: VectorTime

    Permalink

    Vector timestamp, generated by the source of concurrent activity that is identified by processId.

  31. final def wait(): Unit

    Permalink
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  32. final def wait(arg0: Long, arg1: Int): Unit

    Permalink
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  33. final def wait(arg0: Long): Unit

    Permalink
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )

Inherited from Serializable

Inherited from Serializable

Inherited from Product

Inherited from Equals

Inherited from AnyRef

Inherited from Any

Ungrouped