Interface IMessageCorrelationManager
The message correlation manager is a cached user to store correlation Ids of outgoing requests and use them to match incoming responses.
Inherited Members
System.IDisposable.Dispose()
Namespace: Catalyst.Abstractions.IO.Messaging.Correlation
Assembly: Catalyst.Abstractions.dll
Syntax
public interface IMessageCorrelationManager : IDisposableMethods
| Improve this Doc View SourceAddPendingRequest(ICorrelatableMessage<ProtocolMessage>)
Adds a correlatable message to the cache, which can then be matched in TryMatchResponse(ProtocolMessage) upon receiving the response. in the cache.
Declaration
void AddPendingRequest(ICorrelatableMessage<ProtocolMessage> correlatableMessage)Parameters
| Type | Name | Description |
|---|---|---|
| ICorrelatableMessage<ProtocolMessage> | correlatableMessage | The (outgoing) correlatable message to add to the cache. |
TryMatchResponse(ProtocolMessage)
Tries to match the response by checking its correlation Id is still in the cache.
Declaration
bool TryMatchResponse(ProtocolMessage response)Parameters
| Type | Name | Description |
|---|---|---|
| ProtocolMessage | response | A response type message received from the network |
Returns
| Type | Description |
|---|---|
| System.Boolean |