Crate amq_protocol_tcp 

TCP/TLS connection helpers for AMQP URIs.

Provides AMQPUriTcpExt, a trait that extends AMQPUri with a connect method that opens a TcpStream — with or without TLS — according to the URI scheme and the active runtime/TLS feature flags.

Feature flags

Async runtime (pick exactly one)

Flag	Notes
tokio (default)	Requires a running Tokio runtime
smol	Uses the smol executor
async-global-executor	Uses async-global-executor

TLS backend (pick at most one; rustls is the default)

Flag	Notes
rustls (default)	TLS via rustls
native-tls	TLS via the platform’s native library
openssl	TLS via OpenSSL

Rustls certificate store (only when rustls is active)

Flag	Notes
rustls-platform-verifier (default)	Uses the platform trust store
rustls-native-certs	Loads native root certificates
rustls-webpki-roots-certs	Uses the webpki bundled root set

Rustls crypto provider (at least one must be enabled)

Flag	Notes
rustls--aws_lc_rs (default)	Uses aws-lc-rs
rustls--ring	Uses ring (more portable)

Structs

NativeTlsConnector

A builder for client-side TLS connections.

OpensslConnector

A type which wraps client-side streams in a TLS session.

OwnedTLSConfig

Re-export TcpStream Holds extra TLS configuration

RustlsConnector

A rustls TLS connector ready to perform TLS handshakes.

RustlsConnectorConfig

Configuration helper for RustlsConnector

TLSConfig

Re-export TcpStream Holds extra TLS configuration

Enums

AsyncTcpStream

Re-export TcpStream Wrapper around plain or TLS async TCP streams

HandshakeError

Re-export TcpStream An error returned while performing the handshake

Identity

Re-export TcpStream Holds one of:

MidHandshakeTlsStream

Re-export TcpStream A TLS stream which has been interrupted during the handshake

OwnedIdentity

Re-export TcpStream Holds one of:

TcpStream

Re-export TcpStream Wrapper around plain or TLS TCP streams

Traits

AMQPUriTcpExt

Trait providing a method to connect to a TcpStream

Type Aliases

HandshakeResult

Re-export TcpStream Holds either the TLS TcpStream result or the current handshake state