Show / Hide Table of Contents

    Class RpcMessageCorrelationManager

    Inheritance
    System.Object
    MessageCorrelationManagerBase
    RpcMessageCorrelationManager
    Implements
    IRpcMessageCorrelationManager
    IMessageCorrelationManager
    System.IDisposable
    Inherited Members
    MessageCorrelationManagerBase.PendingRequests
    MessageCorrelationManagerBase.Logger
    MessageCorrelationManagerBase.AddPendingRequest(ICorrelatableMessage<ProtocolMessage>)
    MessageCorrelationManagerBase.TryMatchResponse(ProtocolMessage)
    MessageCorrelationManagerBase.ValidateResponseType(ProtocolMessage, ICorrelatableMessage<ProtocolMessage>)
    MessageCorrelationManagerBase.Dispose()
    System.Object.Equals(System.Object)
    System.Object.Equals(System.Object, System.Object)
    System.Object.GetHashCode()
    System.Object.GetType()
    System.Object.MemberwiseClone()
    System.Object.ReferenceEquals(System.Object, System.Object)
    System.Object.ToString()
    Namespace: Catalyst.Core.Lib.Rpc.IO.Messaging.Correlation
    Assembly: Catalyst.Core.Lib.dll
    Syntax
    public sealed class RpcMessageCorrelationManager : MessageCorrelationManagerBase, IRpcMessageCorrelationManager, IMessageCorrelationManager, IDisposable

    Constructors

    | Improve this Doc View Source

    RpcMessageCorrelationManager(IMemoryCache, ILogger, IChangeTokenProvider, IScheduler)

    Declaration
    public RpcMessageCorrelationManager(IMemoryCache cache, ILogger logger, IChangeTokenProvider changeTokenProvider, IScheduler scheduler = null)
    Parameters
    Type Name Description
    IMemoryCache cache
    ILogger logger
    IChangeTokenProvider changeTokenProvider
    IScheduler scheduler

    Properties

    | Improve this Doc View Source

    EvictionEvents

    Declaration
    public IObservable<ICacheEvictionEvent<ProtocolMessage>> EvictionEvents { get; }
    Property Value
    Type Description
    System.IObservable<ICacheEvictionEvent<ProtocolMessage>>

    Methods

    | Improve this Doc View Source

    Dispose(Boolean)

    Declaration
    protected override void Dispose(bool disposing)
    Parameters
    Type Name Description
    System.Boolean disposing
    Overrides
    MessageCorrelationManagerBase.Dispose(Boolean)
    | Improve this Doc View Source

    EvictionCallback(Object, Object, EvictionReason, Object)

    Declaration
    protected override void EvictionCallback(object key, object value, EvictionReason reason, object state)
    Parameters
    Type Name Description
    System.Object key
    System.Object value
    EvictionReason reason
    System.Object state
    Overrides
    MessageCorrelationManagerBase.EvictionCallback(Object, Object, EvictionReason, Object)

    Implements

    IRpcMessageCorrelationManager
    IMessageCorrelationManager
    System.IDisposable
    • Improve this Doc
    • View Source
    Back to top Copyright © 2019 Catalyst Network