LiteBus
CatalogTransport

Transport Axis Capability Catalog

LiteBus transport is the broker-facing publish and consume axis. Dispatch and ingress call transport contracts (ITransportPublisher, IMessageConsumer) but own durable storage, leasing, and processor policy.

Role in LiteBus

Outbox and inbox dispatch   -> ITransportPublisher.PublishAsync
Inbox ingress adapters      -> IMessageConsumer.StartAsync
Raw transport hosts         -> IMessageConsumer + TransportConsumerHandlerInvoker

Transport maps durable envelope metadata to canonical wire headers. It does not write inbox rows, lease envelopes, or run command and event mediators.

Capability Pages and Quality Bar

Every page in this folder is a reference contract and uses the same required sections:

SectionRequired content
ID, Name, Maturity, SummaryStable capability identity and tier
What it doesRuntime behavior and boundaries
Public surfaceAPI tables with concrete types and members
PackagesPackage and adapter ownership
RequiresCapability dependencies
InvariantsBehavior that must remain stable
Non-goalsExplicit exclusions
ObservabilityVerified meter, activity, and tag names from LiteBus.Transport*
Test coverageCovered, Untested, and Out-of-scope
Deep docsAxis and feature guides

manual-acknowledgement.md and ingress/amqp.md remain the depth benchmark for all pages.

Packages

PackageDependency rolePurpose
LiteBus.Transport.AbstractionsPlatform contractsContracts, canonical headers, ack model
LiteBus.TransportCore implementationCircuit breaker, tracing, header mapper, invoker
LiteBus.Transport.AmqpTechnology adapterRabbitMQ and LavinMQ adapter
LiteBus.Transport.KafkaTechnology adapterKafka adapter
LiteBus.Transport.AwsSqsTechnology adapterAWS SQS adapter
LiteBus.Transport.AzureServiceBusTechnology adapterAzure Service Bus adapter
LiteBus.Transport.InMemoryTechnology adapterIn-process channel adapter
LiteBus.Transport.Extensions.OpenTelemetryHost adapterAddLiteBusTransportMetrics()
LiteBus.Transport.Amqp.Extensions.OpenTelemetryHost adapterAddLiteBusAmqpMetrics() alias

Capability Index

IDNameMaturityFile
transport.publish-consume-contractsPublish and consume contractsGApublish-consume-contracts.md
transport.manual-acknowledgementManual acknowledgement modelGAmanual-acknowledgement.md
transport.canonical-headersCanonical wire headersGAcanonical-headers.md
transport.envelope-header-mappingEnvelope to header mappingGAenvelope-header-mapping.md
transport.circuit-breakerTransport circuit breakerGAcircuit-breaker.md
transport.consumer-handler-invokerConsumer handler invokerGAconsumer-handler-invoker.md
transport.single-broker-registrationSingle broker registrationGAsingle-broker-registration.md
transport.tenant-routingTenant routing strategyGAtenant-routing.md
transport.tracingPublish and consume tracingGAtracing.md
transport.metricsCircuit breaker metricsGAmetrics.md
transport.amqpAMQP transportGAamqp.md
transport.kafkaKafka transportGAkafka.md
transport.azure-service-busAzure Service Bus transportBetaazure-service-bus.md
transport.aws-sqsAWS SQS transportBetaaws-sqs.md
transport.inmemoryIn-memory transportGAinmemory.md

Four-Executor Test Pattern

Transport reference pages use a four-executor test map:

ExecutorScope
LiteBus.Transport.UnitTestsAdapter and core unit behavior (Amqp/, Kafka/, AwsSqs/, AzureServiceBus/, InMemory/)
LiteBus.Transport.IntegrationTestsTransport wire tests (AMQP only in v6)
LiteBus.Durable.IntegrationTestsDispatch and ingress hops that exercise transport through durable pipelines
Application host executorConsumer application integration that composes LiteBus modules; repo helper package LiteBus.Transport.IntegrationTesting provides fixtures only and is not an executor

Custom adapter authors can reference the published LiteBus.Transport.Testing package and derive from TransportContractTests. The broker-neutral suite verifies payload and header round trips, explicit redelivery, and cancellation against the adapter's real broker.

Shared Observability Contract

Transport circuit breaker metrics are emitted on meter LiteBus.Transport and tagged by litebus.transport.broker.

InstrumentPublic constantValue semantics
litebus.transport.circuit_breaker.openLiteBusTransportTelemetry.CircuitBreakerOpenInstrumentName1 when any publisher circuit is open or half-open; otherwise 0
litebus.transport.circuit_breaker.failure_countLiteBusTransportTelemetry.CircuitBreakerFailureCountInstrumentNameSum of current failures across destination-scoped publisher circuits

Broker tag values in v6: amqp, kafka, sqs, azure_service_bus, inmemory.

Deep Docs

TopicLocation
Transport platform overviewArchitecture.md
Package inventory and dependency rolesDependency-Graph.md
AMQP transport guideAmqp-Transport.md
Kafka transport guideKafka-Transport.md
AWS SQS transport guideAws-Sqs-Transport.md
Azure Service Bus transport guideAzure-Service-Bus-Transport.md
Integration test executorsIntegration-Tests.md

On this page