Class RabbitUtils

Namespace

Steeltoe.Messaging.RabbitMQ.Connection

Assembly

Steeltoe.Messaging.RabbitMQ.dll

public static class RabbitUtils

Inheritance

object

RabbitUtils

Inherited Members

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.MemberwiseClone()

object.ReferenceEquals(object, object)

object.ToString()

Fields

ChannelClose_ClassId

public const ushort ChannelClose_ClassId = 20

Field Value

ushort

ChannelClose_MethodId

public const ushort ChannelClose_MethodId = 40

Field Value

ushort

Command_Invalid

public const int Command_Invalid = 503

Field Value

int

ConnectionClose_ClassId

public const ushort ConnectionClose_ClassId = 10

Field Value

ushort

ConnectionClose_MethodId

public const ushort ConnectionClose_MethodId = 50

Field Value

ushort

Declare_MethodId

public const ushort Declare_MethodId = 10

Field Value

ushort

Exchange_ClassId

public const ushort Exchange_ClassId = 40

Field Value

ushort

NotFound

public const int NotFound = 404

Field Value

int

Precondition_Failed

public const int Precondition_Failed = 406

Field Value

int

Queue_ClassId

public const ushort Queue_ClassId = 50

Field Value

ushort

ReplySuccess

public const int ReplySuccess = 200

Field Value

int

Methods

Cancel(IModel, string, ILogger)

public static void Cancel(IModel channel, string consumerTag, ILogger logger = null)

Parameters

channel IModel

consumerTag string

logger ILogger

CloseChannel(IModel, ILogger)

public static void CloseChannel(IModel channel, ILogger logger = null)

Parameters

channel IModel

logger ILogger

CloseConnection(IConnection, ILogger)

public static void CloseConnection(IConnection connection, ILogger logger = null)

Parameters

connection IConnection

logger ILogger

CloseMessageConsumer(IModel, List<string>, bool, ILogger)

public static void CloseMessageConsumer(IModel channel, List<string> consumerTags, bool transactional, ILogger logger = null)

Parameters

channel IModel

consumerTags List<string>

transactional bool

logger ILogger

CommitIfNecessary(IModel, ILogger)

public static void CommitIfNecessary(IModel channel, ILogger logger = null)

Parameters

channel IModel

logger ILogger

DeclareTransactional(IModel, ILogger)

public static void DeclareTransactional(IModel channel, ILogger logger = null)

Parameters

channel IModel

logger ILogger

GetMaxFrame(IConnectionFactory)

public static int GetMaxFrame(IConnectionFactory connectionFactory)

Parameters

connectionFactory IConnectionFactory

Returns

int

IsMismatchedQueueArgs(ShutdownEventArgs)

public static bool IsMismatchedQueueArgs(ShutdownEventArgs args)

Parameters

args ShutdownEventArgs

Returns

bool

IsMismatchedQueueArgs(Exception)

public static bool IsMismatchedQueueArgs(Exception exception)

Parameters

exception Exception

Returns

bool

IsNormalChannelClose(ShutdownEventArgs)

public static bool IsNormalChannelClose(ShutdownEventArgs args)

Parameters

args ShutdownEventArgs

Returns

bool

IsNormalShutdown(ShutdownEventArgs)

public static bool IsNormalShutdown(ShutdownEventArgs args)

Parameters

args ShutdownEventArgs

Returns

bool

IsNormalShutdown(ShutdownSignalException)

public static bool IsNormalShutdown(ShutdownSignalException sig)

Parameters

sig ShutdownSignalException

Returns

bool

IsPassiveDeclarationChannelClose(Exception)

public static bool IsPassiveDeclarationChannelClose(Exception exception)

Parameters

exception Exception

Returns

bool

IsPhysicalCloseRequired()

public static bool IsPhysicalCloseRequired()

Returns

bool

RollbackIfNecessary(IModel, ILogger)

public static void RollbackIfNecessary(IModel channel, ILogger logger = null)

Parameters

channel IModel

logger ILogger

SetPhysicalCloseRequired(IModel, bool)

public static void SetPhysicalCloseRequired(IModel channel, bool b)

Parameters

channel IModel

b bool