cc.otavia.core.message
package cc.otavia.core.message
Members list
Type members
Classlikes
case class AcceptedEvent(channel: Channel, accepted: Channel) extends ReactorEvent
Attributes
- Supertypes
-
trait Serializabletrait Producttrait Equalsclass ReactorEventclass Eventclass Objecttrait Matchableclass AnyShow all
message which need reply
message which need reply
Attributes
- Supertypes
- Known subtypes
case class AskTimeoutEvent(registerId: Long, askId: Long) extends TimerEvent
Attributes
- Supertypes
-
trait Serializabletrait Producttrait Equalsclass TimerEventclass Eventclass Objecttrait Matchableclass AnyShow all
case class BindReply(channel: Channel, firstActive: Boolean, cause: Option[Throwable]) extends ReactorEvent
Attributes
- Supertypes
-
trait Serializabletrait Producttrait Equalsclass ReactorEventclass Eventclass Objecttrait Matchableclass AnyShow all
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
- Known subtypes
-
trait Ask[R]class AcceptedChannelclass Bindtrait Connectclass ConnectChanneltrait Noticeclass Argsclass ArrayNotice[T]class IntNoticeclass SeqNotice[T]class StringNoticeclass ProbeStartShow all
case class ChannelClose(channel: Channel, cause: Option[Throwable]) extends ReactorEvent
Attributes
- Supertypes
-
trait Serializabletrait Producttrait Equalsclass ReactorEventclass Eventclass Objecttrait Matchableclass AnyShow all
case class ChannelTimeoutEvent(registerId: Long, channel: Channel) extends TimerEvent
Attributes
- Supertypes
-
trait Serializabletrait Producttrait Equalsclass TimerEventclass Eventclass Objecttrait Matchableclass AnyShow all
case class ConnectReply(channel: Channel, firstActive: Boolean, cause: Option[Throwable]) extends ReactorEvent
Attributes
- Supertypes
-
trait Serializabletrait Producttrait Equalsclass ReactorEventclass Eventclass Objecttrait Matchableclass AnyShow all
case class DeregisterReply(channel: Channel, firstInactive: Boolean, isOpen: Boolean, cause: Option[Throwable]) extends ReactorEvent
Attributes
- Supertypes
-
trait Serializabletrait Producttrait Equalsclass ReactorEventclass Eventclass Objecttrait Matchableclass AnyShow all
case class DisconnectReply(channel: Channel, cause: Option[Throwable]) extends ReactorEvent
Attributes
- Supertypes
-
trait Serializabletrait Producttrait Equalsclass ReactorEventclass Eventclass Objecttrait Matchableclass AnyShow all
object EMPTY_EVENT extends ReactorEvent
Attributes
- Supertypes
- Self type
-
EMPTY_EVENT.type
object Envelope
Attributes
- Supertypes
-
class Objecttrait Matchableclass Any
- Self type
-
Envelope.type
Event for cc.otavia.core.actor.Actor
Event for cc.otavia.core.actor.Actor
Attributes
- Supertypes
-
class Objecttrait Matchableclass Any
- Known subtypes
-
class ReactorEventclass AcceptedEventclass BindReplyclass ChannelCloseclass ConnectReplyclass DeregisterReplyclass DisconnectReplyobject EMPTY_EVENTclass OpenReplyclass ReadBufferclass ReadCompletedEventclass ReadEventclass RegisterReplyclass ShutdownReplyclass TimerEventclass AskTimeoutEventclass ChannelTimeoutEventclass ResourceTimeoutEventclass TimeoutEventShow all
final class ExceptionMessage(message: String | Null, cause: Throwable | Null) extends Exception, Reply
object ExceptionMessage
Attributes
- Companion
- class
- Supertypes
-
class Objecttrait Matchableclass Any
- Self type
-
ExceptionMessage.type
sealed trait Message extends Serializable
Message is base unit for actor community
Message is base unit for actor community
Attributes
- Supertypes
-
trait Serializableclass Objecttrait Matchableclass Any
- Known subtypes
-
trait Calltrait Ask[R]class AcceptedChannelclass Bindtrait Connectclass ConnectChanneltrait Noticeclass Argsclass ArrayNotice[T]class IntNoticeclass SeqNotice[T]class StringNoticeclass ProbeStarttrait Replyclass ChannelEstablishedclass ExceptionMessagetrait TimeoutReplytrait UnitReplyShow all
message which do not need to reply
message which do not need to reply
Attributes
- Supertypes
- Known subtypes
-
class Argstrait Connectclass ConnectChannelclass ArrayNotice[T]class IntNoticeclass SeqNotice[T]class StringNoticeclass ProbeStartShow all
case class OpenReply(channel: Channel, cause: Option[Throwable]) extends ReactorEvent
Attributes
- Supertypes
-
trait Serializabletrait Producttrait Equalsclass ReactorEventclass Eventclass Objecttrait Matchableclass AnyShow all
sealed abstract class ReactorEvent extends Event
channel event for cc.otavia.core.actor.ChannelsActor
channel event for cc.otavia.core.actor.ChannelsActor
Attributes
- Supertypes
- Known subtypes
-
class AcceptedEventclass BindReplyclass ChannelCloseclass ConnectReplyclass DeregisterReplyclass DisconnectReplyobject EMPTY_EVENTclass OpenReplyclass ReadBufferclass ReadCompletedEventclass ReadEventclass RegisterReplyclass ShutdownReplyShow all
case class ReadBuffer(channel: Channel, buffer: RecyclablePageBuffer, sender: Option[SocketAddress], recipient: SocketAddress, cause: Option[Throwable]) extends ReactorEvent
Attributes
- Supertypes
-
trait Serializabletrait Producttrait Equalsclass ReactorEventclass Eventclass Objecttrait Matchableclass AnyShow all
case class ReadCompletedEvent(channel: Channel, cause: Option[Throwable]) extends ReactorEvent
Attributes
- Supertypes
-
trait Serializabletrait Producttrait Equalsclass ReactorEventclass Eventclass Objecttrait Matchableclass AnyShow all
case class ReadEvent(channel: Channel, cause: Option[Throwable]) extends ReactorEvent
Attributes
- Supertypes
-
trait Serializabletrait Producttrait Equalsclass ReactorEventclass Eventclass Objecttrait Matchableclass AnyShow all
case class RegisterReply(channel: Channel, active: Boolean, cause: Option[Throwable]) extends ReactorEvent
Attributes
- Supertypes
-
trait Serializabletrait Producttrait Equalsclass ReactorEventclass Eventclass Objecttrait Matchableclass AnyShow all
reply message, it replies at least one ask message
reply message, it replies at least one ask message
Attributes
- Supertypes
- Known subtypes
case class ResourceTimeoutEvent(registerId: Long, cache: ResourceTimer) extends TimerEvent
Attributes
- Supertypes
-
trait Serializabletrait Producttrait Equalsclass TimerEventclass Eventclass Objecttrait Matchableclass AnyShow all
case class ShutdownReply(channel: Channel, direction: ChannelShutdownDirection, cause: Option[Throwable]) extends ReactorEvent
Attributes
- Supertypes
-
trait Serializabletrait Producttrait Equalsclass ReactorEventclass Eventclass Objecttrait Matchableclass AnyShow all
case class TimeoutEvent(registerId: Long, attach: Option[AnyRef]) extends TimerEvent
Timeout event
Timeout event
Attributes
- Supertypes
-
trait Serializabletrait Producttrait Equalsclass TimerEventclass Eventclass Objecttrait Matchableclass AnyShow all
sealed trait TimeoutReply extends Reply
object TimeoutReply
Attributes
- Companion
- trait
- Supertypes
-
class Objecttrait Matchableclass Any
- Self type
-
TimeoutReply.type
sealed abstract class TimerEvent extends Event
Attributes
- Supertypes
- Known subtypes
In this article