object
MsgHandler
extends ServiceRegistry[Message]
Value Members
-
def
!=
(arg0: AnyRef): Boolean
-
def
!=
(arg0: Any): Boolean
-
def
##
(): Int
-
def
==
(arg0: AnyRef): Boolean
-
def
==
(arg0: Any): Boolean
-
def
asInstanceOf
[T0]
: T0
-
def
clone
(): AnyRef
-
val
envelopeSchema
: TypedSchema[MessageEnvelope]
-
def
eq
(arg0: AnyRef): Boolean
-
def
equals
(arg0: Any): Boolean
-
def
finalize
(): Unit
-
def
futureCount
: Long
-
def
getClass
(): java.lang.Class[_]
-
def
getService
(id: String): MessageReceiver[Message]
-
def
hashCode
(): Int
-
val
invalidMessageCount
: AtomicLong
-
def
isInstanceOf
[T0]
: Boolean
-
val
logger
: Logger
-
def
ne
(arg0: AnyRef): Boolean
-
def
notify
(): Unit
-
def
notifyAll
(): Unit
-
def
registerActor
(actor: Actor): RemoteServiceProxy[Message]
-
def
registerListener
(listener: MessageHandlerListener): Unit
-
def
registerService
(id: String, service: MessageReceiver[Message]): RemoteServiceProxy[Message]
-
def
registerService
(service: MessageReceiver[Message]): RemoteServiceProxy[Message]
-
def
registrySize
: Int
-
def
sendMessage
(src: Option[RemoteServiceProxy[Message]], dest: RemoteServiceProxy[Message], msg: Message): Unit
-
def
startListener
(port: Int): Unit
-
def
synchronized
[T0]
(arg0: ⇒ T0): T0
-
def
toString
(): String
-
def
unregisterListener
(listener: MessageHandlerListener): Unit
-
def
unregisterService
(service: RemoteServiceProxy[Message]): MessageReceiver[Message]
-
def
wait
(): Unit
-
def
wait
(arg0: Long, arg1: Int): Unit
-
def
wait
(arg0: Long): Unit
Deprecated Value Members
-
def
receiveMessage
(src: RemoteNode, msg: Message): Unit
Inherited from ServiceRegistry[Message]
Inherited from AnyRef
Inherited from Any