Class IModelExensions

Namespace

RabbitMQ.Client

Assembly

RabbitMQ.Client.dll

public static class IModelExensions

Inheritance

object

IModelExensions

Inherited Members

object.GetType()

object.MemberwiseClone()

object.ToString()

object.Equals(object)

object.Equals(object, object)

object.ReferenceEquals(object, object)

object.GetHashCode()

Methods

BasicConsume(IModel, IBasicConsumer, string, bool, string, bool, bool, IDictionary<string, object>)

Start a Basic content-class consumer.

public static string BasicConsume(this IModel model, IBasicConsumer consumer, string queue, bool autoAck = false, string consumerTag = "", bool noLocal = false, bool exclusive = false, IDictionary<string, object> arguments = null)

Parameters

model IModel

consumer IBasicConsumer

queue string

autoAck bool

consumerTag string

noLocal bool

exclusive bool

arguments IDictionary<string, object>

Returns

string

BasicConsume(IModel, string, bool, IBasicConsumer)

Start a Basic content-class consumer.

public static string BasicConsume(this IModel model, string queue, bool autoAck, IBasicConsumer consumer)

Parameters

model IModel

queue string

autoAck bool

consumer IBasicConsumer

Returns

string

BasicConsume(IModel, string, bool, string, IBasicConsumer)

Start a Basic content-class consumer.

public static string BasicConsume(this IModel model, string queue, bool autoAck, string consumerTag, IBasicConsumer consumer)

Parameters

model IModel

queue string

autoAck bool

consumerTag string

consumer IBasicConsumer

Returns

string

BasicConsume(IModel, string, bool, string, IDictionary<string, object>, IBasicConsumer)

Start a Basic content-class consumer.

public static string BasicConsume(this IModel model, string queue, bool autoAck, string consumerTag, IDictionary<string, object> arguments, IBasicConsumer consumer)

Parameters

model IModel

queue string

autoAck bool

consumerTag string

arguments IDictionary<string, object>

consumer IBasicConsumer

Returns

string

BasicPublish(IModel, PublicationAddress, IBasicProperties, ReadOnlyMemory<byte>)

(Extension method) Convenience overload of BasicPublish.

public static void BasicPublish(this IModel model, PublicationAddress addr, IBasicProperties basicProperties, ReadOnlyMemory<byte> body)

Parameters

model IModel

addr PublicationAddress

basicProperties IBasicProperties

body ReadOnlyMemory<byte>

Remarks

The publication occurs with mandatory=false and immediate=false.

BasicPublish(IModel, string, string, IBasicProperties, ReadOnlyMemory<byte>)

(Extension method) Convenience overload of BasicPublish.

public static void BasicPublish(this IModel model, string exchange, string routingKey, IBasicProperties basicProperties, ReadOnlyMemory<byte> body)

Parameters

model IModel

exchange string

routingKey string

basicProperties IBasicProperties

body ReadOnlyMemory<byte>

Remarks

The publication occurs with mandatory=false

BasicPublish(IModel, string, string, bool, IBasicProperties, ReadOnlyMemory<byte>)

(Spec method) Convenience overload of BasicPublish.

public static void BasicPublish(this IModel model, string exchange, string routingKey, bool mandatory = false, IBasicProperties basicProperties = null, ReadOnlyMemory<byte> body = default)

Parameters

model IModel

exchange string

routingKey string

mandatory bool

basicProperties IBasicProperties

body ReadOnlyMemory<byte>

ExchangeBind(IModel, string, string, string, IDictionary<string, object>)

(Extension method) Bind an exchange to an exchange.

public static void ExchangeBind(this IModel model, string destination, string source, string routingKey, IDictionary<string, object> arguments = null)

Parameters

model IModel

destination string

source string

routingKey string

arguments IDictionary<string, object>

ExchangeBindNoWait(IModel, string, string, string, IDictionary<string, object>)

(Extension method) Like exchange bind but sets nowait to true.

public static void ExchangeBindNoWait(this IModel model, string destination, string source, string routingKey, IDictionary<string, object> arguments = null)

Parameters

model IModel

destination string

source string

routingKey string

arguments IDictionary<string, object>

ExchangeDeclare(IModel, string, string, bool, bool, IDictionary<string, object>)

(Spec method) Declare an exchange.

public static void ExchangeDeclare(this IModel model, string exchange, string type, bool durable = false, bool autoDelete = false, IDictionary<string, object> arguments = null)

Parameters

model IModel

exchange string

type string

durable bool

autoDelete bool

arguments IDictionary<string, object>

ExchangeDeclareNoWait(IModel, string, string, bool, bool, IDictionary<string, object>)

(Extension method) Like ExchangeDeclare but sets nowait to true.

public static void ExchangeDeclareNoWait(this IModel model, string exchange, string type, bool durable = false, bool autoDelete = false, IDictionary<string, object> arguments = null)

Parameters

model IModel

exchange string

type string

durable bool

autoDelete bool

arguments IDictionary<string, object>

ExchangeDelete(IModel, string, bool)

(Spec method) Deletes an exchange.

public static void ExchangeDelete(this IModel model, string exchange, bool ifUnused = false)

Parameters

model IModel

exchange string

ifUnused bool

ExchangeDeleteNoWait(IModel, string, bool)

(Extension method) Like ExchangeDelete but sets nowait to true.

public static void ExchangeDeleteNoWait(this IModel model, string exchange, bool ifUnused = false)

Parameters

model IModel

exchange string

ifUnused bool

ExchangeUnbind(IModel, string, string, string, IDictionary<string, object>)

(Spec method) Unbinds an exchange.

public static void ExchangeUnbind(this IModel model, string destination, string source, string routingKey, IDictionary<string, object> arguments = null)

Parameters

model IModel

destination string

source string

routingKey string

arguments IDictionary<string, object>

QueueBind(IModel, string, string, string, IDictionary<string, object>)

(Spec method) Binds a queue.

public static void QueueBind(this IModel model, string queue, string exchange, string routingKey, IDictionary<string, object> arguments = null)

Parameters

model IModel

queue string

exchange string

routingKey string

arguments IDictionary<string, object>

QueueDeclare(IModel, string, bool, bool, bool, IDictionary<string, object>)

(Spec method) Declare a queue.

public static QueueDeclareOk QueueDeclare(this IModel model, string queue = "", bool durable = false, bool exclusive = true, bool autoDelete = true, IDictionary<string, object> arguments = null)

Parameters

model IModel

queue string

durable bool

exclusive bool

autoDelete bool

arguments IDictionary<string, object>

Returns

QueueDeclareOk

QueueDelete(IModel, string, bool, bool)

(Spec method) Deletes a queue.

public static uint QueueDelete(this IModel model, string queue, bool ifUnused = false, bool ifEmpty = false)

Parameters

model IModel

queue string

ifUnused bool

ifEmpty bool

Returns

uint

QueueDeleteNoWait(IModel, string, bool, bool)

(Extension method) Like QueueDelete but sets nowait to true.

public static void QueueDeleteNoWait(this IModel model, string queue, bool ifUnused = false, bool ifEmpty = false)

Parameters

model IModel

queue string

ifUnused bool

ifEmpty bool

QueueUnbind(IModel, string, string, string, IDictionary<string, object>)

(Spec method) Unbinds a queue.

public static void QueueUnbind(this IModel model, string queue, string exchange, string routingKey, IDictionary<string, object> arguments = null)

Parameters

model IModel

queue string

exchange string

routingKey string

arguments IDictionary<string, object>