RabbitMqExtensions

Assembly: ServiceStack.RabbitMq.dll

View Source

Declaration

public static class RabbitMqExtensions

Methods

OpenChannel(IConnection)

View Source

Declaration

public static IModel OpenChannel(this IConnection connection)

Returns

IModel

Parameters

Type	Name
IConnection	connection

RegisterDirectExchange(IModel, String)

View Source

Declaration

public static void RegisterDirectExchange(this IModel channel, string exchangeName = null)

Parameters

Type	Name
IModel	channel
System.String	exchangeName

RegisterDlqExchange(IModel, String)

View Source

Declaration

public static void RegisterDlqExchange(this IModel channel, string exchangeName = null)

Parameters

Type	Name
IModel	channel
System.String	exchangeName

RegisterTopicExchange(IModel, String)

View Source

Declaration

public static void RegisterTopicExchange(this IModel channel, string exchangeName = null)

Parameters

Type	Name
IModel	channel
System.String	exchangeName

RegisterFanoutExchange(IModel, String)

View Source

Declaration

public static void RegisterFanoutExchange(this IModel channel, string exchangeName)

Parameters

Type	Name
IModel	channel
System.String	exchangeName

RegisterQueues<T>(IModel)

View Source

Declaration

public static void RegisterQueues<T>(this IModel channel)

Parameters

Type	Name
IModel	channel

Type Parameters

• T

RegisterQueues(IModel, QueueNames)

View Source

Declaration

public static void RegisterQueues(this IModel channel, QueueNames queueNames)

Parameters

Type	Name
IModel	channel
ServiceStack.Messaging.QueueNames	queueNames

RegisterQueue(IModel, String)

View Source

Declaration

public static void RegisterQueue(this IModel channel, string queueName)

Parameters

Type	Name
IModel	channel
System.String	queueName

RegisterDlq(IModel, String)

View Source

Declaration

public static void RegisterDlq(this IModel channel, string queueName)

Parameters

Type	Name
IModel	channel
System.String	queueName

RegisterTopic(IModel, String)

View Source

Declaration

public static void RegisterTopic(this IModel channel, string queueName)

Parameters

Type	Name
IModel	channel
System.String	queueName

DeleteQueue<T>(IModel)

View Source

Declaration

public static void DeleteQueue<T>(this IModel model)

Parameters

Type	Name
IModel	model

Type Parameters

• T

DeleteQueues(IModel, String[])

View Source

Declaration

public static void DeleteQueues(this IModel channel, params string[] queues)

Parameters

Type	Name
IModel	channel
System.String[]	queues

PurgeQueue<T>(IModel)

View Source

Declaration

public static void PurgeQueue<T>(this IModel model)

Parameters

Type	Name
IModel	model

Type Parameters

• T

PurgeQueues(IModel, String[])

View Source

Declaration

public static void PurgeQueues(this IModel model, params string[] queues)

Parameters

Type	Name
IModel	model
System.String[]	queues

RegisterExchangeByName(IModel, String)

View Source

Declaration

public static void RegisterExchangeByName(this IModel channel, string exchange)

Parameters

Type	Name
IModel	channel
System.String	exchange

RegisterQueueByName(IModel, String)

View Source

Declaration

public static void RegisterQueueByName(this IModel channel, string queueName)

Parameters

Type	Name
IModel	channel
System.String	queueName

IsServerNamedQueue(String)

View Source

Declaration

public static bool IsServerNamedQueue(this string queueName)

Returns

System.Boolean

Parameters

Type	Name
System.String	queueName

PopulateFromMessage(IBasicProperties, IMessage)

View Source

Declaration

public static void PopulateFromMessage(this IBasicProperties props, IMessage message)

Parameters

Type	Name
IBasicProperties	props
ServiceStack.Messaging.IMessage	message

ToMessage<T>(BasicGetResult)

View Source

Declaration

public static IMessage<T> ToMessage<T>(this BasicGetResult msgResult)

Returns

ServiceStack.Messaging.IMessage<T>

Parameters

Type	Name
BasicGetResult	msgResult

Type Parameters

• T