Class PublishersExtensions

Namespace

Tp.RabbitMq

Assembly

Tp.RabbitMq.dll

public static class PublishersExtensions

Inheritance

object

PublishersExtensions

Inherited Members

object.GetType()

object.MemberwiseClone()

object.ToString()

object.Equals(object)

object.Equals(object, object)

object.ReferenceEquals(object, object)

object.GetHashCode()

Methods

PublishMessageAsync<TMessage>(IExchangePublisherAsync<TMessage>, string, TMessage)

public static Task PublishMessageAsync<TMessage>(this IExchangePublisherAsync<TMessage> queuePublisher, string routingKey, TMessage message)

Parameters

queuePublisher IExchangePublisherAsync<TMessage>

routingKey string

message TMessage

Returns

Task

Type Parameters

TMessage

PublishMessageAsync<TMessage>(IExchangePublisherAsync<TMessage>, string, TMessage, IReadOnlyDictionary<string, string>)

public static Task PublishMessageAsync<TMessage>(this IExchangePublisherAsync<TMessage> queuePublisher, string routingKey, TMessage message, IReadOnlyDictionary<string, string> headers)

Parameters

queuePublisher IExchangePublisherAsync<TMessage>

routingKey string

message TMessage

headers IReadOnlyDictionary<string, string>

Returns

Task

Type Parameters

TMessage

PublishMessageAsync<TMessage>(IQueuePublisherAsync<TMessage>, TMessage)

public static Task PublishMessageAsync<TMessage>(this IQueuePublisherAsync<TMessage> queuePublisher, TMessage message)

Parameters

queuePublisher IQueuePublisherAsync<TMessage>

message TMessage

Returns

Task

Type Parameters

TMessage

PublishMessageAsync<TMessage>(IQueuePublisherAsync<TMessage>, TMessage, IReadOnlyDictionary<string, string>)

public static Task PublishMessageAsync<TMessage>(this IQueuePublisherAsync<TMessage> queuePublisher, TMessage message, IReadOnlyDictionary<string, string> headers)

Parameters

queuePublisher IQueuePublisherAsync<TMessage>

message TMessage

headers IReadOnlyDictionary<string, string>

Returns

Task

Type Parameters

TMessage

PublishMessageAsync<TMessage>(IQueuePublisherAsync<TMessage>, TMessage, string)

public static Task PublishMessageAsync<TMessage>(this IQueuePublisherAsync<TMessage> queuePublisher, TMessage message, string correlationId)

Parameters

queuePublisher IQueuePublisherAsync<TMessage>

message TMessage

correlationId string

Returns

Task

Type Parameters

TMessage

PublishMessage<TMessage>(IExchangePublisher<TMessage>, string, TMessage)

public static void PublishMessage<TMessage>(this IExchangePublisher<TMessage> exchangePublisher, string routingKey, TMessage message)

Parameters

exchangePublisher IExchangePublisher<TMessage>

routingKey string

message TMessage

Type Parameters

TMessage

PublishMessage<TMessage>(IExchangePublisher<TMessage>, string, TMessage, IReadOnlyDictionary<string, string>)

public static void PublishMessage<TMessage>(this IExchangePublisher<TMessage> exchangePublisher, string routingKey, TMessage message, IReadOnlyDictionary<string, string> headers)

Parameters

exchangePublisher IExchangePublisher<TMessage>

routingKey string

message TMessage

headers IReadOnlyDictionary<string, string>

Type Parameters

TMessage

PublishMessage<TMessage>(IQueuePublisher<TMessage>, TMessage)

public static void PublishMessage<TMessage>(this IQueuePublisher<TMessage> queuePublisher, TMessage message)

Parameters

queuePublisher IQueuePublisher<TMessage>

message TMessage

Type Parameters

TMessage

PublishMessage<TMessage>(IQueuePublisher<TMessage>, TMessage, IReadOnlyDictionary<string, string>)

public static void PublishMessage<TMessage>(this IQueuePublisher<TMessage> queuePublisher, TMessage message, IReadOnlyDictionary<string, string> headers)

Parameters

queuePublisher IQueuePublisher<TMessage>

message TMessage

headers IReadOnlyDictionary<string, string>

Type Parameters

TMessage

PublishMessage<TMessage>(IQueuePublisher<TMessage>, TMessage, string)

public static void PublishMessage<TMessage>(this IQueuePublisher<TMessage> queuePublisher, TMessage message, string correlationId)

Parameters

queuePublisher IQueuePublisher<TMessage>

message TMessage

correlationId string

Type Parameters

TMessage

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

public static Task<TResponse> PublishWithResponseAsync<TRequest, TResponse>(this IQueuePublisherWithResponseAsync<TRequest, TResponse> publisher, TRequest message)

Parameters

publisher IQueuePublisherWithResponseAsync<TRequest, TResponse>

message TRequest

Returns

Task<TResponse>

Type Parameters

TRequest

TResponse

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

public static Task<TResponse> PublishWithResponseAsync<TRequest, TResponse>(this IQueuePublisherWithResponseAsync<TRequest, TResponse> publisher, TRequest message, IReadOnlyDictionary<string, string> headers)

Parameters

publisher IQueuePublisherWithResponseAsync<TRequest, TResponse>

message TRequest

headers IReadOnlyDictionary<string, string>

Returns

Task<TResponse>

Type Parameters

TRequest

TResponse

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

public static TResponse PublishWithResponse<TRequest, TResponse>(this IQueuePublisherWithResponse<TRequest, TResponse> publisher, TRequest message)

Parameters

publisher IQueuePublisherWithResponse<TRequest, TResponse>

message TRequest

Returns

TResponse

Type Parameters

TRequest

TResponse

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

public static TResponse PublishWithResponse<TRequest, TResponse>(this IQueuePublisherWithResponse<TRequest, TResponse> publisher, TRequest message, IReadOnlyDictionary<string, string> headers)

Parameters

publisher IQueuePublisherWithResponse<TRequest, TResponse>

message TRequest

headers IReadOnlyDictionary<string, string>

Returns

TResponse

Type Parameters

TRequest

TResponse