Represents a TCP-addressable AMQP peer: a host name and port number.
public class AmqpTcpEndpoint
AmqpTcpEndpoint
Construct an AmqpTcpEndpoint with "localhost" as the hostname, and using the default port.
AmqpTcpEndpoint(string, int)Creates a new instance of the AmqpTcpEndpoint.
public AmqpTcpEndpoint(string hostName, int portOrMinusOne = -1)
Parameters
hostName
string
Hostname.
portOrMinusOne
int
Port number. If the port number is -1, the default port number will be used.
Creates a new instance of the AmqpTcpEndpoint.
public AmqpTcpEndpoint(string hostName, int portOrMinusOne, SslOption ssl)
Parameters
hostName
string
Hostname.
portOrMinusOne
int
Port number. If the port number is -1, the default port number will be used.
ssl
SslOption
Ssl option.
Creates a new instance of the AmqpTcpEndpoint.
public AmqpTcpEndpoint(string hostName, int portOrMinusOne, SslOption ssl, uint maxInboundMessageBodySize)
Parameters
hostName
string
Hostname.
portOrMinusOne
int
Port number. If the port number is -1, the default port number will be used.
ssl
SslOption
Ssl option.
maxInboundMessageBodySize
uint
Maximum message size from RabbitMQ.
Creates a new instance of the AmqpTcpEndpoint with the given Uri.
public AmqpTcpEndpoint(Uri uri)
Parameters
uri
Uri
Creates a new instance of the AmqpTcpEndpoint with the given Uri and ssl options.
public AmqpTcpEndpoint(Uri uri, SslOption ssl)
Parameters
uri
Uri
ssl
SslOption
Default Amqp ssl port.
public const int DefaultAmqpSslPort = 5671
Field Value
Indicates that the default port for the protocol should be used.
public const int UseDefaultPort = -1
Field Value
Used to force the address family of the endpoint. Use InterNetwork to force to IPv4. Use InterNetworkV6 to force to IPv6. Or use Unknown to attempt both IPv6 and IPv4.
public AddressFamily AddressFamily { get; set; }
Property Value
Retrieve or set the hostname of this AmqpTcpEndpoint.
public string HostName { get; set; }
Property Value
Get the maximum size for a message in bytes. The default value is defined in DefaultMaxInboundMessageBodySize.
public uint MaxInboundMessageBodySize { get; }
Property Value
Retrieve or set the port number of this AmqpTcpEndpoint. A port number of -1 causes the default port number.
public int Port { get; set; }
Property Value
Retrieve IProtocol of this AmqpTcpEndpoint.
public IProtocol Protocol { get; }
Property Value
Retrieve the TLS options for this AmqpTcpEndpoint. If not set, null is returned.
public SslOption Ssl { get; set; }
Property Value
Clones the endpoint.
ReturnsA copy with the same hostname, port, and TLS settings
Clones the endpoint using the provided hostname.
public AmqpTcpEndpoint CloneWithHostname(string hostname)
Parameters
hostname
string
Hostname to use
A copy with the provided hostname and port/TLS settings of this endpoint
Compares this instance by value (protocol, hostname, port) against another instance.
public override bool Equals(object? obj)
Parameters
obj
object
Implementation of hash code depending on protocol, hostname and port, to line up with the implementation of Equals(object?).
public override int GetHashCode()
Returns
Construct an instance from a protocol and an address in "hostname:port" format.
public static AmqpTcpEndpoint Parse(string address)
Parameters
address
string
Splits the passed-in string on ",", and passes the substrings to Parse(string).
public static AmqpTcpEndpoint[] ParseMultiple(string addresses)
Parameters
addresses
string
Returns a URI-like string of the form amqp-PROTOCOL://HOSTNAME:PORTNUMBER.
public override string ToString()
Returns
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