Graceful Shutdown¶

TypedBus provides several levels of cleanup for stopping channels and buses.

Close a Channel¶

Stops accepting new publishes and subscribes. Pending deliveries are force-NACKed and routed to the DLQ.

channel.close
channel.closed?  # => true

After closing:

publish raises RuntimeError
subscribe raises RuntimeError
The DLQ retains its entries for inspection

Close All Channels¶

bus.close_all

Closes every channel on the bus. Each channel's pending deliveries are force-NACKed.

Clear a Channel¶

Hard reset: cancels all timeout tasks, discards pending deliveries, and clears the DLQ.

channel.clear!

Unlike close, clear! does not mark the channel as closed — you can continue using it.

Clear a Bus¶

Clears all channels and resets stats:

bus.clear!

Remove a Channel¶

Close and remove a channel from the bus registry:

bus.remove_channel(:orders)
bus.channel?(:orders)  # => false

Removing a nonexistent channel is a no-op.

Shutdown Order¶

For a clean shutdown:

Stop publishing new messages
Wait for pending deliveries to resolve (or let timeouts fire)
Process any DLQ entries
Call bus.close_all

Async do
  # ... normal operations ...

  # Shutdown
  sleep(timeout_duration)  # let pending deliveries settle
  bus.dead_letters(:orders).drain { |d| reprocess(d.message) }
  bus.close_all
end