Home - News ( United States | United Kingdom | Italy | Germany ) - Football scores

Showing content from https://rabbitmq.github.io/rabbitmq-dotnet-client/api/RabbitMQ.Client.ConnectionFactory.html below:

Namespace

RabbitMQ.Client

Assembly

RabbitMQ.Client.dll

Main entry point to the RabbitMQ .NET AMQP client API. Constructs IConnection instances.

public sealed class ConnectionFactory : ConnectionFactoryBase, IConnectionFactory

Inheritance

ConnectionFactory

Implements

Inherited Members

Construct a fresh instance, with all fields set to their respective defaults.

public ConnectionFactory()

Default SASL auth mechanisms to use.

public static readonly IEnumerable<IAuthMechanismFactory> DefaultAuthMechanisms

IEnumerable<IAuthMechanismFactory>

Default value for the desired maximum channel number. Default: 2047.

public const ushort DefaultChannelMax = 2047

ushort

Default value for connection attempt timeout.

public static readonly TimeSpan DefaultConnectionTimeout

TimeSpan

Default value for the desired maximum frame size. Default is 0 ("no limit").

public const uint DefaultFrameMax = 0

uint

Default value for desired heartbeat interval. Default is 60 seconds, TimeSpan.Zero means "heartbeats are disabled".

public static readonly TimeSpan DefaultHeartbeat

TimeSpan

Default value for

ConnectionFactory

's

MaxInboundMessageBodySize

.

public const uint DefaultMaxInboundMessageBodySize = 67108864

uint

Default password (value: "guest").

public const string DefaultPass = "guest"

string

Default user name (value: "guest").

public const string DefaultUser = "guest"

string

Default virtual host (value: "/").

public const string DefaultVHost = "/"

string

The AMQP URI SSL protocols.

public SslProtocols AmqpUriSslProtocols { get; set; }

SslProtocols

SASL auth mechanisms to use.

public IEnumerable<IAuthMechanismFactory> AuthMechanisms { get; set; }

IEnumerable<IAuthMechanismFactory>

Set to false to disable automatic connection recovery. Defaults to true.

public bool AutomaticRecoveryEnabled { get; set; }

bool

Dictionary of client properties to be sent to the server.

public IDictionary<string, object?> ClientProperties { get; set; }

IDictionary<string, object>

Default client provided name to be used for connections.

public string? ClientProvidedName { get; set; }

string

Set to a value greater than one to enable concurrent processing. For a concurrency greater than one IAsyncBasicConsumer will be offloaded to the worker thread pool so it is important to choose the value for the concurrency wisely to avoid thread pool overloading. IAsyncBasicConsumer can handle concurrency much more efficiently due to the non-blocking nature of the consumer. Defaults to 1.

public ushort ConsumerDispatchConcurrency { get; set; }

ushort

Amount of time protocol operations (e.g.

queue.declare

) are allowed to take before timing out.

public TimeSpan ContinuationTimeout { get; set; }

TimeSpan

ICredentialsProvider used to obtain username and password.

public ICredentialsProvider? CredentialsProvider { get; set; }

ICredentialsProvider

Address family used by default. Use InterNetwork to force to IPv4. Use InterNetworkV6 to force to IPv6. Or use Unknown to attempt both IPv6 and IPv4.

public static AddressFamily DefaultAddressFamily { get; set; }

AddressFamily

TLS versions enabled by default: TLSv1.2, v1.1, v1.0.

public static SslProtocols DefaultAmqpUriSslProtocols { get; set; }

SslProtocols

Connection endpoint.

public AmqpTcpEndpoint Endpoint { get; set; }

AmqpTcpEndpoint

Factory function for creating the IEndpointResolver used to generate a list of endpoints for the ConnectionFactory to try in order. The default value creates an instance of the DefaultEndpointResolver using the list of endpoints passed in. The DefaultEndpointResolver shuffles the provided list each time it is requested.

public Func<IEnumerable<AmqpTcpEndpoint>, IEndpointResolver> EndpointResolverFactory { get; set; }

Func<IEnumerable<AmqpTcpEndpoint>, IEndpointResolver>

Amount of time protocol handshake operations are allowed to take before timing out.

public TimeSpan HandshakeContinuationTimeout { get; set; }

TimeSpan

The host to connect to.

public string HostName { get; set; }

string

Maximum allowed message size, in bytes, from RabbitMQ. Corresponds to the

ConnectionFactory.DefaultMaxMessageSize

setting.

public uint MaxInboundMessageBodySize { get; set; }

uint

Amount of time client will wait for before re-trying to recover connection.

public TimeSpan NetworkRecoveryInterval { get; set; }

TimeSpan

Password to use when authenticating to the server.

public string Password { get; set; }

string

The port to connect on. UseDefaultPort indicates the default for the protocol should be used.

public int Port { get; set; }

int

Maximum channel number to ask for.

public ushort RequestedChannelMax { get; set; }

ushort

Timeout setting for connection attempts.

public TimeSpan RequestedConnectionTimeout { get; set; }

TimeSpan

Frame-max parameter to ask for (in bytes).

public uint RequestedFrameMax { get; set; }

uint

Heartbeat timeout to use when negotiating with the server.

public TimeSpan RequestedHeartbeat { get; set; }

TimeSpan

Timeout setting for socket read operations.

public TimeSpan SocketReadTimeout { get; set; }

TimeSpan

Timeout setting for socket write operations.

public TimeSpan SocketWriteTimeout { get; set; }

TimeSpan

TLS options setting.

public SslOption Ssl { get; set; }

SslOption

Set to false to make automatic connection recovery not recover topology (exchanges, queues, bindings, etc). Defaults to true.

public bool TopologyRecoveryEnabled { get; set; }

bool

Custom logic for handling topology recovery exceptions that match the specified filters.

public TopologyRecoveryExceptionHandler TopologyRecoveryExceptionHandler { get; set; }

TopologyRecoveryExceptionHandler

Filter to include/exclude entities from topology recovery. Default filter includes all entities in topology recovery.

public TopologyRecoveryFilter TopologyRecoveryFilter { get; set; }

TopologyRecoveryFilter

The uri to use for the connection.

public Uri Uri { get; set; }

Uri

Username to use when authenticating to the server.

public string UserName { get; set; }

string

Virtual host to access during this connection.

public string VirtualHost { get; set; }

string

Given a list of mechanism names supported by the server, select a preferred mechanism, or null if we have none in common.

public IAuthMechanismFactory? AuthMechanismFactory(IEnumerable<string> argServerMechanismNames)

argServerMechanismNames IEnumerable<string>

IAuthMechanismFactory

Asynchronously create a connection using an IEndpointResolver.

public Task<IConnection> CreateConnectionAsync(IEndpointResolver endpointResolver, string? clientProvidedName, CancellationToken cancellationToken = default)

endpointResolver IEndpointResolver

The endpointResolver that returns the endpoints to use for the connection attempt.

clientProvidedName string

Application-specific connection name, will be displayed in the management UI if RabbitMQ server supports it. This value doesn't have to be unique and cannot be used as a connection identifier, e.g. in HTTP API requests. This value is supposed to be human-readable.

cancellationToken CancellationToken

Cancellation token for this connection

Task<IConnection>

Open connection

BrokerUnreachableException

When no hostname was reachable.

Asynchronously create a connection using a list of endpoints. By default each endpoint will be tried in a random order until a successful connection is found or the list is exhausted. The selection behaviour can be overridden by configuring the EndpointResolverFactory.

public Task<IConnection> CreateConnectionAsync(IEnumerable<AmqpTcpEndpoint> endpoints, string? clientProvidedName, CancellationToken cancellationToken = default)

endpoints IEnumerable<AmqpTcpEndpoint>

List of endpoints to use for the initial connection and recovery.

clientProvidedName string

Application-specific connection name, will be displayed in the management UI if RabbitMQ server supports it. This value doesn't have to be unique and cannot be used as a connection identifier, e.g. in HTTP API requests. This value is supposed to be human-readable.

cancellationToken CancellationToken

Cancellation token for this connection

Task<IConnection>

Open connection

BrokerUnreachableException

When no hostname was reachable.

Asynchronously create a connection using a list of endpoints. By default each endpoint will be tried in a random order until a successful connection is found or the list is exhausted. The selection behaviour can be overridden by configuring the EndpointResolverFactory.

public Task<IConnection> CreateConnectionAsync(IEnumerable<AmqpTcpEndpoint> endpoints, CancellationToken cancellationToken = default)

endpoints IEnumerable<AmqpTcpEndpoint>

List of endpoints to use for the initial connection and recovery.

cancellationToken CancellationToken

Cancellation token for this connection

Task<IConnection>

Open connection

BrokerUnreachableException

When no hostname was reachable.

Asynchronously create a connection using a list of hostnames using the configured port. By default each endpoint is tried in a random order until a successful connection is found or the list is exhausted. The selection behaviour can be overridden by configuring the EndpointResolverFactory.

public Task<IConnection> CreateConnectionAsync(IEnumerable<string> hostnames, string? clientProvidedName, CancellationToken cancellationToken = default)

hostnames IEnumerable<string>

List of hostnames to use for the initial connection and recovery.

clientProvidedName string

Application-specific connection name, will be displayed in the management UI if RabbitMQ server supports it. This value doesn't have to be unique and cannot be used as a connection identifier, e.g. in HTTP API requests. This value is supposed to be human-readable.

cancellationToken CancellationToken

Cancellation token for this connection

Task<IConnection>

Open connection

BrokerUnreachableException

When no hostname was reachable.

Asynchronously create a connection using a list of hostnames using the configured port. By default each hostname is tried in a random order until a successful connection is found or the list is exhausted using the DefaultEndpointResolver. The selection behaviour can be overridden by configuring the EndpointResolverFactory.

public Task<IConnection> CreateConnectionAsync(IEnumerable<string> hostnames, CancellationToken cancellationToken = default)

hostnames IEnumerable<string>

List of hostnames to use for the initial connection and recovery.

cancellationToken CancellationToken

Cancellation token for this connection

Task<IConnection>

Open connection

BrokerUnreachableException

When no hostname was reachable.

Asynchronously create a connection to one of the endpoints provided by the IEndpointResolver returned by the EndpointResolverFactory. By default the configured hostname and port are used.

public Task<IConnection> CreateConnectionAsync(string? clientProvidedName, CancellationToken cancellationToken = default)

clientProvidedName string

Application-specific connection name, will be displayed in the management UI if RabbitMQ server supports it. This value doesn't have to be unique and cannot be used as a connection identifier, e.g. in HTTP API requests. This value is supposed to be human-readable.

cancellationToken CancellationToken

Cancellation token for this connection

Task<IConnection>

BrokerUnreachableException

When the configured hostname was not reachable.

Asynchronously create a connection to one of the endpoints provided by the IEndpointResolver returned by the EndpointResolverFactory. By default the configured hostname and port are used.

public Task<IConnection> CreateConnectionAsync(CancellationToken cancellationToken = default)

cancellationToken CancellationToken

Cancellation token for this connection

Task<IConnection>

BrokerUnreachableException

When the configured hostname was not reachable.

RetroSearch is an open source project built by @garambo | Open a GitHub Issue

Search and Browse the WWW like it's 1997 | Search results from DuckDuckGo

HTML: 3.2 | Encoding: UTF-8 | Version: 0.7.4