Class CachingConnectionFactory

Inheritance

System.Object

AbstractConnectionFactory

CachingConnectionFactory

Implements

IConnectionFactory

IDisposable

IServiceNameAware

IShutdownListener

Inherited Members

AbstractConnectionFactory.DEFAULT_CLOSE_TIMEOUT

AbstractConnectionFactory._loggerFactory

AbstractConnectionFactory._logger

AbstractConnectionFactory._rabbitConnectionFactory

AbstractConnectionFactory.RabbitConnectionFactory

AbstractConnectionFactory.Username

AbstractConnectionFactory.Password

AbstractConnectionFactory.Uri

AbstractConnectionFactory.Host

AbstractConnectionFactory.Port

AbstractConnectionFactory.VirtualHost

AbstractConnectionFactory.RequestedHeartBeat

AbstractConnectionFactory.ConnectionTimeout

AbstractConnectionFactory.CloseTimeout

AbstractConnectionFactory.ServiceName

AbstractConnectionFactory.ShuffleAddresses

AbstractConnectionFactory.Addresses

AbstractConnectionFactory.HasPublisherConnectionFactory

AbstractConnectionFactory.PublisherConnectionFactory

AbstractConnectionFactory.BlockedListener

AbstractConnectionFactory.RecoveryListener

AbstractConnectionFactory.ConnectionListener

AbstractConnectionFactory.ChannelListener

AbstractConnectionFactory.RemoveConnectionListener(IConnectionListener)

AbstractConnectionFactory.ClearConnectionListeners()

AbstractConnectionFactory.SetChannelListeners(List<IChannelListener>)

AbstractConnectionFactory.AddChannelListener(IChannelListener)

AbstractConnectionFactory.SetRecoveryListener(IRecoveryListener)

AbstractConnectionFactory.SetBlockedListener(IBlockedListener)

AbstractConnectionFactory.SetAddresses(String)

AbstractConnectionFactory.ToString()

AbstractConnectionFactory.ConnectionShutdownCompleted(Object, RabbitMQ.Client.ShutdownEventArgs)

AbstractConnectionFactory.AbstractPublisherConnectionFactory

AbstractConnectionFactory.CreateBareConnection()

AbstractConnectionFactory.GetDefaultHostName()

AbstractConnectionFactory.ObtainNewConnectionName()

Namespace: Steeltoe.Messaging.RabbitMQ.Connection

Assembly: Steeltoe.Messaging.RabbitMQ.dll

Syntax

public class CachingConnectionFactory : AbstractConnectionFactory, IConnectionFactory, IShutdownListener

Constructors

| Edit this page View Source

CachingConnectionFactory(ILoggerFactory)

Declaration

public CachingConnectionFactory(ILoggerFactory loggerFactory = null)

Parameters

Type	Name	Description
ILoggerFactory	loggerFactory

| Edit this page View Source

CachingConnectionFactory(IOptionsMonitor<RabbitOptions>, ILoggerFactory)

Declaration

public CachingConnectionFactory(IOptionsMonitor<RabbitOptions> optionsMonitor, ILoggerFactory loggerFactory = null)

Parameters

Type	Name	Description
IOptionsMonitor<RabbitOptions>	optionsMonitor
ILoggerFactory	loggerFactory

| Edit this page View Source

CachingConnectionFactory(RabbitMQ.Client.IConnectionFactory, ILoggerFactory)

Declaration

protected CachingConnectionFactory(RabbitMQ.Client.IConnectionFactory rabbitConnectionFactory, ILoggerFactory loggerFactory = null)

Parameters

Type	Name	Description
RabbitMQ.Client.IConnectionFactory	rabbitConnectionFactory
ILoggerFactory	loggerFactory

| Edit this page View Source

CachingConnectionFactory(RabbitMQ.Client.IConnectionFactory, Boolean, CachingConnectionFactory.CachingMode, ILoggerFactory)

Declaration

protected CachingConnectionFactory(RabbitMQ.Client.IConnectionFactory rabbitConnectionFactory, bool isPublisherFactory, CachingConnectionFactory.CachingMode cachingMode = CachingConnectionFactory.CachingMode.CHANNEL, ILoggerFactory loggerFactory = null)

Parameters

Type	Name	Description
RabbitMQ.Client.IConnectionFactory	rabbitConnectionFactory
System.Boolean	isPublisherFactory
CachingConnectionFactory.CachingMode	cachingMode
ILoggerFactory	loggerFactory

| Edit this page View Source

CachingConnectionFactory(Int32, ILoggerFactory)

Declaration

public CachingConnectionFactory(int port, ILoggerFactory loggerFactory = null)

Parameters

Type	Name	Description
System.Int32	port
ILoggerFactory	loggerFactory

| Edit this page View Source

CachingConnectionFactory(String, ILoggerFactory)

Declaration

public CachingConnectionFactory(string hostname, ILoggerFactory loggerFactory = null)

Parameters

Type	Name	Description
System.String	hostname
ILoggerFactory	loggerFactory

| Edit this page View Source

CachingConnectionFactory(String, Int32, ILoggerFactory)

Declaration

public CachingConnectionFactory(string hostNameArg, int port, ILoggerFactory loggerFactory = null)

Parameters

Type	Name	Description
System.String	hostNameArg
System.Int32	port
ILoggerFactory	loggerFactory

| Edit this page View Source

CachingConnectionFactory(String, Int32, RabbitMQ.Client.IConnectionFactory, ILoggerFactory)

Declaration

public CachingConnectionFactory(string hostNameArg, int port, RabbitMQ.Client.IConnectionFactory connectionFactory, ILoggerFactory loggerFactory = null)

Parameters

Type	Name	Description
System.String	hostNameArg
System.Int32	port
RabbitMQ.Client.IConnectionFactory	connectionFactory
ILoggerFactory	loggerFactory

| Edit this page View Source

CachingConnectionFactory(Uri, ILoggerFactory)

Declaration

public CachingConnectionFactory(Uri uri, ILoggerFactory loggerFactory = null)

Parameters

Type	Name	Description
Uri	uri
ILoggerFactory	loggerFactory

| Edit this page View Source

CachingConnectionFactory(Uri, CachingConnectionFactory.CachingMode, ILoggerFactory)

Declaration

public CachingConnectionFactory(Uri uri, CachingConnectionFactory.CachingMode cachingMode = CachingConnectionFactory.CachingMode.CHANNEL, ILoggerFactory loggerFactory = null)

Parameters

Type	Name	Description
Uri	uri
CachingConnectionFactory.CachingMode	cachingMode
ILoggerFactory	loggerFactory

Fields

| Edit this page View Source

DEFAULT_SERVICE_NAME

Declaration

public const string DEFAULT_SERVICE_NAME = null

Field Value

Type	Description
System.String

Properties

| Edit this page View Source

CacheMode

Declaration

public CachingConnectionFactory.CachingMode CacheMode { get; set; }

Property Value

Type	Description
CachingConnectionFactory.CachingMode

| Edit this page View Source

ChannelCacheSize

Declaration

public int ChannelCacheSize { get; set; }

Property Value

Type	Description
System.Int32

| Edit this page View Source

ChannelCheckoutTimeout

Declaration

public int ChannelCheckoutTimeout { get; set; }

Property Value

Type	Description
System.Int32

| Edit this page View Source

CloseExceptionLogger

Declaration

public IConditionalExceptionLogger CloseExceptionLogger { get; set; }

Property Value

Type	Description
IConditionalExceptionLogger

| Edit this page View Source

ConnectionCacheSize

Declaration

public int ConnectionCacheSize { get; set; }

Property Value

Type	Description
System.Int32

| Edit this page View Source

ConnectionLimit

Declaration

public int ConnectionLimit { get; set; }

Property Value

Type	Description
System.Int32

| Edit this page View Source

IsPublisherConfirms

Declaration

public override bool IsPublisherConfirms { get; }

Property Value

Type	Description
System.Boolean

Overrides

AbstractConnectionFactory.IsPublisherConfirms

| Edit this page View Source

IsPublisherReturns

Declaration

public override bool IsPublisherReturns { get; set; }

Property Value

Type	Description
System.Boolean

Overrides

AbstractConnectionFactory.IsPublisherReturns

| Edit this page View Source

IsSimplePublisherConfirms

Declaration

public override bool IsSimplePublisherConfirms { get; }

Property Value

Type	Description
System.Boolean

Overrides

AbstractConnectionFactory.IsSimplePublisherConfirms

| Edit this page View Source

Options

Declaration

protected RabbitOptions Options { get; }

Property Value

Type	Description
RabbitOptions

| Edit this page View Source

PublisherCachingConnectionFactory

Declaration

public CachingConnectionFactory PublisherCachingConnectionFactory { get; set; }

Property Value

Type	Description
CachingConnectionFactory

| Edit this page View Source

PublisherCallbackChannelFactory

Declaration

public IPublisherCallbackChannelFactory PublisherCallbackChannelFactory { get; set; }

Property Value

Type	Description
IPublisherCallbackChannelFactory

| Edit this page View Source

PublisherConfirmType

Declaration

public CachingConnectionFactory.ConfirmType PublisherConfirmType { get; set; }

Property Value

Type	Description
CachingConnectionFactory.ConfirmType

Methods

| Edit this page View Source

AddConnectionListener(IConnectionListener)

Declaration

public override void AddConnectionListener(IConnectionListener connectionListener)

Parameters

Type	Name	Description
IConnectionListener	connectionListener

Overrides

AbstractConnectionFactory.AddConnectionListener(IConnectionListener)

| Edit this page View Source

ChannelShutdownCompleted(Object, RabbitMQ.Client.ShutdownEventArgs)

Declaration

public void ChannelShutdownCompleted(object sender, RabbitMQ.Client.ShutdownEventArgs args)

Parameters

Type	Name	Description
System.Object	sender
RabbitMQ.Client.ShutdownEventArgs	args

| Edit this page View Source

CloseAndClear(LinkedList<IChannelProxy>)

Declaration

protected void CloseAndClear(LinkedList<IChannelProxy> theChannels)

Parameters

Type	Name	Description
LinkedList<IChannelProxy>	theChannels

| Edit this page View Source

CloseChannels(ICollection<IChannelProxy>)

Declaration

protected void CloseChannels(ICollection<IChannelProxy> theChannels)

Parameters

Type	Name	Description
ICollection<IChannelProxy>	theChannels

| Edit this page View Source

CreateConnection()

Declaration

public override IConnection CreateConnection()

Returns

Type	Description
IConnection

Overrides

AbstractConnectionFactory.CreateConnection()

| Edit this page View Source

Destroy()

Declaration

public override void Destroy()

Overrides

AbstractConnectionFactory.Destroy()

| Edit this page View Source

Dispose()

Declaration

public override void Dispose()

Overrides

AbstractConnectionFactory.Dispose()

| Edit this page View Source

GetCacheProperties()

Declaration

public IDictionary<string, object> GetCacheProperties()

Returns

Type	Description
IDictionary<System.String, System.Object>

| Edit this page View Source

Reset(LinkedList<IChannelProxy>, LinkedList<IChannelProxy>, Dictionary<RabbitMQ.Client.IModel, IChannelProxy>)

Declaration

protected void Reset(LinkedList<IChannelProxy> channels, LinkedList<IChannelProxy> txChannels, Dictionary<RabbitMQ.Client.IModel, IChannelProxy> channelsAwaitingAcks)

Parameters

Type	Name	Description
LinkedList<IChannelProxy>	channels
LinkedList<IChannelProxy>	txChannels
Dictionary<RabbitMQ.Client.IModel, IChannelProxy>	channelsAwaitingAcks

| Edit this page View Source

ResetConnection()

Declaration

public void ResetConnection()

| Edit this page View Source

SetConnectionListeners(List<IConnectionListener>)

Declaration

public override void SetConnectionListeners(List<IConnectionListener> listeners)

Parameters

Type	Name	Description
List<IConnectionListener>	listeners

Overrides

AbstractConnectionFactory.SetConnectionListeners(List<IConnectionListener>)

Implements

IConnectionFactory

IDisposable

IServiceNameAware

IShutdownListener