KlusterKite
0.0.0
A framework to create scalable and redundant services based on awesome Akka.Net project.
|
Mocked message router More...
Public Member Functions | |
TestMessageRouter (IActorRef testActor) | |
Initializes a new instance of the TestMessageRouter class. More... | |
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 | RegisterVirtualNode (Address address, IActorRef receiver) |
Registers virtual node as actor, that would receive all messages as TestMessage<T> More... | |
void | Tell (Address nodeAddress, string path, object message, IActorRef sender=null) |
Sends message to the specified actor path on the specified node More... | |
Mocked message router
Definition at line 27 of file TestMessageRouter.cs.
KlusterKite.Core.TestKit.TestMessageRouter.TestMessageRouter | ( | IActorRef | testActor | ) |
Initializes a new instance of the TestMessageRouter class.
testActor | The test actor. |
Definition at line 45 of file TestMessageRouter.cs.
Task<T> KlusterKite.Core.TestKit.TestMessageRouter.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 59 of file TestMessageRouter.cs.
void KlusterKite.Core.TestKit.TestMessageRouter.RegisterVirtualNode | ( | Address | address, |
IActorRef | receiver | ||
) |
Registers virtual node as actor, that would receive all messages as TestMessage<T>
address | The virtual node address |
receiver | Virtual node representative |
Definition at line 81 of file TestMessageRouter.cs.
void KlusterKite.Core.TestKit.TestMessageRouter.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 101 of file TestMessageRouter.cs.