Module: BugBunny::ConsumerMiddleware

Defined in:

lib/bug_bunny/consumer_middleware.rb

Overview

Infraestructura de middleware para el Consumer AMQP.

Permite inyectar lógica transversal (tracing, autenticación, logging) en el pipeline de procesamiento de mensajes, antes de que la gema procese el mensaje.

Cada middleware recibe ‘(delivery_info, properties, body)` y debe llamar a `@app.call(delivery_info, properties, body)` para continuar la cadena.

Examples:

Registrar un middleware desde una gema externa (auto-registro al hacer require)

BugBunny.consumer_middlewares.use MyTracing::ConsumerMiddleware

Implementar un middleware propio

class MyMiddleware < BugBunny::ConsumerMiddleware::Base
  def call(delivery_info, properties, body)
    # lógica pre-procesamiento (ej: hidratar contexto de tracing)
    @app.call(delivery_info, properties, body)
    # lógica post-procesamiento
  end
end

Defined Under Namespace

Classes: Base, Stack