cc.otavia.core.message

Members list

Type members

Classlikes

case class AcceptedEvent(channel: Channel, accepted: Channel) extends ReactorEvent

Attributes

Supertypes
trait Serializable
trait Product
trait Equals
class ReactorEvent
class Event
class Object
trait Matchable
class Any
Show all
trait Ask[R <: Reply] extends Call

message which need reply

message which need reply

Attributes

Supertypes
trait Call
trait Message
trait Serializable
class Object
trait Matchable
class Any
Show all
Known subtypes
class Bind
trait Connect
case class AskTimeoutEvent(registerId: Long, askId: Long) extends TimerEvent

Attributes

Supertypes
trait Serializable
trait Product
trait Equals
class TimerEvent
class Event
class Object
trait Matchable
class Any
Show all
case class BindReply(channel: Channel, firstActive: Boolean, cause: Option[Throwable]) extends ReactorEvent

Attributes

Supertypes
trait Serializable
trait Product
trait Equals
class ReactorEvent
class Event
class Object
trait Matchable
class Any
Show all
sealed trait Call extends Message

Message which will generate cc.otavia.core.stack.Stack when a cc.otavia.core.actor.Actor received.

Message which will generate cc.otavia.core.stack.Stack when a cc.otavia.core.actor.Actor received.

Attributes

Supertypes
trait Message
trait Serializable
class Object
trait Matchable
class Any
Known subtypes
trait Ask[R]
class Bind
trait Connect
trait Notice
class Args
class ArrayNotice[T]
class IntNotice
class SeqNotice[T]
class StringNotice
class ProbeStart
Show all
case class ChannelClose(channel: Channel, cause: Option[Throwable]) extends ReactorEvent

Attributes

Supertypes
trait Serializable
trait Product
trait Equals
class ReactorEvent
class Event
class Object
trait Matchable
class Any
Show all
case class ChannelTimeoutEvent(registerId: Long, channel: Channel) extends TimerEvent

Attributes

Supertypes
trait Serializable
trait Product
trait Equals
class TimerEvent
class Event
class Object
trait Matchable
class Any
Show all
case class ConnectReply(channel: Channel, firstActive: Boolean, cause: Option[Throwable]) extends ReactorEvent

Attributes

Supertypes
trait Serializable
trait Product
trait Equals
class ReactorEvent
class Event
class Object
trait Matchable
class Any
Show all
case class DeregisterReply(channel: Channel, firstInactive: Boolean, isOpen: Boolean, cause: Option[Throwable]) extends ReactorEvent

Attributes

Supertypes
trait Serializable
trait Product
trait Equals
class ReactorEvent
class Event
class Object
trait Matchable
class Any
Show all
case class DisconnectReply(channel: Channel, cause: Option[Throwable]) extends ReactorEvent

Attributes

Supertypes
trait Serializable
trait Product
trait Equals
class ReactorEvent
class Event
class Object
trait Matchable
class Any
Show all
object EMPTY_EVENT extends ReactorEvent

Attributes

Supertypes
class ReactorEvent
class Event
class Object
trait Matchable
class Any
Self type
object Envelope

Attributes

Supertypes
class Object
trait Matchable
class Any
Self type
Envelope.type
sealed abstract class Event

Attributes

Supertypes
class Object
trait Matchable
class Any
Known subtypes
final class ExceptionMessage(message: String | Null, cause: Throwable | Null) extends Exception, Reply

exception message

exception message

Value parameters

cause

exception detail

message

exception message

Attributes

Companion
object
Supertypes
trait Reply
trait Message
class Exception
class Throwable
trait Serializable
class Object
trait Matchable
class Any
Show all

Attributes

Companion
class
Supertypes
class Object
trait Matchable
class Any
Self type
sealed trait Message extends Serializable

Message is base unit for actor community

Message is base unit for actor community

Attributes

Supertypes
trait Serializable
class Object
trait Matchable
class Any
Known subtypes
trait Call
trait Ask[R]
class Bind
trait Connect
trait Notice
class Args
class ArrayNotice[T]
class IntNotice
class SeqNotice[T]
class StringNotice
class ProbeStart
trait Reply
trait TimeoutReply
trait UnitReply
Show all
trait Notice extends Call

message which do not need to reply

message which do not need to reply

Attributes

Supertypes
trait Call
trait Message
trait Serializable
class Object
trait Matchable
class Any
Show all
Known subtypes
class Args
trait Connect
class ArrayNotice[T]
class IntNotice
class SeqNotice[T]
class StringNotice
class ProbeStart
Show all
case class OpenReply(channel: Channel, cause: Option[Throwable]) extends ReactorEvent

Attributes

Supertypes
trait Serializable
trait Product
trait Equals
class ReactorEvent
class Event
class Object
trait Matchable
class Any
Show all
sealed abstract class ReactorEvent extends Event

Attributes

Supertypes
class Event
class Object
trait Matchable
class Any
Known subtypes
case class ReadBuffer(channel: Channel, buffer: RecyclablePageBuffer, sender: Option[SocketAddress], recipient: SocketAddress, cause: Option[Throwable]) extends ReactorEvent

Attributes

Supertypes
trait Serializable
trait Product
trait Equals
class ReactorEvent
class Event
class Object
trait Matchable
class Any
Show all
case class ReadCompletedEvent(channel: Channel, cause: Option[Throwable]) extends ReactorEvent

Attributes

Supertypes
trait Serializable
trait Product
trait Equals
class ReactorEvent
class Event
class Object
trait Matchable
class Any
Show all
case class ReadEvent(channel: Channel, cause: Option[Throwable]) extends ReactorEvent

Attributes

Supertypes
trait Serializable
trait Product
trait Equals
class ReactorEvent
class Event
class Object
trait Matchable
class Any
Show all
case class RegisterReply(channel: Channel, active: Boolean, cause: Option[Throwable]) extends ReactorEvent

Attributes

Supertypes
trait Serializable
trait Product
trait Equals
class ReactorEvent
class Event
class Object
trait Matchable
class Any
Show all
trait Reply extends Message

reply message, it replies at least one ask message

reply message, it replies at least one ask message

Attributes

Supertypes
trait Message
trait Serializable
class Object
trait Matchable
class Any
Known subtypes
case class ResourceTimeoutEvent(registerId: Long, cache: ResourceTimer) extends TimerEvent

Attributes

Supertypes
trait Serializable
trait Product
trait Equals
class TimerEvent
class Event
class Object
trait Matchable
class Any
Show all
case class ShutdownReply(channel: Channel, direction: ChannelShutdownDirection, cause: Option[Throwable]) extends ReactorEvent

Attributes

Supertypes
trait Serializable
trait Product
trait Equals
class ReactorEvent
class Event
class Object
trait Matchable
class Any
Show all
case class TimeoutEvent(registerId: Long, attach: Option[AnyRef]) extends TimerEvent

Timeout event

Timeout event

Attributes

Supertypes
trait Serializable
trait Product
trait Equals
class TimerEvent
class Event
class Object
trait Matchable
class Any
Show all
sealed trait TimeoutReply extends Reply

Attributes

Companion
object
Supertypes
trait Reply
trait Message
trait Serializable
class Object
trait Matchable
class Any
Show all
object TimeoutReply

Attributes

Companion
trait
Supertypes
class Object
trait Matchable
class Any
Self type
sealed abstract class TimerEvent extends Event

Attributes

Supertypes
class Event
class Object
trait Matchable
class Any
Known subtypes
object helper

Some notices classes that may be used frequently

Some notices classes that may be used frequently

Attributes

Supertypes
class Object
trait Matchable
class Any
Self type
helper.type

Types

type ReplyOf[A <: Ask[_ <: Reply]] = A match { case Ask[r] => r }

Calculate the message type of the Ask message

Calculate the message type of the Ask message

Attributes