X

Class AbstractConnectionFactory

Inheritance
System.Object
AbstractConnectionFactory
CachingConnectionFactory
Implements
IDisposable
IServiceNameAware
Namespace: Steeltoe.Messaging.RabbitMQ.Connection
Assembly: Steeltoe.Messaging.RabbitMQ.dll
Syntax
public abstract class AbstractConnectionFactory : object, IConnectionFactory

Constructors

| Edit this page View Source

AbstractConnectionFactory(RabbitMQ.Client.IConnectionFactory, ILoggerFactory)

Declaration
protected AbstractConnectionFactory(RabbitMQ.Client.IConnectionFactory rabbitConnectionFactory, ILoggerFactory loggerFactory = null)
Parameters
Type Name Description
RabbitMQ.Client.IConnectionFactory rabbitConnectionFactory
ILoggerFactory loggerFactory
| Edit this page View Source

AbstractConnectionFactory(RabbitMQ.Client.IConnectionFactory, AbstractConnectionFactory, ILoggerFactory)

Declaration
protected AbstractConnectionFactory(RabbitMQ.Client.IConnectionFactory rabbitConnectionFactory, AbstractConnectionFactory publisherConnectionFactory, ILoggerFactory loggerFactory = null)
Parameters
Type Name Description
RabbitMQ.Client.IConnectionFactory rabbitConnectionFactory
AbstractConnectionFactory publisherConnectionFactory
ILoggerFactory loggerFactory

Fields

| Edit this page View Source

_logger

Declaration
protected readonly ILogger _logger
Field Value
Type Description
ILogger
| Edit this page View Source

_loggerFactory

Declaration
protected readonly ILoggerFactory _loggerFactory
Field Value
Type Description
ILoggerFactory
| Edit this page View Source

_rabbitConnectionFactory

Declaration
protected readonly RabbitMQ.Client.IConnectionFactory _rabbitConnectionFactory
Field Value
Type Description
RabbitMQ.Client.IConnectionFactory
| Edit this page View Source

DEFAULT_CLOSE_TIMEOUT

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

Properties

| Edit this page View Source

AbstractPublisherConnectionFactory

Declaration
protected virtual AbstractConnectionFactory AbstractPublisherConnectionFactory { get; }
Property Value
Type Description
AbstractConnectionFactory
| Edit this page View Source

Addresses

Declaration
public virtual List<RabbitMQ.Client.AmqpTcpEndpoint> Addresses { get; set; }
Property Value
Type Description
List<RabbitMQ.Client.AmqpTcpEndpoint>
| Edit this page View Source

BlockedListener

Declaration
public virtual IBlockedListener BlockedListener { get; set; }
Property Value
Type Description
IBlockedListener
| Edit this page View Source

ChannelListener

Declaration
public virtual IChannelListener ChannelListener { get; }
Property Value
Type Description
IChannelListener
| Edit this page View Source

CloseTimeout

Declaration
public virtual int CloseTimeout { get; set; }
Property Value
Type Description
System.Int32
| Edit this page View Source

ConnectionListener

Declaration
public virtual IConnectionListener ConnectionListener { get; }
Property Value
Type Description
IConnectionListener
| Edit this page View Source

ConnectionTimeout

Declaration
public virtual int ConnectionTimeout { get; set; }
Property Value
Type Description
System.Int32
| Edit this page View Source

HasPublisherConnectionFactory

Declaration
public virtual bool HasPublisherConnectionFactory { get; }
Property Value
Type Description
System.Boolean
| Edit this page View Source

Host

Declaration
public virtual string Host { get; set; }
Property Value
Type Description
System.String
| Edit this page View Source

IsPublisherConfirms

Declaration
public virtual bool IsPublisherConfirms { get; set; }
Property Value
Type Description
System.Boolean
| Edit this page View Source

IsPublisherReturns

Declaration
public virtual bool IsPublisherReturns { get; set; }
Property Value
Type Description
System.Boolean
| Edit this page View Source

IsSimplePublisherConfirms

Declaration
public virtual bool IsSimplePublisherConfirms { get; set; }
Property Value
Type Description
System.Boolean
| Edit this page View Source

Password

Declaration
public virtual string Password { get; set; }
Property Value
Type Description
System.String
| Edit this page View Source

Port

Declaration
public virtual int Port { get; set; }
Property Value
Type Description
System.Int32
| Edit this page View Source

PublisherConnectionFactory

Declaration
public virtual IConnectionFactory PublisherConnectionFactory { get; protected set; }
Property Value
Type Description
IConnectionFactory
| Edit this page View Source

RabbitConnectionFactory

Declaration
public virtual RabbitMQ.Client.ConnectionFactory RabbitConnectionFactory { get; }
Property Value
Type Description
RabbitMQ.Client.ConnectionFactory
| Edit this page View Source

RecoveryListener

Declaration
public virtual IRecoveryListener RecoveryListener { get; set; }
Property Value
Type Description
IRecoveryListener
| Edit this page View Source

RequestedHeartBeat

Declaration
public virtual ushort RequestedHeartBeat { get; set; }
Property Value
Type Description
System.UInt16
| Edit this page View Source

ServiceName

Declaration
public virtual string ServiceName { get; set; }
Property Value
Type Description
System.String
| Edit this page View Source

ShuffleAddresses

Declaration
public virtual bool ShuffleAddresses { get; set; }
Property Value
Type Description
System.Boolean
| Edit this page View Source

Uri

Declaration
public virtual Uri Uri { get; set; }
Property Value
Type Description
Uri
| Edit this page View Source

Username

Declaration
public virtual string Username { get; set; }
Property Value
Type Description
System.String
| Edit this page View Source

VirtualHost

Declaration
public virtual string VirtualHost { get; set; }
Property Value
Type Description
System.String

Methods

| Edit this page View Source

AddChannelListener(IChannelListener)

Declaration
public virtual void AddChannelListener(IChannelListener listener)
Parameters
Type Name Description
IChannelListener listener
| Edit this page View Source

AddConnectionListener(IConnectionListener)

Declaration
public virtual void AddConnectionListener(IConnectionListener connectionListener)
Parameters
Type Name Description
IConnectionListener connectionListener
| Edit this page View Source

ClearConnectionListeners()

Declaration
public virtual void ClearConnectionListeners()
| Edit this page View Source

ConnectionShutdownCompleted(Object, RabbitMQ.Client.ShutdownEventArgs)

Declaration
protected virtual void ConnectionShutdownCompleted(object sender, RabbitMQ.Client.ShutdownEventArgs args)
Parameters
Type Name Description
System.Object sender
RabbitMQ.Client.ShutdownEventArgs args
| Edit this page View Source

CreateBareConnection()

Declaration
protected virtual IConnection CreateBareConnection()
Returns
Type Description
IConnection
| Edit this page View Source

CreateConnection()

Declaration
public abstract IConnection CreateConnection()
Returns
Type Description
IConnection
| Edit this page View Source

Destroy()

Declaration
public virtual void Destroy()
| Edit this page View Source

Dispose()

Declaration
public virtual void Dispose()
| Edit this page View Source

GetDefaultHostName()

Declaration
protected virtual string GetDefaultHostName()
Returns
Type Description
System.String
| Edit this page View Source

ObtainNewConnectionName()

Declaration
protected virtual string ObtainNewConnectionName()
Returns
Type Description
System.String
| Edit this page View Source

RemoveConnectionListener(IConnectionListener)

Declaration
public virtual bool RemoveConnectionListener(IConnectionListener connectionListener)
Parameters
Type Name Description
IConnectionListener connectionListener
Returns
Type Description
System.Boolean
| Edit this page View Source

SetAddresses(String)

Declaration
public virtual void SetAddresses(string addresses)
Parameters
Type Name Description
System.String addresses
| Edit this page View Source

SetBlockedListener(IBlockedListener)

Declaration
public virtual void SetBlockedListener(IBlockedListener blockedListener)
Parameters
Type Name Description
IBlockedListener blockedListener
| Edit this page View Source

SetChannelListeners(List<IChannelListener>)

Declaration
public virtual void SetChannelListeners(List<IChannelListener> listeners)
Parameters
Type Name Description
List<IChannelListener> listeners
| Edit this page View Source

SetConnectionListeners(List<IConnectionListener>)

Declaration
public virtual void SetConnectionListeners(List<IConnectionListener> listeners)
Parameters
Type Name Description
List<IConnectionListener> listeners
| Edit this page View Source

SetRecoveryListener(IRecoveryListener)

Declaration
public virtual void SetRecoveryListener(IRecoveryListener recoveryListener)
Parameters
Type Name Description
IRecoveryListener recoveryListener
| Edit this page View Source

ToString()

Declaration
public override string ToString()
Returns
Type Description
System.String

Implements

IDisposable
IServiceNameAware