WriteOutMsg

Instructs a Journal to write an output message. An output message is an event message sent to a ReliableChannel. Together with the output message, an acknowledgement can optionally be written. The acknowledgement refers to the input message that caused the emission of the output message. Refer to org.eligosource.eventsourced.core.JournalProtocol.WriteAck for more details about acknowledgements.

channelId: id of the reliable channel.
message: output message.
ackProcessorId: id of the Eventsourced processor that emitted the output message to the reliable channel.
ackSequenceNr: sequence number of the input message that caused the emission of the output message.
target: target that should receive the output message after it has been written. The output 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

Instance Constructors

new WriteOutMsg(channelId: Int, message: Message, ackProcessorId: Int, ackSequenceNr: Long, target: ActorRef, genSequenceNr: Boolean = true)

channelId
id of the reliable channel.
message
output message.
ackProcessorId
id of the Eventsourced processor that emitted the output message to the reliable channel.
ackSequenceNr
sequence number of the input message that caused the emission of the output message.
target
target that should receive the output message after it has been written. The output 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

final def !=(arg0: AnyRef): Boolean

Definition Classes
AnyRef
final def !=(arg0: Any): Boolean

Definition Classes
Any
final def ##(): Int

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

Definition Classes
AnyRef
final def ==(arg0: Any): Boolean

Definition Classes
Any
val ackProcessorId: Int

id of the Eventsourced processor that emitted the output message to the reliable channel.
val ackSequenceNr: Long

sequence number of the input message that caused the emission of the output message.
final def asInstanceOf[T0]: T0

Definition Classes
Any
val channelId: Int

id of the reliable channel.
def clone(): AnyRef

Attributes
protected[java.lang]
Definition Classes
AnyRef
Annotations
@throws( ... )
final def eq(arg0: AnyRef): Boolean

Definition Classes
AnyRef
def finalize(): Unit

Attributes
protected[java.lang]
Definition Classes
AnyRef
Annotations
@throws( classOf[java.lang.Throwable] )
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.
final def getClass(): Class[_]

Definition Classes
AnyRef → Any
final def isInstanceOf[T0]: Boolean

Definition Classes
Any
val message: Message

output message.
final def ne(arg0: AnyRef): Boolean

Definition Classes
AnyRef
final def notify(): Unit

Definition Classes
AnyRef
final def notifyAll(): Unit

Definition Classes
AnyRef
final def synchronized[T0](arg0: ⇒ T0): T0

Definition Classes
AnyRef
val target: ActorRef

target that should receive the output message after it has been written.
target that should receive the output message after it has been written. The output message is sent to target wrapped in org.eligosource.eventsourced.core.JournalProtocol.Written. The sender reference is set to system.deadLetters.
final def wait(): Unit

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

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

Definition Classes
AnyRef
Annotations
@throws( ... )
def withSequenceNr(snr: Long): WriteOutMsg

case class WriteOutMsg(channelId: Int, message: Message, ackProcessorId: Int, ackSequenceNr: Long, target: ActorRef, genSequenceNr: Boolean = true) extends Product with Serializable

Instance Constructors

new WriteOutMsg(channelId: Int, message: Message, ackProcessorId: Int, ackSequenceNr: Long, target: ActorRef, genSequenceNr: Boolean = true)

Value Members

final def !=(arg0: AnyRef): Boolean

final def !=(arg0: Any): Boolean

final def ##(): Int

final def ==(arg0: AnyRef): Boolean

final def ==(arg0: Any): Boolean

val ackProcessorId: Int

val ackSequenceNr: Long

final def asInstanceOf[T0]: T0

val channelId: Int

def clone(): AnyRef

final def eq(arg0: AnyRef): Boolean

def finalize(): Unit

val genSequenceNr: Boolean

final def getClass(): Class[_]

final def isInstanceOf[T0]: Boolean

val message: Message

final def ne(arg0: AnyRef): Boolean

final def notify(): Unit

final def notifyAll(): Unit

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

val target: ActorRef

final def wait(): Unit

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

final def wait(arg0: Long): Unit

def withSequenceNr(snr: Long): WriteOutMsg

Inherited from Serializable

Inherited from Serializable

Inherited from Product

Inherited from Equals

Inherited from AnyRef

Inherited from Any

Ungrouped