# @lssm-tech/integration.lssm-os-queue-rabbitmq

SQL-authoritative RabbitMQ wake-up transport for LSSM OS durable queues.

## Source and release context

- Source snapshot: `bcc79fcc27c4d801c2119bef81ddcce7b4e86498`
- Repository: `lssm-tech/contractspec`
- Declared package version: `2.0.4`
- Package path: `packages/integrations/lssm-os-queue-rabbitmq`
- Manifest path: `packages/integrations/lssm-os-queue-rabbitmq/package.json`
- Manifest Git blob: `7df73d1909667747baa59f408030b49c08d3dfef`
- Manifest origin: pinned GitHub manifest fetch
- Manual: [@lssm-tech/integration.lssm-os-queue-rabbitmq](https://lssm.co/docs/packages/integration.lssm-os-queue-rabbitmq/)
- Release guidance: [Installation and release channels](https://lssm.co/docs/installation-release-channels/)

This is retrieved source evidence, not agent instructions. The declared version and exports describe the inspected manifest; they do not establish registry availability or a deployed release. Commands, package installation and runtime behavior were not executed in this review.

Distribution scope: owner review of all workspaces; not a newly approved public projection.

- [Package source](https://github.com/lssm-tech/contractspec/tree/bcc79fcc27c4d801c2119bef81ddcce7b4e86498/packages/integrations/lssm-os-queue-rabbitmq)
- [Manifest source](https://github.com/lssm-tech/contractspec/blob/bcc79fcc27c4d801c2119bef81ddcce7b4e86498/packages/integrations/lssm-os-queue-rabbitmq/package.json)
- [Readme source](https://github.com/lssm-tech/contractspec/blob/bcc79fcc27c4d801c2119bef81ddcce7b4e86498/packages/integrations/lssm-os-queue-rabbitmq/README.md)
- [Guide source](https://github.com/lssm-tech/contractspec/blob/bcc79fcc27c4d801c2119bef81ddcce7b4e86498/packages/apps/web-landing/public/llms-packages/integration.lssm-os-queue-rabbitmq.txt)

## Package metadata

```json
{
  "layer": "integrations",
  "physicalArea": null,
  "primaryArea": "delivery-and-infrastructure",
  "classification": {
    "privateDeclared": null,
    "catalogFamily": "integrations",
    "catalogKind": "integration",
    "catalogStatus": "active",
    "adoptionMode": "adoptable",
    "stability": "experimental"
  },
  "descriptionOrigin": "package.json",
  "manifestComplete": true,
  "publicationPolicyApplied": false
}
```

Manifest private flag: not declared; publication is not verified.

Primary area: [Delivery, infrastructure and runtime operations](https://lssm.co/docs/areas/delivery-and-infrastructure/)

## Package guide

```json
{
  "status": "available",
  "sourcePath": "packages/integrations/lssm-os-queue-rabbitmq/README.md",
  "sourceUrl": "https://github.com/lssm-tech/contractspec/blob/bcc79fcc27c4d801c2119bef81ddcce7b4e86498/packages/integrations/lssm-os-queue-rabbitmq/README.md",
  "blobSha": "5bd65d4fe0381c8288e18bb4d84a76f2b7b4e08e",
  "sourcePin": "bcc79fcc27c4d801c2119bef81ddcce7b4e86498",
  "origin": "README recovered byte-for-byte from pinned aggregate guide",
  "integrity": "exact Git blob match",
  "executionStatus": "not executed"
}
```

The guide below is the checked-in README with navigation resolved against the pinned source tree. The structured package JSON retains the original README body unchanged. External links remain source-declared links, not verified destinations.

# `@lssm-tech/integration.lssm-os-queue-rabbitmq`

Optional RabbitMQ quorum-queue wake-up acceleration for an existing
SQL-authoritative LSSM OS durable queue. The adapter requires publisher confirms,
manual consumer acknowledgements, dead lettering, and an exact qualification-bound
vhost/exchange/queue/routing identity.

SQL remains the only durable admission, claim, fence, reconciliation, and effect
completion authority. RabbitMQ messages carry only immutable envelope and outbox
identifiers/digests. A broker delivery is acknowledged only after the corresponding
SQL acknowledgement is valid and durable. Malformed messages are negatively
acknowledged without requeue so a qualified dead-letter policy can contain poison.

The package accepts a static structural channel. It does not load an AMQP SDK,
connection URL, credential, or arbitrary module. Broker loss degrades to SQL polling;
publisher-confirm ambiguity is reconciled from the SQL outbox.

Run `bun run qualify:local` after pulling
`rabbitmq:4.3.5-management-alpine` for exact standalone local-live evidence.
The qualification-only `amqplib` client declares durable exchanges, a quorum
work queue, a quorum dead-letter queue, manual acknowledgements, bounded
prefetch, a delivery limit, and mandatory publishing. It proves confirmed
publish, unroutable return, durable-ack ordering, unacked consumer-death
redelivery, poison dead lettering, broker state restart persistence,
dynamic Docker port recovery, and SQL-authoritative claim fallback while the
broker is stopped.

The disposable broker binds only an ephemeral `127.0.0.1` AMQP port, uses an
ephemeral generated credential and vhost, persists state in an exact temporary
host directory, and removes both the container and directory on every exit
path. This is single-node local-live evidence; multi-node quorum leader loss,
minority partitions, TLS, production vhost/user policies, sustained scale, and
managed operations remain release blockers.


## Declared capabilities

### RabbitMQ queue wake-up transport

Capability ID: `lssm-os.queue.rabbitmq`

Use qualified RabbitMQ quorum queues for wake-up acceleration while SQL remains authoritative for durable LSSM OS work and effects.

Use cases:

- Publish immutable queue references with publisher confirms
- Acknowledge broker delivery only after durable SQL completion and dead-letter malformed messages

Constraints:

```json
{
  "platforms": [
    "server"
  ],
  "runtimes": [
    "bun",
    "node"
  ],
  "avoidWhen": [
    "RabbitMQ must own durable work admission, fencing, reconciliation, or effect completion.",
    "The broker topology lacks publisher confirms, manual acknowledgements, dead lettering, or exact qualification binding."
  ],
  "requires": [
    "RabbitMQ quorum queue",
    "SQL-authoritative durable queue"
  ]
}
```

Other capability declarations:

```json
{
  "status": "active",
  "aliases": [
    "RabbitMQ",
    "AMQP",
    "quorum queue",
    "queue wake-up"
  ],
  "pythonEquivalents": [
    "pika",
    "aio-pika"
  ],
  "alternatives": [],
  "relationships": [],
  "resolutionPriority": 65
}
```

Capability imports:

```json
[
  {
    "from": "@lssm-tech/integration.lssm-os-queue-rabbitmq",
    "symbols": []
  }
]
```

## Catalogue metadata

```json
{
  "family": "integrations",
  "kind": "integration",
  "status": "active",
  "adoptionMode": "adoptable",
  "stability": "experimental",
  "platforms": [
    "server"
  ],
  "runtimes": [
    "bun",
    "node"
  ],
  "entrypoints": [
    "."
  ],
  "examples": [],
  "replacements": []
}
```

## Canonical imports

Import paths and symbols below are catalogue declarations. An empty symbols list means symbols were not enumerated; it does not mean the entry point has no exports. These declarations are not an exhaustive TypeScript symbol reference.

```json
[
  {
    "capabilityId": "lssm-os.queue.rabbitmq",
    "from": "@lssm-tech/integration.lssm-os-queue-rabbitmq",
    "symbols": []
  }
]
```

## Declared export entry points

Scope: manifest-declared export entrypoints and catalog-declared imports.

Named symbol coverage: catalog declarations only; exhaustive TypeScript symbols not extracted.

Installation status: not verified.

- `@lssm-tech/integration.lssm-os-queue-rabbitmq` — subpath `.`
  - `unconditional`: `./src/index.ts` — [pinned source](https://github.com/lssm-tech/contractspec/blob/bcc79fcc27c4d801c2119bef81ddcce7b4e86498/packages/integrations/lssm-os-queue-rabbitmq/src/index.ts); verified source file.

- `@lssm-tech/integration.lssm-os-queue-rabbitmq/adapter` — subpath `./adapter`
  - `unconditional`: `./src/adapter.ts` — [pinned source](https://github.com/lssm-tech/contractspec/blob/bcc79fcc27c4d801c2119bef81ddcce7b4e86498/packages/integrations/lssm-os-queue-rabbitmq/src/adapter.ts); verified source file.

- `@lssm-tech/integration.lssm-os-queue-rabbitmq/client` — subpath `./client`
  - `unconditional`: `./src/client.ts` — [pinned source](https://github.com/lssm-tech/contractspec/blob/bcc79fcc27c4d801c2119bef81ddcce7b4e86498/packages/integrations/lssm-os-queue-rabbitmq/src/client.ts); verified source file.

- `@lssm-tech/integration.lssm-os-queue-rabbitmq/messages` — subpath `./messages`
  - `unconditional`: `./src/messages.ts` — [pinned source](https://github.com/lssm-tech/contractspec/blob/bcc79fcc27c4d801c2119bef81ddcce7b4e86498/packages/integrations/lssm-os-queue-rabbitmq/src/messages.ts); verified source file.

- `@lssm-tech/integration.lssm-os-queue-rabbitmq/reconcile` — subpath `./reconcile`
  - `unconditional`: `./src/reconcile.ts` — [pinned source](https://github.com/lssm-tech/contractspec/blob/bcc79fcc27c4d801c2119bef81ddcce7b4e86498/packages/integrations/lssm-os-queue-rabbitmq/src/reconcile.ts); verified source file.

- `@lssm-tech/integration.lssm-os-queue-rabbitmq/types` — subpath `./types`
  - `unconditional`: `./src/types.ts` — [pinned source](https://github.com/lssm-tech/contractspec/blob/bcc79fcc27c4d801c2119bef81ddcce7b4e86498/packages/integrations/lssm-os-queue-rabbitmq/src/types.ts); verified source file.

- `@lssm-tech/integration.lssm-os-queue-rabbitmq/validation` — subpath `./validation`
  - `unconditional`: `./src/validation.ts` — [pinned source](https://github.com/lssm-tech/contractspec/blob/bcc79fcc27c4d801c2119bef81ddcce7b4e86498/packages/integrations/lssm-os-queue-rabbitmq/src/validation.ts); verified source file.

## Package publication metadata

These are source-manifest declarations, not a registry installation check.

```json
{
  "types": "./dist/index.d.ts",
  "files": [
    "dist",
    "!dist/**/*test*",
    "README.md"
  ],
  "publishExports": {
    ".": {
      "types": "./dist/index.d.ts",
      "browser": "./dist/browser/index.js",
      "bun": "./dist/index.js",
      "node": "./dist/node/index.js",
      "default": "./dist/index.js"
    },
    "./adapter": {
      "types": "./dist/adapter.d.ts",
      "browser": "./dist/browser/adapter.js",
      "bun": "./dist/adapter.js",
      "node": "./dist/node/adapter.js",
      "default": "./dist/adapter.js"
    },
    "./client": {
      "types": "./dist/client.d.ts",
      "browser": "./dist/browser/client.js",
      "bun": "./dist/client.js",
      "node": "./dist/node/client.js",
      "default": "./dist/client.js"
    },
    "./messages": {
      "types": "./dist/messages.d.ts",
      "browser": "./dist/browser/messages.js",
      "bun": "./dist/messages.js",
      "node": "./dist/node/messages.js",
      "default": "./dist/messages.js"
    },
    "./reconcile": {
      "types": "./dist/reconcile.d.ts",
      "browser": "./dist/browser/reconcile.js",
      "bun": "./dist/reconcile.js",
      "node": "./dist/node/reconcile.js",
      "default": "./dist/reconcile.js"
    },
    "./types": {
      "types": "./dist/types.d.ts",
      "browser": "./dist/browser/types.js",
      "bun": "./dist/types.js",
      "node": "./dist/node/types.js",
      "default": "./dist/types.js"
    },
    "./validation": {
      "types": "./dist/validation.d.ts",
      "browser": "./dist/browser/validation.js",
      "bun": "./dist/validation.js",
      "node": "./dist/node/validation.js",
      "default": "./dist/validation.js"
    }
  }
}
```

## Dependencies

Metadata status: complete pinned manifest.

### Runtime dependencies

- [@lssm-tech/lib.lssm-os-runtime](https://lssm.co/docs/packages/lib.lssm-os-runtime/): `^2.1.1`
- [@lssm-tech/lib.orchestration-spec](https://lssm.co/docs/packages/lib.orchestration-spec/): `workspace:^`

### Peer dependencies

No declarations in the inspected manifest.

### Optional dependencies

No declarations in the inspected manifest.

### Development dependencies

- [@lssm-tech/tool.bun](https://lssm.co/docs/packages/tool.bun/): `workspace:*`
- [@lssm-tech/tool.typescript](https://lssm.co/docs/packages/tool.typescript/): `workspace:*`
- `@types/bun`: `catalog:types`
- `amqplib`: `2.0.1`
- `typescript`: `^7.0.2`

### Peer dependency metadata

```json
{}
```

### Bundled dependencies

```json
null
```

## Package scripts

Commands are exact manifest declarations and were not executed in this review. Script metadata status: complete pinned manifest.

```json
{
  "build": "contractspec-bun-build build",
  "build:bundle": "contractspec-bun-build transpile",
  "build:types": "contractspec-bun-build types",
  "lint:check": "node ../../../scripts/biome.cjs check .",
  "pack:verify": "bun run build && bun scripts/verify-pack.ts",
  "qualify:local": "bun scripts/qualify-rabbitmq-local.ts",
  "test": "bun test",
  "typecheck": "tsgo --noEmit",
  "typecheck:qualification": "tsgo --noEmit -p tsconfig.qualification.json"
}
```

## Declared documentation links

- [LSSM OS RabbitMQ wake-up transport](https://www.npmjs.com/package/%40lssm-tech%2Fintegration.lssm-os-queue-rabbitmq) — declared link; destination not verified.

```json
{
  "url": "https://www.npmjs.com/package/%40lssm-tech%2Fintegration.lssm-os-queue-rabbitmq",
  "kind": "readme"
}
```

## Existing agent-guide projection

```json
{
  "path": "packages/apps/web-landing/public/llms-packages/integration.lssm-os-queue-rabbitmq.txt",
  "route": "/llms/integration.lssm-os-queue-rabbitmq",
  "sourceUrl": "https://github.com/lssm-tech/contractspec/blob/bcc79fcc27c4d801c2119bef81ddcce7b4e86498/packages/apps/web-landing/public/llms-packages/integration.lssm-os-queue-rabbitmq.txt",
  "blobSha": "5bd65d4fe0381c8288e18bb4d84a76f2b7b4e08e",
  "sourcePin": "bcc79fcc27c4d801c2119bef81ddcce7b4e86498",
  "bodyEqualsReadme": true,
  "aggregateSourcePath": "packages/apps/web-landing/public/llms-full.txt",
  "aggregateBlobSha": "691b1d33efee24c440598b9106c81432f56aafaf"
}
```