Interface IInputChannel
Defines the interface that a channel must implement to receive a message.
Namespace: DotNext.Net.Cluster.Messaging
Assembly: DotNext.Net.Cluster.dll
Syntax
public interface IInputChannelMethods
| Improve this Doc View SourceIsSupported(String, Boolean)
Determines whether the specified message can be processed by this handler.
Declaration
virtual bool IsSupported(string messageName, bool oneWay)Parameters
| Type | Name | Description |
|---|---|---|
| String | messageName | The name of the message. |
| Boolean | oneWay | true if message is one-way; false if message is request message that requires a response. |
Returns
| Type | Description |
|---|---|
| Boolean | true if message can be processed by this handler; otherwise, false. |
ReceiveMessage(ISubscriber, IMessage, Object, CancellationToken)
Handles incoming message from the specified cluster member.
Declaration
Task<IMessage> ReceiveMessage(ISubscriber sender, IMessage message, object context, CancellationToken token)Parameters
| Type | Name | Description |
|---|---|---|
| ISubscriber | sender | The sender of the message. |
| IMessage | message | The received message. |
| Object | context | The context of the underlying network request. |
| CancellationToken | token | The token that can be used to cancel the operation. |
Returns
| Type | Description |
|---|---|
| Task<IMessage> | The response message. |
Remarks
Implementation of this method should handle every exception inside of it and prepare response message representing such exception.
ReceiveSignal(ISubscriber, IMessage, Object, CancellationToken)
Handles incoming signal from the specified cluster member.
Declaration
Task ReceiveSignal(ISubscriber sender, IMessage signal, object context, CancellationToken token)Parameters
| Type | Name | Description |
|---|---|---|
| ISubscriber | sender | The sender of the message. |
| IMessage | signal | The received message representing signal. |
| Object | context | The context of the underlying network request. |
| CancellationToken | token | The token that can be used to cancel the operation. |
Returns
| Type | Description |
|---|---|
| Task | The task representing asynchronous execution of the method. |