KlusterKite  0.0.0
A framework to create scalable and redundant services based on awesome Akka.Net project.
KlusterKite.Core.IMessageRouter Interface Reference

Base class to route messages. Used to give possibility to create routing mocks More...

Inheritance diagram for KlusterKite.Core.IMessageRouter:
KlusterKite.Core.MessageRouter KlusterKite.Core.TestKit.TestMessageRouter

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...
 

Detailed Description

Base class to route messages. Used to give possibility to create routing mocks

Definition at line 22 of file IMessageRouter.cs.

Member Function Documentation

◆ Ask< T >()

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>)

Template Parameters
TThe type of awaited response
Parameters
nodeAddressThe node address.
pathThe recipient path.
messageThe message.
timeoutThe maximum time to wait for response
Returns
The response

Implemented in KlusterKite.Core.TestKit.TestMessageRouter, and KlusterKite.Core.MessageRouter.

◆ Tell()

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

Parameters
nodeAddressThe node address.
pathThe recipient path.
messageThe message.
senderThe sender.

Implemented in KlusterKite.Core.TestKit.TestMessageRouter, and KlusterKite.Core.MessageRouter.


The documentation for this interface was generated from the following file: