zerodds-amqp-endpoint

Layer 5 — Bridges (Tier B). OMG DDS-AMQP-1.0 bidirectional endpoint stack.

zerodds-amqp-endpoint delivers the protocol layers above the AMQP wire codec: SASL frame layer, connection/session/link state machine, address routing, body-encoding mapping, application properties, DDS-bridge trait surfaces (incl. disposition-mapper wire-up §7.7.3), resource limits, catalog + audit + metrics, access control, coexistence hop cap, RPC correlation, and the Annex A configuration schema. Sits on zerodds-amqp-bridge.

Spec anchors

  • OMG DDS-AMQP-1.0 (formal/2024-08-01) §2.1, §6.1, §7, §8.1, §9, §10.2, §11, Annex A.
  • OASIS AMQP 1.0 §2.4, §2.5, §2.6, §3.4, §3.5.3.

Quickstart

use zerodds_amqp_endpoint::{
    DispositionState, LinkRole, LinkSession, NoopDispositionMapper, SettlementMode,
};

let mut link = LinkSession::new(
    "outbound-1".into(),
    0,
    LinkRole::Sender,
    SettlementMode::Unsettled,
);
link.grant_credit(2);
link.deliver().expect("ok");

let mapper = NoopDispositionMapper;
link.settle_with_mapper(&mapper, [0u8; 16], DispositionState::Accepted);
assert_eq!(link.pending_settlements, 0);

Stability

1.0.0-rc.3. RC1-stable; wire format fixed by DDS-AMQP-1.0 + OASIS AMQP-1.0.

zerodds-amqp-endpoint

Layer 5 — Bridges (Tier-B). OMG DDS-AMQP-1.0 bidirektionaler Endpoint-Stack.

zerodds-amqp-endpoint liefert die Protokoll-Schichten oberhalb des AMQP-Wire-Codecs: SASL-Frame-Layer, Connection/Session/Link-State- Machine, Address-Routing, Body-Encoding-Mapping, Application- Properties, DDS-Bridge-Trait-Surfaces (incl. Disposition-Mapper-Wire- up §7.7.3), Resource-Limits, Catalog + Audit + Metrics, Access- Control, Coexistence-Hop-Cap, RPC-Correlation, und Annex-A- Configuration-Schema. Sitzt auf zerodds-amqp-bridge.

Spec-Anker

  • OMG DDS-AMQP-1.0 (formal/2024-08-01) §2.1, §6.1, §7, §8.1, §9, §10.2, §11, Annex A.
  • OASIS AMQP 1.0 §2.4, §2.5, §2.6, §3.4, §3.5.3.

Quickstart

use zerodds_amqp_endpoint::{
    DispositionState, LinkRole, LinkSession, NoopDispositionMapper, SettlementMode,
};

let mut link = LinkSession::new(
    "outbound-1".into(),
    0,
    LinkRole::Sender,
    SettlementMode::Unsettled,
);
link.grant_credit(2);
link.deliver().expect("ok");

let mapper = NoopDispositionMapper;
link.settle_with_mapper(&mapper, [0u8; 16], DispositionState::Accepted);
assert_eq!(link.pending_settlements, 0);

Stabilitaet

1.0.0-rc.3. RC1-stabil; Wire-Format durch DDS-AMQP-1.0 + OASIS AMQP-1.0 fixiert.