Class RpcQueueListenerAsync<TRequest, TResponse>

Namespace

Tp.RabbitMq

Assembly

Tp.RabbitMq.dll

public sealed class RpcQueueListenerAsync<TRequest, TResponse> : RpcMessageProcessorBase<TResponse>, IQueueListener, IDisposable, IQueuePublisherWithResponseAsync<TRequest, TResponse>

Type Parameters

TRequest

TResponse

Inheritance

object

RpcMessageProcessorBase<TResponse>

RpcQueueListenerAsync<TRequest, TResponse>

Implements

IQueueListener

IDisposable

IQueuePublisherWithResponseAsync<TRequest, TResponse>

Inherited Members

RpcMessageProcessorBase<TResponse>.Dispose()

RpcMessageProcessorBase<TResponse>.RunAsync()

object.GetType()

object.ToString()

object.Equals(object)

object.Equals(object, object)

object.ReferenceEquals(object, object)

object.GetHashCode()

Extension Methods

PublishersExtensions.PublishWithResponseAsync<TRequest, TResponse>(IQueuePublisherWithResponseAsync<TRequest, TResponse>, TRequest)

PublishersExtensions.PublishWithResponseAsync<TRequest, TResponse>(IQueuePublisherWithResponseAsync<TRequest, TResponse>, TRequest, IReadOnlyDictionary<string, string>)

Constructors

RpcQueueListenerAsync(IConnectionManager, IChannelProvider, ILogger, IMessageSerializerAsync<TRequest>, IMessageDeserializerAsync<TResponse>, RpcQueueListenerConfig)

public RpcQueueListenerAsync(IConnectionManager connectionManager, IChannelProvider channelProvider, ILogger logger, IMessageSerializerAsync<TRequest> messageSerializer, IMessageDeserializerAsync<TResponse> messageDeserializer, RpcQueueListenerConfig config)

Parameters

connectionManager IConnectionManager

channelProvider IChannelProvider

logger ILogger

messageSerializer IMessageSerializerAsync<TRequest>

messageDeserializer IMessageDeserializerAsync<TResponse>

config RpcQueueListenerConfig

Methods

PublishWithResponseAsync(TRequest, string, IReadOnlyDictionary<string, string>)

public Task<TResponse> PublishWithResponseAsync(TRequest message, string correlationId, IReadOnlyDictionary<string, string> headers)

Parameters

message TRequest

correlationId string

headers IReadOnlyDictionary<string, string>

Returns

Task<TResponse>