Show / Hide Table of Contents

Class RabbitMqManager

Менеджер соединения с RabbitMQ.

Inheritance
System.Object
RabbitMqManager
Namespace:InfinniPlatform.MessageQueue.Management
Assembly:InfinniPlatform.MessageQueue.RabbitMQ.dll
Syntax
public class RabbitMqManager : IDisposable

Constructors

| Improve this Doc View Source

RabbitMqManager(RabbitMqMessageQueueOptions, AppOptions, ILogger<RabbitMqManager>)

Declaration
public RabbitMqManager(RabbitMqMessageQueueOptions options, AppOptions appOptions, ILogger<RabbitMqManager> logger)
Parameters
Type Name Description
RabbitMqMessageQueueOptions options
AppOptions appOptions
ILogger<RabbitMqManager> logger

Properties

| Improve this Doc View Source

BroadcastExchangeName

Declaration
public string BroadcastExchangeName { get; }
Property Value
Type Description
System.String
| Improve this Doc View Source

Connection

Declaration
public IConnection Connection { get; }
Property Value
Type Description
IConnection

Methods

| Improve this Doc View Source

DeclareBroadcastQueue(String)

Создает очередь для широковещательных сообщений по ключу.

Declaration
public string DeclareBroadcastQueue(string routingKey)
Parameters
Type Name Description
System.String routingKey

Ключ.

Returns
Type Description
System.String
| Improve this Doc View Source

DeclareTaskQueue(String)

Создает очередь для сообщений по имени.

Declaration
public string DeclareTaskQueue(string queueName)
Parameters
Type Name Description
System.String queueName

Имя очереди.

Returns
Type Description
System.String
| Improve this Doc View Source

Dispose()

Declaration
public void Dispose()
| Improve this Doc View Source

GetBroadcastKey(String)

Создает ключ из ключа.

Declaration
public string GetBroadcastKey(string key)
Parameters
Type Name Description
System.String key

Ключ.

Returns
Type Description
System.String
| Improve this Doc View Source

GetChannel()

Создает канал.

Declaration
public IModel GetChannel()
Returns
Type Description
IModel
| Improve this Doc View Source

GetChannel(UInt16)

Создает канал.

Declaration
public IModel GetChannel(ushort prefetchCount)
Parameters
Type Name Description
System.UInt16 prefetchCount
Returns
Type Description
IModel
| Improve this Doc View Source

GetTaskKey(String)

Создает ключ из ключа.

Declaration
public string GetTaskKey(string key)
Parameters
Type Name Description
System.String key

Ключ.

Returns
Type Description
System.String

Events

| Improve this Doc View Source

OnReconnect

Событие, вызываемое при восстановлении соединения с сервером RabbitMq.

Declaration
public event RabbitMqManager.ReconnectEventHandler OnReconnect
Event Type
Type Description
RabbitMqManager.ReconnectEventHandler

Extension Methods

DynamicCollectionExtensions.GetItem(Object, Int32)
DynamicCollectionExtensions.SetItem(Object, Int32, Object)
DynamicCollectionExtensions.AddItem(Object, Object)
DynamicCollectionExtensions.InsertItem(Object, Int32, Object)
DynamicCollectionExtensions.RemoveItem(Object, Object)
DynamicCollectionExtensions.RemoveItemAt(Object, Int32)
DynamicCollectionExtensions.MoveItem(Object, Object, Int32)
DynamicObjectExtensions.TryGetPropertyValue(Object, String)
DynamicObjectExtensions.TrySetPropertyValue(Object, String, Object)
DynamicObjectExtensions.TryGetPropertyValueByPath(Object, String)
DynamicObjectExtensions.TrySetPropertyValueByPath(Object, String, Object)
ReflectionExtensions.IsInstanceOfType(Object, Type)
ReflectionExtensions.GetMemberValue(Object, String)
ReflectionExtensions.SetMemberValue(Object, String, Object)
ReflectionExtensions.InvokeMember(Object, String, Object[], out Object, Type[])
ReflectionExtensions.GetFieldValue(Object, FieldInfo)
ReflectionExtensions.SetFieldValue(Object, FieldInfo, Object)
ReflectionExtensions.GetPropertyValue(Object, PropertyInfo)
ReflectionExtensions.SetPropertyValue(Object, PropertyInfo, Object)
ReflectionExtensions.GetMethodDelegate(Object, MethodInfo)
ReflectionExtensions.GetEventDelegate(Object, EventInfo)
ReflectionExtensions.SetEventDelegate(Object, EventInfo, Object)
CommonExtensions.ExecuteSilent<T>(T, Action<T>)
  • Improve this Doc
  • View Source
Back to top © Copyright Infinnity Solutions Ltd, 2010–2017.