Crate amqp_dds_endpoint 

DDS-AMQP 1.0 Endpoint Daemon — Library-Layer.

Safety classification: TOOLING (Server-Daemon-Bibliothek; kein safety-relevanter Runtime-Code, std-only).

Synchronen, std-only AMQP-1.0-Server-Daemon. Wir lesen AMQP-Frames blocking auf einer TcpStream-Verbindung und treiben die zerodds-amqp-endpoint-State-Machine.

Spec-Quellen:

• dds-amqp-1.0 §2.1 Endpoint Profile (Cl. 2 Connection Acceptance, Cl. 3 Sender+Receiver Links, Cl. 6 SASL).
• amqp-1.0-transport §2.2 Protocol Header, §2.3 Frame Layout, §2.4 Connection State.

Was diese Crate liefert:

• Protocol-Header-Read/Write (AMQP\0\1\0\0 und SASL-Variant).
• Frame-Read/Write (8-Byte Header + Body).
• Performative-Dispatch (Descriptor → InboundFrameKind).
• Per-Connection-Handler (handle_connection), der die State-Machine treibt.
• run_server — Multi-Connection-Accept-Loop mit thread-per-connection.

Was diese Crate nicht liefert (separate Folge-Schichten):

• TLS-Termination — Spec §10.1 Daemon-Layer-Welle.
• DDS-Side-Bruecke (DataWriter/Reader) — Spec §2.1 Cl. 3 Folge-Welle.
• Outbound-Bridge-Mode — Spec §2.2 Cl. 2.
• Reconnect-Loop — Spec §10.8.

Re-exports

pub use client::ClientConfig;

pub use client::ClientError;

pub use client::OutboundSession;

pub use client::ReconnectConfig;

pub use client::connect_outbound;

pub use client::connect_with_reconnect;

pub use frame_io::AmqpProtocol;

pub use frame_io::FrameIoError;

pub use frame_io::ProtocolHeader;

pub use frame_io::read_frame;

pub use frame_io::read_protocol_header;

pub use frame_io::write_frame;

pub use frame_io::write_protocol_header;

pub use handler::ConnectionStats;

pub use handler::HandlerError;

pub use handler::handle_connection;

pub use server::ServerConfig;

pub use server::ServerError;

pub use server::run_server;

Modules

bridge

AMQP↔DDS Bridge-Logic.

client

Outbound Bridge-Client + Reconnect-Loop.

dds_host

DDS-Host Abstraktion fuer die AMQP-Daemon-Bridge.

frame_io

AMQP-1.0 Frame-IO ueber blocking std::io::Read/Write.

handler

Per-Connection Handler — treibt die Endpoint-State-Machine.

server

Multi-Connection-Accept-Loop mit thread-per-connection.