Class QueuePublisherWithResponseBase

Namespace

Tp.RabbitMq

Assembly

Tp.RabbitMq.dll

[Obsolete("Use RpcQueueListener and RpcQueueListenerAsync instead")]
public abstract class QueuePublisherWithResponseBase

Inheritance

object

QueuePublisherWithResponseBase

Derived

QueuePublisherWithResponseAsync<TRequest, TResponse>

QueuePublisherWithResponse<TRequest, TResponse>

Inherited Members

object.GetType()

object.MemberwiseClone()

object.ToString()

object.Equals(object)

object.Equals(object, object)

object.ReferenceEquals(object, object)

object.GetHashCode()

Constructors

QueuePublisherWithResponseBase(IChannelProvider, ILogger, PublisherWithResponseConfig)

protected QueuePublisherWithResponseBase(IChannelProvider channelProvider, ILogger logger, PublisherWithResponseConfig publisherWithResponseConfig)

Parameters

channelProvider IChannelProvider

logger ILogger

publisherWithResponseConfig PublisherWithResponseConfig

Fields

ChannelProvider

protected readonly IChannelProvider ChannelProvider

Field Value

IChannelProvider

Config

protected readonly PublisherWithResponseConfig Config

Field Value

PublisherWithResponseConfig

Log

protected readonly ILogger Log

Field Value

ILogger

Methods

ConfigureQueuesAndPublishRequest(IModel, string, byte[], IReadOnlyDictionary<string, string>)

protected (string publishedCorrelationId, QueueDeclareOk responseQueueInfo) ConfigureQueuesAndPublishRequest(IModel channel, string correlationId, byte[] body, IReadOnlyDictionary<string, string> headers)

Parameters

channel IModel

correlationId string

body byte[]

headers IReadOnlyDictionary<string, string>

Returns

(string publishedCorrelationId, QueueDeclareOk responseQueueInfo)

TryDeleteResponseQueue(IModel, string)

protected void TryDeleteResponseQueue(IModel channel, string responseQueueName)

Parameters

channel IModel

responseQueueName string