Contents

$: << File.expand_path('../lib', File.dirname(__FILE__))
require 'sneakers'
require 'sneakers/runner'

class MiddlewareWorker
  include Sneakers::Worker

  from_queue 'middleware-demo',
    ack: false

  def work(message)
    puts "******** MiddlewareWorker -> #{message}"
  end
end

class DemoMiddleware
  def initialize(app, *args)
    @app = app
    @args = args
  end

  def call(deserialized_msg, delivery_info, metadata, handler)
    puts "******** DemoMiddleware - before; args #{@args}"
    res = @app.call(deserialized_msg, delivery_info, metadata, handler)
    puts "******** DemoMiddleware - after"
    
    res
  end
end

Sneakers.configure
Sneakers.middleware.use(DemoMiddleware, foo: :bar)

Sneakers.publish("{}", :to_queue => 'middleware-demo')
r = Sneakers::Runner.new([MiddlewareWorker])
r.run

Version data entries

4 entries across 4 versions & 1 rubygems

Version	Path
kicks-3.1.1	examples/middleware_worker.rb
kicks-3.1.0	examples/middleware_worker.rb
kicks-3.0.0	examples/middleware_worker.rb
kicks-3.0.0.pre	examples/middleware_worker.rb