Table of Contents

Class ConnectionFactoryUtils

Namespace
Steeltoe.Messaging.RabbitMQ.Connection
Assembly
Steeltoe.Messaging.RabbitMQ.dll
public static class ConnectionFactoryUtils
Inheritance
ConnectionFactoryUtils
Inherited Members

Methods

BindResourceToTransaction(RabbitResourceHolder, IConnectionFactory, bool)

public static RabbitResourceHolder BindResourceToTransaction(RabbitResourceHolder resourceHolder, IConnectionFactory connectionFactory, bool synched)

Parameters

resourceHolder RabbitResourceHolder
connectionFactory IConnectionFactory
synched bool

Returns

RabbitResourceHolder

CreateConnection(IConnectionFactory, bool)

public static IConnection CreateConnection(IConnectionFactory connectionFactory, bool publisherConnectionIfPossible)

Parameters

connectionFactory IConnectionFactory
publisherConnectionIfPossible bool

Returns

IConnection

GetTransactionalResourceHolder(IConnectionFactory, bool)

public static RabbitResourceHolder GetTransactionalResourceHolder(IConnectionFactory connectionFactory, bool synchedLocalTransactionAllowed)

Parameters

connectionFactory IConnectionFactory
synchedLocalTransactionAllowed bool

Returns

RabbitResourceHolder

GetTransactionalResourceHolder(IConnectionFactory, bool, bool)

public static RabbitResourceHolder GetTransactionalResourceHolder(IConnectionFactory connectionFactory, bool synchedLocalTransactionAllowed, bool publisherConnectionIfPossible)

Parameters

connectionFactory IConnectionFactory
synchedLocalTransactionAllowed bool
publisherConnectionIfPossible bool

Returns

RabbitResourceHolder

IsChannelTransactional(IModel, IConnectionFactory)

public static bool IsChannelTransactional(IModel channel, IConnectionFactory connectionFactory)

Parameters

channel IModel
connectionFactory IConnectionFactory

Returns

bool

RegisterDeliveryTag(IConnectionFactory, IModel, ulong)

public static void RegisterDeliveryTag(IConnectionFactory connectionFactory, IModel channel, ulong tag)

Parameters

connectionFactory IConnectionFactory
channel IModel
tag ulong

ReleaseResources(RabbitResourceHolder)

public static void ReleaseResources(RabbitResourceHolder resourceHolder)

Parameters

resourceHolder RabbitResourceHolder