From 65145e6be87df7b0440fb98c11abc23a2b3c49ed Mon Sep 17 00:00:00 2001 From: mo khan Date: Sat, 7 Feb 2015 12:33:06 -0700 Subject: use a single topic exchange instead of multiple fanout exchanges. --- app/workers/cloud_queries.rb | 17 ++--------------- 1 file changed, 2 insertions(+), 15 deletions(-) (limited to 'app/workers') diff --git a/app/workers/cloud_queries.rb b/app/workers/cloud_queries.rb index e944142..fbbe5c4 100644 --- a/app/workers/cloud_queries.rb +++ b/app/workers/cloud_queries.rb @@ -11,21 +11,8 @@ class CloudQueries fingerprint = attributes["data"]["fingerprint"] disposition = Disposition.find_by(fingerprint: fingerprint) - publish(JSON.generate({ - name: :scanned, - agent_id: attributes["agent_id"], - data: attributes["data"] - }), to_queue: "worker.events") - - if disposition.nil? - #publish(JSON.generate({ - #command: :request_analysis, - #agent_id: attributes["agent_id"], - #fingerprint: fingerprint, - #}), routing_key: "malwer.commands") - Disposition.create!(fingerprint: fingerprint, state: :unknown) - FingerprintLookupJob.perform_later(fingerprint) - end + Disposition.create!(fingerprint: fingerprint, state: :unknown) if disposition.nil? + FingerprintLookupJob.perform_later(fingerprint) if disposition.state == :unknown ack! end -- cgit v1.2.3