Contents

module Vx
  module Worker

    LogJob = Struct.new(:app) do

      include Helper::Logger

      def call(env)
        logger.tagged("job #{env.job.message.id}.#{env.job.message.job_id}") do
          logger.info "starting job"
          rs = app.call env
          logger.info "done job"
          rs
        end
      end

    end
  end
end

Version data entries

13 entries across 13 versions & 1 rubygems

Version	Path
vx-worker-0.3.0.pre0	lib/vx/worker/middlewares/log_job.rb
vx-worker-0.2.1	lib/vx/worker/middlewares/log_job.rb
vx-worker-0.2.0.pre38	lib/vx/worker/middlewares/log_job.rb
vx-worker-0.2.0.pre37	lib/vx/worker/middlewares/log_job.rb
vx-worker-0.2.0.pre36	lib/vx/worker/middlewares/log_job.rb
vx-worker-0.2.0.pre35	lib/vx/worker/middlewares/log_job.rb
vx-worker-0.2.0.pre34	lib/vx/worker/middlewares/log_job.rb
vx-worker-0.2.0.pre33	lib/vx/worker/middlewares/log_job.rb
vx-worker-0.2.0.pre32	lib/vx/worker/middlewares/log_job.rb
vx-worker-0.2.0.pre31	lib/vx/worker/middlewares/log_job.rb
vx-worker-0.2.0.pre30	lib/vx/worker/middlewares/log_job.rb
vx-worker-0.2.0.pre29	lib/vx/worker/middlewares/log_job.rb
vx-worker-0.2.0.pre28	lib/vx/worker/middlewares/log_job.rb