Receiver

Stackable modification for actors to extract the event from a received event org.eligosource.eventsourced.core.Message and calling the modified actor's receive method with that event. Example:

val myReceiver = system.actorOf(Props(new MyReceiver with Receiver))

myReceiver ! Message("foo event")

class MyReceiver extends Actor { this: Receiver =>
  def receive = {
    case "foo event" => {
      val msg = message          // current message
      val snr = sequenceNr       // sequence number of message

      assert(snr > 0L)
      // ...
    }
  }
}

Event messages received by concrete Receivers are stored in a private field and can be obtained via the message or messageOption method.

The Receiver trait can also be used in combination with other stackable traits of the library (such as org.eligosource.eventsourced.core.Confirm or org.eligosource.eventsourced.core.Eventsourced), for example:

val myReceiver = system.actorOf(Props(new MyReceiver with Receiver with Confirm with Eventsourced { val id = ... } ))

class MyReceiver extends Actor { this: Receiver =>
  def receive = {
    // ...
  }
}

Linear Supertypes

Behavior, Actor, AnyRef, Any

Known Subclasses

Emitter, UntypedConfirmingReceiver, UntypedEmitter, UntypedEventsourcedConfirmingReceiver, UntypedEventsourcedEmitter, UntypedEventsourcedReceiver, UntypedReceiver

Type Members

type Receive = PartialFunction[Any, Unit]

Definition Classes
Actor

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
final def asInstanceOf[T0]: T0

Definition Classes
Any
def become(behavior: Procedure[Any], discardOld: Boolean): Unit

Java API.
Java API.
Puts behavior on the hotswap stack. This will preserve the behavior of this stackable trait. Actors that additionally want to replace the behavior of this stackable trait should call getContext().become(...).
behavior
new behavior
discardOld
if true, unbecome() will be called prior to pushing behavior.

Definition Classes
Behavior
def become(behavior: Procedure[Any]): Unit

Java API.
Java API.
Puts behavior on the hotswap stack. This will preserve the behavior of this stackable trait. Actors that additionally want to replace the behavior of this stackable trait should call getContext().become(...). The existing (old) behavior will be discarded.
behavior
new behavior

Definition Classes
Behavior
def become(behavior: akka.actor.Actor.Receive, discardOld: Boolean = true): Unit

Puts behavior on the hotswap stack.
Puts behavior on the hotswap stack. This will preserve the behavior of this stackable trait. Actors that additionally want to replace the behavior of this stackable trait should call context.become(...).
behavior
new behavior
discardOld
if true, unbecome() will be called prior to pushing behavior.

Definition Classes
Behavior
def clone(): AnyRef

Attributes
protected[java.lang]
Definition Classes
AnyRef
Annotations
@throws( ... )
def confirm(pos: Boolean = true): Unit

Positively or negatively confirms the receipt of the current event message.
Positively or negatively confirms the receipt of the current event message.
pos
true for a positive receipt confirmation, false for a negative one.

Exceptions thrown
IllegalStateException
if the the last message received by this receiver is not of type org.eligosource.eventsourced.core.Message
implicit val context: ActorContext

Definition Classes
Actor
final def eq(arg0: AnyRef): Boolean

Definition Classes
AnyRef
def equals(arg0: Any): Boolean

Definition Classes
AnyRef → Any
def finalize(): Unit

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

Definition Classes
AnyRef → Any
def hashCode(): Int

Definition Classes
AnyRef → Any
final def invoke(msg: Any): Unit

Definition Classes
Behavior
final def isInstanceOf[T0]: Boolean

Definition Classes
Any
def message: Message

Current event message.
Current event message.

Exceptions thrown
IllegalStateException
if the the last message received by this receiver is not of type org.eligosource.eventsourced.core.Message
See also
messageOption
def messageOption: Option[Message]

Current event message option.
Current event message option. None if the last message received by this receiver is not of type org.eligosource.eventsourced.core.Message.
final def ne(arg0: AnyRef): Boolean

Definition Classes
AnyRef
final def notify(): Unit

Definition Classes
AnyRef
final def notifyAll(): Unit

Definition Classes
AnyRef
def postRestart(reason: Throwable): Unit

Definition Classes
Actor
Annotations
@throws( classOf[java.lang.Exception] )
def postStop(): Unit

Definition Classes
Actor
Annotations
@throws( classOf[java.lang.Exception] )
def preRestart(reason: Throwable, message: Option[Any]): Unit

Definition Classes
Actor
Annotations
@throws( classOf[java.lang.Exception] )
def preStart(): Unit

Definition Classes
Actor
Annotations
@throws( classOf[java.lang.Exception] )
def receive: PartialFunction[Any, Unit]

Definition Classes
Receiver → Behavior → Actor
implicit final val self: ActorRef

Definition Classes
Actor
final def sender: ActorRef

Definition Classes
Actor
def sequenceNr: Long

Sequence number of current event message
Sequence number of current event message

Exceptions thrown
IllegalStateException
if the the last message received by this receiver is not of type org.eligosource.eventsourced.core.Message
def supervisorStrategy: SupervisorStrategy

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

Definition Classes
AnyRef
def toString(): String

Definition Classes
AnyRef → Any
def unbecome(): Unit

Reverts the behavior to the previous one on the hotswap stack.
Reverts the behavior to the previous one on the hotswap stack. This will preserve the behavior of this stackable trait.

Definition Classes
Behavior
def unhandled(message: Any): Unit

Definition Classes
Actor
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( ... )

trait Receiver extends Behavior

Type Members

type Receive = PartialFunction[Any, Unit]

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

final def asInstanceOf[T0]: T0

def become(behavior: Procedure[Any], discardOld: Boolean): Unit

def become(behavior: Procedure[Any]): Unit

def become(behavior: akka.actor.Actor.Receive, discardOld: Boolean = true): Unit

def clone(): AnyRef

def confirm(pos: Boolean = true): Unit

implicit val context: ActorContext

final def eq(arg0: AnyRef): Boolean

def equals(arg0: Any): Boolean

def finalize(): Unit

final def getClass(): Class[_]

def hashCode(): Int

final def invoke(msg: Any): Unit

final def isInstanceOf[T0]: Boolean

def message: Message

def messageOption: Option[Message]

final def ne(arg0: AnyRef): Boolean

final def notify(): Unit

final def notifyAll(): Unit

def postRestart(reason: Throwable): Unit

def postStop(): Unit

def preRestart(reason: Throwable, message: Option[Any]): Unit

def preStart(): Unit

def receive: PartialFunction[Any, Unit]

implicit final val self: ActorRef

final def sender: ActorRef

def sequenceNr: Long

def supervisorStrategy: SupervisorStrategy

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

def toString(): String

def unbecome(): Unit

def unhandled(message: Any): Unit

final def wait(): Unit

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

final def wait(arg0: Long): Unit

Inherited from Behavior

Inherited from Actor

Inherited from AnyRef

Inherited from Any

Ungrouped