KlusterKite
0.0.0
A framework to create scalable and redundant services based on awesome Akka.Net project.
|
Base class to route messages. More...
Public Member Functions | |
MessageRouter (ActorSystem actorSystem) | |
Initializes a new instance of the MessageRouter class. More... | |
async Task< T > | Ask< T > (Address nodeAddress, string path, object message, TimeSpan timeout) |
Sends message to the specified actor path on the specified node. See also Futures.Ask(Akka.Actor.ICanTell,object,System.Nullable<System.TimeSpan>) More... | |
void | Tell (Address nodeAddress, string path, object message, IActorRef sender=null) |
Sends message to the specified actor path on the specified node More... | |
Base class to route messages.
Definition at line 23 of file MessageRouter.cs.
KlusterKite.Core.MessageRouter.MessageRouter | ( | ActorSystem | actorSystem | ) |
Initializes a new instance of the MessageRouter class.
actorSystem | The actor system. |
Definition at line 36 of file MessageRouter.cs.
async Task<T> KlusterKite.Core.MessageRouter.Ask< T > | ( | Address | nodeAddress, |
string | path, | ||
object | message, | ||
TimeSpan | timeout | ||
) |
Sends message to the specified actor path on the specified node. See also Futures.Ask(Akka.Actor.ICanTell,object,System.Nullable<System.TimeSpan>)
T | The type of awaited response |
nodeAddress | The node address. |
path | The recipient path. |
message | The message. |
timeout | The maximum time to wait for response |
Implements KlusterKite.Core.IMessageRouter.
Definition at line 50 of file MessageRouter.cs.
void KlusterKite.Core.MessageRouter.Tell | ( | Address | nodeAddress, |
string | path, | ||
object | message, | ||
IActorRef | sender = null |
||
) |
Sends message to the specified actor path on the specified node
nodeAddress | The node address. |
path | The recipient path. |
message | The message. |
sender | The sender. |
Implements KlusterKite.Core.IMessageRouter.
Definition at line 70 of file MessageRouter.cs.