org.eligosource.eventsourced.core.JournalProtocol

WriteInMsg

case class WriteInMsg(processorId: Int, message: Message, target: ActorRef, genSequenceNr: Boolean = true) extends Product with Serializable

Instructs a Journal to write an input message. An input message is an event message sent to an Eventsourced processor.

processorId

id of the Eventsourced processor.

message

input message.

target

target that should receive the input message after it has been written. The input message is sent to target wrapped in org.eligosource.eventsourced.core.JournalProtocol.Written. The sender reference is set to system.deadLetters.

genSequenceNr

true if message.sequenceNr should be updated to the journal's current counter value or false if the journal's counter should be set to message.sequenceNr.

Linear Supertypes
Serializable, Serializable, Product, Equals, AnyRef, Any
Ordering
  1. Alphabetic
  2. By inheritance
Inherited
  1. WriteInMsg
  2. Serializable
  3. Serializable
  4. Product
  5. Equals
  6. AnyRef
  7. Any
  1. Hide All
  2. Show all
Learn more about member selection
Visibility
  1. Public
  2. All

Instance Constructors

  1. new WriteInMsg(processorId: Int, message: Message, target: ActorRef, genSequenceNr: Boolean = true)

    processorId

    id of the Eventsourced processor.

    message

    input message.

    target

    target that should receive the input message after it has been written. The input message is sent to target wrapped in org.eligosource.eventsourced.core.JournalProtocol.Written. The sender reference is set to system.deadLetters.

    genSequenceNr

    true if message.sequenceNr should be updated to the journal's current counter value or false if the journal's counter should be set to message.sequenceNr.

Value Members

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

    Definition Classes
    AnyRef

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

    Definition Classes
    Any

  3. final def ##(): Int

    Definition Classes
    AnyRef → Any

  4. final def ==(arg0: AnyRef): Boolean

    Definition Classes
    AnyRef

  5. final def ==(arg0: Any): Boolean

    Definition Classes
    Any

  6. final def asInstanceOf[T0]: T0

    Definition Classes
    Any

  7. def clone(): AnyRef

    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )

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

    Definition Classes
    AnyRef

  9. def finalize(): Unit

    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( classOf[java.lang.Throwable] )

  10. val genSequenceNr: Boolean

    true if message.sequenceNr should be updated to the journal's current counter value or false if the journal's counter should be set to message.sequenceNr.

  11. final def getClass(): Class[_]

    Definition Classes
    AnyRef → Any

  12. final def isInstanceOf[T0]: Boolean

    Definition Classes
    Any

  13. val message: Message

    input message.

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

    Definition Classes
    AnyRef

  15. final def notify(): Unit

    Definition Classes
    AnyRef

  16. final def notifyAll(): Unit

    Definition Classes
    AnyRef

  17. val processorId: Int

    id of the Eventsourced processor.

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

    Definition Classes
    AnyRef

  19. val target: ActorRef

    target that should receive the input message after it has been written.

    target that should receive the input message after it has been written. The input message is sent to target wrapped in org.eligosource.eventsourced.core.JournalProtocol.Written. The sender reference is set to system.deadLetters.

  20. final def wait(): Unit

    Definition Classes
    AnyRef
    Annotations
    @throws( ... )

  21. final def wait(arg0: Long, arg1: Int): Unit

    Definition Classes
    AnyRef
    Annotations
    @throws( ... )

  22. final def wait(arg0: Long): Unit

    Definition Classes
    AnyRef
    Annotations
    @throws( ... )

  23. def withSequenceNr(snr: Long): WriteInMsg

  24. def withTimestamp: WriteInMsg

Inherited from Serializable

Inherited from Serializable

Inherited from Product

Inherited from Equals

Inherited from AnyRef

Inherited from Any

Ungrouped