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