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
resourceHolderRabbitResourceHolderconnectionFactoryIConnectionFactorysynchedbool
Returns
CreateConnection(IConnectionFactory, bool)
public static IConnection CreateConnection(IConnectionFactory connectionFactory, bool publisherConnectionIfPossible)
Parameters
connectionFactoryIConnectionFactorypublisherConnectionIfPossiblebool
Returns
GetTransactionalResourceHolder(IConnectionFactory, bool)
public static RabbitResourceHolder GetTransactionalResourceHolder(IConnectionFactory connectionFactory, bool synchedLocalTransactionAllowed)
Parameters
connectionFactoryIConnectionFactorysynchedLocalTransactionAllowedbool
Returns
GetTransactionalResourceHolder(IConnectionFactory, bool, bool)
public static RabbitResourceHolder GetTransactionalResourceHolder(IConnectionFactory connectionFactory, bool synchedLocalTransactionAllowed, bool publisherConnectionIfPossible)
Parameters
connectionFactoryIConnectionFactorysynchedLocalTransactionAllowedboolpublisherConnectionIfPossiblebool
Returns
IsChannelTransactional(IModel, IConnectionFactory)
public static bool IsChannelTransactional(IModel channel, IConnectionFactory connectionFactory)
Parameters
channelIModelconnectionFactoryIConnectionFactory
Returns
RegisterDeliveryTag(IConnectionFactory, IModel, ulong)
public static void RegisterDeliveryTag(IConnectionFactory connectionFactory, IModel channel, ulong tag)
Parameters
connectionFactoryIConnectionFactorychannelIModeltagulong
ReleaseResources(RabbitResourceHolder)
public static void ReleaseResources(RabbitResourceHolder resourceHolder)
Parameters
resourceHolderRabbitResourceHolder