Warehouseman

Instance Constructors

new Warehouseman(warehousemanType: WarehousemanType, dbName: String, mapName: String = null)

create a new Warehouseman actor instance from a String.
create a new Warehouseman actor instance from a String.
warehousemanType
The behaviour of theWarehouseman
dbName
The database name.
mapName
The map name.

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
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( ... )
var clusterListener: ActorRef

Definition Classes
ClusterAwareActor
implicit val context: ActorContext

Definition Classes
Actor
def currentMethodName(): String

Return the name of the current running method.
Return the name of the current running method.
returns
The name of the method that call this.

Definition Classes
ReplyActor
implicit val ec: ExecutionContextExecutor

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

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

Definition Classes
AnyRef → Any
var fileManager: FileManager
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 isInstanceOf[T0]: Boolean

Definition Classes
Any
def log: LoggingAdapter

Definition Classes
ActorLogging
def logAndReply(reply: ReplyMessage, sender: ActorRef = sender): Unit

Logs the operation represent by the ReplyMessage message and sends the ReplyMessage to the sender.
Logs the operation represent by the ReplyMessage message and sends the ReplyMessage to the sender.
reply
The ReplyMessage message that represent the reply to a request.
sender
The sender's reference of the request.

Definition Classes
ReplyActor
See also
#writeLog(ReplyMessage)
#reply(ReplyMessage, ActorRef)
final def ne(arg0: AnyRef): Boolean

Definition Classes
AnyRef
def nextAddress: Address

Returns an address of one node in the cluster.
Returns an address of one node in the cluster. This method sends a message to the ClusterListener of the same node of this actor so it will stop the thread of this actor while waiting for a response.
returns
the address of type akka.actor.Address.

Definition Classes
ClusterAwareActor
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

Override of the actor's preStart method.
Override of the actor's preStart method. Changes the actor's behaviour based on the constructor.

Definition Classes
Warehouseman → Actor
See also
#become(Actor.receive)
def receive: PartialFunction[Any, Unit]

Processes all incoming messages.
Processes all incoming messages. Handles RowMessage messages and ScalabilityMessage messages.

Definition Classes
Warehouseman → Actor
See also
#handleRowMessages(RowMessage)
SendMapMessage
ReadMapMessage
WriteMapMessage
RowMessage
def reply(reply: ReplyMessage, sender: ActorRef = sender): Unit

Send the ReplyMessage message to the sender.
Send the ReplyMessage message to the sender.
reply
The ReplyMessage message that represent the reply to a request.
sender
The sender's reference of the request.

Definition Classes
ReplyActor
val replyBuilder: ReplyBuilder

Definition Classes
ReplyActor
implicit final val self: ActorRef

Definition Classes
Actor
final def sender(): ActorRef

Definition Classes
Actor
def supervisorStrategy: SupervisorStrategy

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

Definition Classes
AnyRef
implicit val timeout: Timeout

Definition Classes
ClusterAwareActor
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( ... )
def writeLog(reply: ReplyMessage): Unit

Logs the operation represent by the ReplyMessage using the ReplyBuilder class.
Logs the operation represent by the ReplyMessage using the ReplyBuilder class.
reply
The ReplyMessage message that represent the reply to a request.

Definition Classes
ReplyActor
See also
ReplyBuilder

class Warehouseman extends ReplyActor

Instance Constructors

new Warehouseman(warehousemanType: WarehousemanType, dbName: String, mapName: String = null)

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

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

var clusterListener: ActorRef

implicit val context: ActorContext

def currentMethodName(): String

implicit val ec: ExecutionContextExecutor

final def eq(arg0: AnyRef): Boolean

def equals(arg0: Any): Boolean

var fileManager: FileManager

def finalize(): Unit

final def getClass(): Class[_]

def hashCode(): Int

final def isInstanceOf[T0]: Boolean

def log: LoggingAdapter

def logAndReply(reply: ReplyMessage, sender: ActorRef = sender): Unit

final def ne(arg0: AnyRef): Boolean

def nextAddress: Address

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]

def reply(reply: ReplyMessage, sender: ActorRef = sender): Unit

val replyBuilder: ReplyBuilder

implicit final val self: ActorRef

final def sender(): ActorRef

def supervisorStrategy: SupervisorStrategy

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

implicit val timeout: Timeout

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

def writeLog(reply: ReplyMessage): Unit

Inherited from ReplyActor

Inherited from ActorLogging

Inherited from ClusterAwareActor

Inherited from Actor

Inherited from AnyRef

Inherited from Any

Ungrouped