X

Class RabbitUtils

Inheritance
System.Object
RabbitUtils
Namespace: Steeltoe.Messaging.RabbitMQ.Connection
Assembly: Steeltoe.Messaging.RabbitMQ.dll
Syntax
public static class RabbitUtils : object

Fields

| Edit this page View Source

ChannelClose_ClassId

Declaration
public const ushort ChannelClose_ClassId = null
Field Value
Type Description
System.UInt16
| Edit this page View Source

ChannelClose_MethodId

Declaration
public const ushort ChannelClose_MethodId = null
Field Value
Type Description
System.UInt16
| Edit this page View Source

Command_Invalid

Declaration
public const int Command_Invalid = null
Field Value
Type Description
System.Int32
| Edit this page View Source

ConnectionClose_ClassId

Declaration
public const ushort ConnectionClose_ClassId = null
Field Value
Type Description
System.UInt16
| Edit this page View Source

ConnectionClose_MethodId

Declaration
public const ushort ConnectionClose_MethodId = null
Field Value
Type Description
System.UInt16
| Edit this page View Source

Declare_MethodId

Declaration
public const ushort Declare_MethodId = null
Field Value
Type Description
System.UInt16
| Edit this page View Source

Exchange_ClassId

Declaration
public const ushort Exchange_ClassId = null
Field Value
Type Description
System.UInt16
| Edit this page View Source

NotFound

Declaration
public const int NotFound = null
Field Value
Type Description
System.Int32
| Edit this page View Source

Precondition_Failed

Declaration
public const int Precondition_Failed = null
Field Value
Type Description
System.Int32
| Edit this page View Source

Queue_ClassId

Declaration
public const ushort Queue_ClassId = null
Field Value
Type Description
System.UInt16
| Edit this page View Source

ReplySuccess

Declaration
public const int ReplySuccess = null
Field Value
Type Description
System.Int32

Methods

| Edit this page View Source

Cancel(RabbitMQ.Client.IModel, String, ILogger)

Declaration
public static void Cancel(RabbitMQ.Client.IModel channel, string consumerTag, ILogger logger = null)
Parameters
Type Name Description
RabbitMQ.Client.IModel channel
System.String consumerTag
ILogger logger
| Edit this page View Source

CloseChannel(RabbitMQ.Client.IModel, ILogger)

Declaration
public static void CloseChannel(RabbitMQ.Client.IModel channel, ILogger logger = null)
Parameters
Type Name Description
RabbitMQ.Client.IModel channel
ILogger logger
| Edit this page View Source

CloseConnection(IConnection, ILogger)

Declaration
public static void CloseConnection(IConnection connection, ILogger logger = null)
Parameters
Type Name Description
IConnection connection
ILogger logger
| Edit this page View Source

CloseMessageConsumer(RabbitMQ.Client.IModel, List<String>, Boolean, ILogger)

Declaration
public static void CloseMessageConsumer(RabbitMQ.Client.IModel channel, List<string> consumerTags, bool transactional, ILogger logger = null)
Parameters
Type Name Description
RabbitMQ.Client.IModel channel
List<System.String> consumerTags
System.Boolean transactional
ILogger logger
| Edit this page View Source

CommitIfNecessary(RabbitMQ.Client.IModel, ILogger)

Declaration
public static void CommitIfNecessary(RabbitMQ.Client.IModel channel, ILogger logger = null)
Parameters
Type Name Description
RabbitMQ.Client.IModel channel
ILogger logger
| Edit this page View Source

DeclareTransactional(RabbitMQ.Client.IModel, ILogger)

Declaration
public static void DeclareTransactional(RabbitMQ.Client.IModel channel, ILogger logger = null)
Parameters
Type Name Description
RabbitMQ.Client.IModel channel
ILogger logger
| Edit this page View Source

GetMaxFrame(IConnectionFactory)

Declaration
public static int GetMaxFrame(IConnectionFactory connectionFactory)
Parameters
Type Name Description
IConnectionFactory connectionFactory
Returns
Type Description
System.Int32
| Edit this page View Source

IsMismatchedQueueArgs(Exception)

Declaration
public static bool IsMismatchedQueueArgs(Exception exception)
Parameters
Type Name Description
Exception exception
Returns
Type Description
System.Boolean
| Edit this page View Source

IsMismatchedQueueArgs(RabbitMQ.Client.ShutdownEventArgs)

Declaration
public static bool IsMismatchedQueueArgs(RabbitMQ.Client.ShutdownEventArgs args)
Parameters
Type Name Description
RabbitMQ.Client.ShutdownEventArgs args
Returns
Type Description
System.Boolean
| Edit this page View Source

IsNormalChannelClose(RabbitMQ.Client.ShutdownEventArgs)

Declaration
public static bool IsNormalChannelClose(RabbitMQ.Client.ShutdownEventArgs args)
Parameters
Type Name Description
RabbitMQ.Client.ShutdownEventArgs args
Returns
Type Description
System.Boolean
| Edit this page View Source

IsNormalShutdown(RabbitMQ.Client.ShutdownEventArgs)

Declaration
public static bool IsNormalShutdown(RabbitMQ.Client.ShutdownEventArgs args)
Parameters
Type Name Description
RabbitMQ.Client.ShutdownEventArgs args
Returns
Type Description
System.Boolean
| Edit this page View Source

IsNormalShutdown(ShutdownSignalException)

Declaration
public static bool IsNormalShutdown(ShutdownSignalException sig)
Parameters
Type Name Description
ShutdownSignalException sig
Returns
Type Description
System.Boolean
| Edit this page View Source

IsPassiveDeclarationChannelClose(Exception)

Declaration
public static bool IsPassiveDeclarationChannelClose(Exception exception)
Parameters
Type Name Description
Exception exception
Returns
Type Description
System.Boolean
| Edit this page View Source

IsPhysicalCloseRequired()

Declaration
public static bool IsPhysicalCloseRequired()
Returns
Type Description
System.Boolean
| Edit this page View Source

RollbackIfNecessary(RabbitMQ.Client.IModel, ILogger)

Declaration
public static void RollbackIfNecessary(RabbitMQ.Client.IModel channel, ILogger logger = null)
Parameters
Type Name Description
RabbitMQ.Client.IModel channel
ILogger logger
| Edit this page View Source

SetPhysicalCloseRequired(RabbitMQ.Client.IModel, Boolean)

Declaration
public static void SetPhysicalCloseRequired(RabbitMQ.Client.IModel channel, bool b)
Parameters
Type Name Description
RabbitMQ.Client.IModel channel
System.Boolean b