PushingDispatcherBase

Type Members

type HandlerName = String

Definition Classes
Dispatcher
type Receive = PartialFunction[Any, Unit]

Definition Classes
Actor
type WorkerPoolRef = ActorRef

Definition Classes
Dispatcher

Abstract Value Members

abstract def checkRequest(m: Any): Boolean

Attributes
protected
abstract def handlerProvider: HandlerProvider[T]

Definition Classes
PushingDispatcherBase → Dispatcher
abstract def name: String

Definition Classes
PushingDispatcherBase → Dispatcher
abstract def reporter: Option[Reporter]

Definition Classes
PushingDispatcherBase → Dispatcher
abstract def settings: Settings

Definition Classes
PushingDispatcherBase → Dispatcher

Concrete Value Members

final def !=(arg0: Any): Boolean

Definition Classes
AnyRef → Any
final def ##(): Int

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

Definition Classes
AnyRef → Any
def aroundPostRestart(reason: Throwable): Unit

Attributes
protected[akka]
Definition Classes
Actor
def aroundPostStop(): Unit

Attributes
protected[akka]
Definition Classes
Actor
def aroundPreRestart(reason: Throwable, message: Option[Any]): Unit

Attributes
protected[akka]
Definition Classes
Actor
def aroundPreStart(): Unit

Attributes
protected[akka]
Definition Classes
Actor
def aroundReceive(receive: akka.actor.Actor.Receive, msg: Any): Unit

Attributes
protected[akka]
Definition Classes
Actor
final def asInstanceOf[T0]: T0

Definition Classes
Any
def clone(): AnyRef

Attributes
protected[java.lang]
Definition Classes
AnyRef
Annotations
@throws( ... )
implicit val context: ActorContext

Definition Classes
Actor
def delayedMsg(delay: FiniteDuration, msg: Any, receiver: ActorRef = self): Cancellable

Definition Classes
MessageScheduler
var droppingRate: DroppingRate
final def eq(arg0: AnyRef): Boolean

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

Definition Classes
AnyRef → Any
def extraReceive: Receive

This extraReceive implementation helps this PushingDispatcher act as a transparent proxy.
This extraReceive implementation helps this PushingDispatcher act as a transparent proxy. It will send the message to the underlying kanaloa.queue.Queue and the sender will be set as the receiver of any results of the downstream kanaloa.handler.Handler. This receive will disable any acks, and in the event of an kanaloa.queue.Queue.EnqueueRejected, notify the original sender of the rejection.

Attributes
protected
Definition Classes
PushingDispatcherBase → Dispatcher
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
var inGracePeriod: Boolean

Definition Classes
Dispatcher
final def isInstanceOf[T0]: Boolean

Definition Classes
Any
def log: LoggingAdapter

Definition Classes
ActorLogging
def maybeDelayedMsg(delayO: Option[FiniteDuration], msg: Any, receiver: ActorRef = self): Option[Cancellable]

Definition Classes
MessageScheduler
def monitorWorkerPools(reportTo: Option[ActorRef], shuttingDown: Boolean): Receive

Definition Classes
Dispatcher
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] )
lazy val queue: ActorRef

Attributes
protected
Definition Classes
Dispatcher
lazy val queueProps: Props

Attributes
protected
Definition Classes
PushingDispatcherBase → Dispatcher
lazy val queueSampler: ActorRef

Attributes
protected
Definition Classes
Dispatcher
val random: Random
def receive: Receive

Definition Classes
Dispatcher → Actor
implicit final val self: ActorRef

Definition Classes
Actor
final def sender(): ActorRef

Definition Classes
Actor
def shutdown(reportTo: Option[ActorRef], timeout: FiniteDuration): Unit

Definition Classes
Dispatcher
def shuttingDown(reportTo: Option[ActorRef], timeout: FiniteDuration): Receive

Definition Classes
Dispatcher
val supervisorStrategy: OneForOneStrategy

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

Definition Classes
AnyRef
def toString(): String

Definition Classes
AnyRef → Any
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( ... )
var workerPoolIndex: Int

Definition Classes
Dispatcher
var workerPools: List[(HandlerName, WorkerPoolRef)]

Definition Classes
Dispatcher

Related Doc: package kanaloa

sealed abstract class PushingDispatcherBase[T] extends Dispatcher[T]

Type Members

type HandlerName = String

type Receive = PartialFunction[Any, Unit]

type WorkerPoolRef = ActorRef

Abstract Value Members

abstract def checkRequest(m: Any): Boolean

abstract def handlerProvider: HandlerProvider[T]

abstract def name: String

abstract def reporter: Option[Reporter]

abstract def settings: Settings

Concrete Value Members

final def !=(arg0: Any): Boolean

final def ##(): Int

final def ==(arg0: Any): Boolean

def aroundPostRestart(reason: Throwable): Unit

def aroundPostStop(): Unit

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

def aroundPreStart(): Unit

def aroundReceive(receive: akka.actor.Actor.Receive, msg: Any): Unit

final def asInstanceOf[T0]: T0

def clone(): AnyRef

implicit val context: ActorContext

def delayedMsg(delay: FiniteDuration, msg: Any, receiver: ActorRef = self): Cancellable

var droppingRate: DroppingRate

final def eq(arg0: AnyRef): Boolean

def equals(arg0: Any): Boolean

def extraReceive: Receive

def finalize(): Unit

final def getClass(): Class[_]

def hashCode(): Int

var inGracePeriod: Boolean

final def isInstanceOf[T0]: Boolean

def log: LoggingAdapter

def maybeDelayedMsg(delayO: Option[FiniteDuration], msg: Any, receiver: ActorRef = self): Option[Cancellable]

def monitorWorkerPools(reportTo: Option[ActorRef], shuttingDown: Boolean): Receive

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

lazy val queue: ActorRef

lazy val queueProps: Props

lazy val queueSampler: ActorRef

val random: Random

def receive: Receive

implicit final val self: ActorRef

final def sender(): ActorRef

def shutdown(reportTo: Option[ActorRef], timeout: FiniteDuration): Unit

def shuttingDown(reportTo: Option[ActorRef], timeout: FiniteDuration): Receive

val supervisorStrategy: OneForOneStrategy

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

def toString(): String

def unhandled(message: Any): Unit

final def wait(): Unit

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

final def wait(arg0: Long): Unit

var workerPoolIndex: Int

var workerPools: List[(HandlerName, WorkerPoolRef)]

Inherited from Dispatcher[T]

Inherited from MessageScheduler

Inherited from ActorLogging

Inherited from Actor

Inherited from AnyRef

Inherited from Any

Ungrouped