Commit 9cb0e6f
Changed files (2)
app
workers
config
initializers
app/workers/events_worker.rb
@@ -3,12 +3,9 @@ require 'json'
class EventsWorker
include Sneakers::Worker
from_queue "worker.events",
- durable: true,
- ack: true,
threads: 50,
prefetch: 50,
- timeout_job_after: 1,
- exchange: "malwer.events"
+ timeout_job_after: 1
def work(event_json)
logger.info event_json
config/initializers/sneakers.rb
@@ -1,6 +1,6 @@
require 'sneakers/metrics/logging_metrics'
Sneakers.configure({
- metrics: Sneakers::Metrics::LoggingMetrics.new,
+ metrics: Sneakers::Metrics::LoggingMetrics.new
})
Sneakers.logger.level = Logger::INFO