amqp.reflect

amqp.reflect (incubator)

Listens on amqp port 7172 and will echo back whatever is sent to the server, broadcasting to all receiving clients. Listens on amqps port 7171 and will echo back whatever is sent to the server, broadcasting to all receiving clients.

Requirements

• docker compose
• cli-rhea

Setup

To start the Docker Compose stack defined in the compose.yaml file, use:

docker compose up -d

Install amqp client

Requires AMQP 1.0 client, such as cli-rhea.

npm install cli-rhea -g

Verify behavior

Connect two receiving clients first, then send Hello, world from sending client.

cli-rhea-receiver --address 'zilla' --log-lib 'TRANSPORT_DRV' --log-msgs 'body' --broker localhost:7172

output:

  rhea:events [connection-1] Connection got event: connection_open +0ms
  rhea:events [5c6a67c4-7e0b-fa4e-916c-b8e78ac6ba2e] Container got event: connection_open +0ms
  rhea:events [connection-1] Session got event: session_open +0ms
  rhea:events [connection-1] Connection got event: session_open +0ms
  rhea:events [5c6a67c4-7e0b-fa4e-916c-b8e78ac6ba2e] Container got event: session_open +0ms
  rhea:events [connection-1] Link got event: receiver_open +1ms
  rhea:events [connection-1] Session got event: receiver_open +0ms
  rhea:events [connection-1] Connection got event: receiver_open +0ms
  rhea:events [5c6a67c4-7e0b-fa4e-916c-b8e78ac6ba2e] Container got event: receiver_open +0ms
  rhea:events [connection-1] Link got event: message +52s
  rhea:events [connection-1] Session got event: message +0ms
  rhea:events [connection-1] Connection got event: message +0ms
  rhea:events [5c6a67c4-7e0b-fa4e-916c-b8e78ac6ba2e] Container got event: message +0ms
"Hello, world"
  rhea:events [connection-1] Connection got event: connection_close +7ms
  rhea:events [5c6a67c4-7e0b-fa4e-916c-b8e78ac6ba2e] Container got event: connection_close +0ms

cli-rhea-receiver --address 'zilla' --log-lib 'TRANSPORT_DRV' --log-msgs 'body' --broker localhost:7172

output:

  rhea:events [connection-1] Connection got event: connection_open +0ms
  rhea:events [fc4447a6-ce6d-9943-8847-33dab2317567] Container got event: connection_open +0ms
  rhea:events [connection-1] Session got event: session_open +1ms
  rhea:events [connection-1] Connection got event: session_open +0ms
  rhea:events [fc4447a6-ce6d-9943-8847-33dab2317567] Container got event: session_open +0ms
  rhea:events [connection-1] Link got event: receiver_open +1ms
  rhea:events [connection-1] Session got event: receiver_open +0ms
  rhea:events [connection-1] Connection got event: receiver_open +0ms
  rhea:events [fc4447a6-ce6d-9943-8847-33dab2317567] Container got event: receiver_open +0ms
  rhea:events [connection-1] Link got event: message +30s
  rhea:events [connection-1] Session got event: message +0ms
  rhea:events [connection-1] Connection got event: message +0ms
  rhea:events [fc4447a6-ce6d-9943-8847-33dab2317567] Container got event: message +0ms
"Hello, world"
  rhea:events [connection-1] Connection got event: connection_close +7ms
  rhea:events [fc4447a6-ce6d-9943-8847-33dab2317567] Container got event: connection_close +0ms

cli-rhea-sender --address 'zilla' --msg-content 'Hello, world' --log-lib 'TRANSPORT_DRV' --broker localhost:7172

output:

  rhea:events [connection-1] Connection got event: connection_open +0ms
  rhea:events [efd09fe2-4090-4141-91e6-5ce5223d1dbc] Container got event: connection_open +1ms
  rhea:events [connection-1] Session got event: session_open +0ms
  rhea:events [connection-1] Connection got event: session_open +0ms
  rhea:events [efd09fe2-4090-4141-91e6-5ce5223d1dbc] Container got event: session_open +0ms
  rhea:events [connection-1] Link got event: sender_open +1ms
  rhea:events [connection-1] Session got event: sender_open +0ms
  rhea:events [connection-1] Connection got event: sender_open +0ms
  rhea:events [efd09fe2-4090-4141-91e6-5ce5223d1dbc] Container got event: sender_open +0ms
  rhea:events [connection-1] Link got event: sender_flow +0ms
  rhea:events [connection-1] Session got event: sender_flow +1ms
  rhea:events [connection-1] Connection got event: sender_flow +0ms
  rhea:events [efd09fe2-4090-4141-91e6-5ce5223d1dbc] Container got event: sender_flow +0ms
  rhea:events [connection-1] Link got event: sender_flow +0ms
  rhea:events [connection-1] Session got event: sender_flow +0ms
  rhea:events [connection-1] Connection got event: sender_flow +0ms
  rhea:events [efd09fe2-4090-4141-91e6-5ce5223d1dbc] Container got event: sender_flow +0ms
  rhea:events [connection-1] Link got event: sendable +0ms
  rhea:events [connection-1] Session got event: sendable +0ms
  rhea:events [connection-1] Connection got event: sendable +0ms
  rhea:events [efd09fe2-4090-4141-91e6-5ce5223d1dbc] Container got event: sendable +0ms
  rhea:events [connection-1] Connection got event: disconnected +3ms
  rhea:events [efd09fe2-4090-4141-91e6-5ce5223d1dbc] Container got event: disconnected +0ms
  rhea:events [connection-1] Connection got event: connection_open +105ms
  rhea:events [efd09fe2-4090-4141-91e6-5ce5223d1dbc] Container got event: connection_open +0ms
  rhea:events [connection-1] Session got event: session_open +0ms
  rhea:events [connection-1] Connection got event: session_open +1ms
  rhea:events [efd09fe2-4090-4141-91e6-5ce5223d1dbc] Container got event: session_open +0ms
  rhea:events [connection-1] Link got event: sender_open +0ms
  rhea:events [connection-1] Session got event: sender_open +0ms
  rhea:events [connection-1] Connection got event: sender_open +0ms
  rhea:events [efd09fe2-4090-4141-91e6-5ce5223d1dbc] Container got event: sender_open +0ms
  rhea:events [connection-1] Link got event: sender_flow +0ms
  rhea:events [connection-1] Session got event: sender_flow +0ms
  rhea:events [connection-1] Connection got event: sender_flow +0ms
  rhea:events [efd09fe2-4090-4141-91e6-5ce5223d1dbc] Container got event: sender_flow +0ms
  rhea:events [connection-1] Link got event: sender_flow +1ms
  rhea:events [connection-1] Session got event: sender_flow +0ms
  rhea:events [connection-1] Connection got event: sender_flow +0ms
  rhea:events [efd09fe2-4090-4141-91e6-5ce5223d1dbc] Container got event: sender_flow +0ms
  rhea:events [connection-1] Link got event: sendable +0ms
  rhea:events [connection-1] Session got event: sendable +0ms
  rhea:events [connection-1] Connection got event: sendable +0ms
  rhea:events [efd09fe2-4090-4141-91e6-5ce5223d1dbc] Container got event: sendable +0ms

Teardown

To remove any resources created by the Docker Compose stack, use:

docker compose down