KlusterKite
0.0.0
A framework to create scalable and redundant services based on awesome Akka.Net project.
|
Base class to route messages. Used to give possibility to create routing mocks More...
Public Member Functions | |
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<T>(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. Used to give possibility to create routing mocks
Definition at line 22 of file IMessageRouter.cs.
Task<T> KlusterKite.Core.IMessageRouter.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<T>(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 |
Implemented in KlusterKite.Core.TestKit.TestMessageRouter, and KlusterKite.Core.MessageRouter.
void KlusterKite.Core.IMessageRouter.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. |
Implemented in KlusterKite.Core.TestKit.TestMessageRouter, and KlusterKite.Core.MessageRouter.