Class RpcMessageProcessorBase<TResponse>

Namespace

Tp.RabbitMq

Assembly

Tp.RabbitMq.dll

public abstract class RpcMessageProcessorBase<TResponse> : IQueueListener, IDisposable

Type Parameters

TResponse

Inheritance

object

RpcMessageProcessorBase<TResponse>

Implements

IQueueListener

IDisposable

Derived

RpcQueueListenerAsync<TRequest, TResponse>

RpcQueueListener<TRequest, TResponse>

Inherited Members

object.GetType()

object.MemberwiseClone()

object.ToString()

object.Equals(object)

object.Equals(object, object)

object.ReferenceEquals(object, object)

object.GetHashCode()

Constructors

RpcMessageProcessorBase(ILogger, RpcQueueListenerConfig)

protected RpcMessageProcessorBase(ILogger logger, RpcQueueListenerConfig config)

Parameters

logger ILogger

config RpcQueueListenerConfig

Fields

AwaitingRequests

protected readonly ConcurrentDictionary<string, RpcMessageProcessorBase<TResponse>.RpcAwaitingRequest> AwaitingRequests

Field Value

ConcurrentDictionary<string, RpcMessageProcessorBase<TResponse>.RpcAwaitingRequest>

Config

protected readonly RpcQueueListenerConfig Config

Field Value

RpcQueueListenerConfig

InnerQueueListener

protected IQueueListener InnerQueueListener

Field Value

IQueueListener

Logger

protected readonly ILogger Logger

Field Value

ILogger

Methods

Dispose()

public void Dispose()

GetQueueListenerConfig(RpcQueueListenerConfig)

protected QueueListenerConfig GetQueueListenerConfig(RpcQueueListenerConfig config)

Parameters

config RpcQueueListenerConfig

Returns

QueueListenerConfig

GetQueuePublisherConfig(RpcQueueListenerConfig)

protected QueuePublisherConfig GetQueuePublisherConfig(RpcQueueListenerConfig config)

Parameters

config RpcQueueListenerConfig

Returns

QueuePublisherConfig

GetTimeoutException(string)

protected TimeoutException GetTimeoutException(string correlationId)

Parameters

correlationId string

Returns

TimeoutException

RunAsync()

public Task RunAsync()

Returns

Task