Class AbstractRoutingConnectionFactory

Namespace

Steeltoe.Messaging.RabbitMQ.Connection

Assembly

Steeltoe.Messaging.RabbitMQ.dll

public abstract class AbstractRoutingConnectionFactory : IConnectionFactory, IDisposable, IServiceNameAware, IRoutingConnectionFactory

Inheritance

object

AbstractRoutingConnectionFactory

Implements

IConnectionFactory

IDisposable

IServiceNameAware

IRoutingConnectionFactory

Derived

SimpleRoutingConnectionFactory

Inherited Members

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.MemberwiseClone()

object.ReferenceEquals(object, object)

object.ToString()

Properties

DefaultTargetConnectionFactory

public IConnectionFactory DefaultTargetConnectionFactory { get; set; }

Property Value

IConnectionFactory

Host

Gets the host name for the connection factory

public string Host { get; }

Property Value

string

IsPublisherConfirms

Gets a value indicating whether if publisher confirms are enabled

public bool IsPublisherConfirms { get; }

Property Value

bool

IsPublisherReturns

Gets a value indicating whether if publisher returns are enabled

public bool IsPublisherReturns { get; }

Property Value

bool

IsSimplePublisherConfirms

Gets a value indicating whether if simple publisher confirms are enabled

public bool IsSimplePublisherConfirms { get; }

Property Value

bool

LenientFallback

public bool LenientFallback { get; set; }

Property Value

bool

Port

Gets the port number for this connection factory

public int Port { get; }

Property Value

int

PublisherConnectionFactory

Gets the publisher connection factory that will be used;

public IConnectionFactory PublisherConnectionFactory { get; }

Property Value

IConnectionFactory

ServiceName

public abstract string ServiceName { get; set; }

Property Value

string

Username

Gets the user name for the connection factory

public string Username { get; }

Property Value

string

VirtualHost

Gets the virtual host name for the connection factory

public string VirtualHost { get; }

Property Value

string

Methods

AddConnectionListener(IConnectionListener)

Add a connection listener to this factory

public virtual void AddConnectionListener(IConnectionListener listener)

Parameters

listener IConnectionListener

AddTargetConnectionFactory(object, IConnectionFactory)

public virtual void AddTargetConnectionFactory(object key, IConnectionFactory connectionFactory)

Parameters

key object

connectionFactory IConnectionFactory

ClearConnectionListeners()

Remove all connection listeners

public virtual void ClearConnectionListeners()

CreateConnection()

Create a connection

public virtual IConnection CreateConnection()

Returns

IConnection

the connection if successful

Destroy()

Close underlying shared connection. The factory is still able to create new connections after this call

public virtual void Destroy()

DetermineCurrentLookupKey()

public abstract object DetermineCurrentLookupKey()

Returns

object

DetermineTargetConnectionFactory()

public virtual IConnectionFactory DetermineTargetConnectionFactory()

Returns

IConnectionFactory

Dispose()

Performs application-defined tasks associated with freeing, releasing, or resetting unmanaged resources.

public void Dispose()

GetTargetConnectionFactory(object)

Returns the ConnectionFactory bound to given lookup key, or null if one does not exist.

public virtual IConnectionFactory GetTargetConnectionFactory(object key)

Parameters

key object

the lookup key to which the factory is bound

Returns

IConnectionFactory

the factory if found

RemoveConnectionListener(IConnectionListener)

Remove a connection facotry from this factory

public virtual bool RemoveConnectionListener(IConnectionListener listener)

Parameters

listener IConnectionListener

Returns

bool

true if removed

RemoveTargetConnectionFactory(object)

public virtual IConnectionFactory RemoveTargetConnectionFactory(object key)

Parameters

key object

Returns

IConnectionFactory

SetTargetConnectionFactories(Dictionary<object, IConnectionFactory>)

public virtual void SetTargetConnectionFactories(Dictionary<object, IConnectionFactory> targetConnectionFactories)

Parameters

targetConnectionFactories Dictionary<object, IConnectionFactory>