summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authormo khan <mo@mokhan.ca>2015-02-03 16:53:47 -0700
committermo khan <mo@mokhan.ca>2015-02-03 16:53:50 -0700
commit9cb0e6f157263c90ef7ee50beb7bba25c7377bf7 (patch)
tree08d0646a697d3bb55d78e557200458d1c89d7c52
parentb33fc1ee35bc0ee8d03645efac5ff4f844abc53f (diff)
revert back to rake task to set up the bindings.
-rw-r--r--app/workers/events_worker.rb5
-rw-r--r--config/initializers/sneakers.rb2
2 files changed, 2 insertions, 5 deletions
diff --git a/app/workers/events_worker.rb b/app/workers/events_worker.rb
index 2e44b12..3fcb2c8 100644
--- a/app/workers/events_worker.rb
+++ b/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
diff --git a/config/initializers/sneakers.rb b/config/initializers/sneakers.rb
index b122404..3a441e9 100644
--- a/config/initializers/sneakers.rb
+++ b/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