Skip to main content

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
TypeName
IConnectionconnection

RegisterDirectExchange(IModel, String)

View Source
Declaration
public static void RegisterDirectExchange(this IModel channel, string exchangeName = null)
Parameters
TypeName
IModelchannel
System.StringexchangeName

RegisterDlqExchange(IModel, String)

View Source
Declaration
public static void RegisterDlqExchange(this IModel channel, string exchangeName = null)
Parameters
TypeName
IModelchannel
System.StringexchangeName

RegisterTopicExchange(IModel, String)

View Source
Declaration
public static void RegisterTopicExchange(this IModel channel, string exchangeName = null)
Parameters
TypeName
IModelchannel
System.StringexchangeName

RegisterFanoutExchange(IModel, String)

View Source
Declaration
public static void RegisterFanoutExchange(this IModel channel, string exchangeName)
Parameters
TypeName
IModelchannel
System.StringexchangeName

RegisterQueues<T>(IModel)

View Source
Declaration
public static void RegisterQueues<T>(this IModel channel)
Parameters
TypeName
IModelchannel
Type Parameters
  • T

RegisterQueues(IModel, QueueNames)

View Source
Declaration
public static void RegisterQueues(this IModel channel, QueueNames queueNames)
Parameters
TypeName
IModelchannel
ServiceStack.Messaging.QueueNamesqueueNames

RegisterQueue(IModel, String)

View Source
Declaration
public static void RegisterQueue(this IModel channel, string queueName)
Parameters
TypeName
IModelchannel
System.StringqueueName

RegisterDlq(IModel, String)

View Source
Declaration
public static void RegisterDlq(this IModel channel, string queueName)
Parameters
TypeName
IModelchannel
System.StringqueueName

RegisterTopic(IModel, String)

View Source
Declaration
public static void RegisterTopic(this IModel channel, string queueName)
Parameters
TypeName
IModelchannel
System.StringqueueName

DeleteQueue<T>(IModel)

View Source
Declaration
public static void DeleteQueue<T>(this IModel model)
Parameters
TypeName
IModelmodel
Type Parameters
  • T

DeleteQueues(IModel, String[])

View Source
Declaration
public static void DeleteQueues(this IModel channel, params string[] queues)
Parameters
TypeName
IModelchannel
System.String[]queues

PurgeQueue<T>(IModel)

View Source
Declaration
public static void PurgeQueue<T>(this IModel model)
Parameters
TypeName
IModelmodel
Type Parameters
  • T

PurgeQueues(IModel, String[])

View Source
Declaration
public static void PurgeQueues(this IModel model, params string[] queues)
Parameters
TypeName
IModelmodel
System.String[]queues

RegisterExchangeByName(IModel, String)

View Source
Declaration
public static void RegisterExchangeByName(this IModel channel, string exchange)
Parameters
TypeName
IModelchannel
System.Stringexchange

RegisterQueueByName(IModel, String)

View Source
Declaration
public static void RegisterQueueByName(this IModel channel, string queueName)
Parameters
TypeName
IModelchannel
System.StringqueueName

IsServerNamedQueue(String)

View Source
Declaration
public static bool IsServerNamedQueue(this string queueName)
Returns

System.Boolean

Parameters
TypeName
System.StringqueueName

PopulateFromMessage(IBasicProperties, IMessage)

View Source
Declaration
public static void PopulateFromMessage(this IBasicProperties props, IMessage message)
Parameters
TypeName
IBasicPropertiesprops
ServiceStack.Messaging.IMessagemessage

ToMessage<T>(BasicGetResult)

View Source
Declaration
public static IMessage<T> ToMessage<T>(this BasicGetResult msgResult)
Returns

ServiceStack.Messaging.IMessage<T>

Parameters
TypeName
BasicGetResultmsgResult
Type Parameters
  • T