Class QueuePublisherWithResponse<TRequest, TResponse>

Namespace

Tp.RabbitMq

Assembly

Tp.RabbitMq.dll

[Obsolete("Use RpcQueueListener instead")]
public sealed class QueuePublisherWithResponse<TRequest, TResponse> : QueuePublisherWithResponseBase, IQueuePublisherWithResponse<TRequest, TResponse>

Type Parameters

TRequest

TResponse

Inheritance

object

QueuePublisherWithResponseBase

QueuePublisherWithResponse<TRequest, TResponse>

Implements

IQueuePublisherWithResponse<TRequest, TResponse>

Inherited Members

object.GetType()

object.ToString()

object.Equals(object)

object.Equals(object, object)

object.ReferenceEquals(object, object)

object.GetHashCode()

Extension Methods

PublishersExtensions.PublishWithResponse<TRequest, TResponse>(IQueuePublisherWithResponse<TRequest, TResponse>, TRequest)

PublishersExtensions.PublishWithResponse<TRequest, TResponse>(IQueuePublisherWithResponse<TRequest, TResponse>, TRequest, IReadOnlyDictionary<string, string>)

Constructors

QueuePublisherWithResponse(IChannelProvider, ILogger, PublisherWithResponseConfig, IMessageSerializer<TRequest>, IMessageDeserializer<TResponse>)

public QueuePublisherWithResponse(IChannelProvider channelProvider, ILogger logger, PublisherWithResponseConfig config, IMessageSerializer<TRequest> messageSerializer, IMessageDeserializer<TResponse> messageDeserializer)

Parameters

channelProvider IChannelProvider

logger ILogger

config PublisherWithResponseConfig

messageSerializer IMessageSerializer<TRequest>

messageDeserializer IMessageDeserializer<TResponse>

Methods

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

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

Parameters

message TRequest

correlationId string

headers IReadOnlyDictionary<string, string>

Returns

TResponse