summaryrefslogtreecommitdiff
path: root/app/controllers/agents/files_controller.rb
diff options
context:
space:
mode:
authormo khan <mo@mokhan.ca>2015-02-07 12:33:06 -0700
committermo khan <mo@mokhan.ca>2015-02-07 12:33:06 -0700
commit65145e6be87df7b0440fb98c11abc23a2b3c49ed (patch)
tree026e5260bf03be83d38d454028023316a555a1ea /app/controllers/agents/files_controller.rb
parent2bbe4091b513ab40b0540a1315c8946ade21b476 (diff)
use a single topic exchange instead of multiple fanout exchanges.
Diffstat (limited to 'app/controllers/agents/files_controller.rb')
-rw-r--r--app/controllers/agents/files_controller.rb9
1 files changed, 8 insertions, 1 deletions
diff --git a/app/controllers/agents/files_controller.rb b/app/controllers/agents/files_controller.rb
index 76051cf..3c2e47b 100644
--- a/app/controllers/agents/files_controller.rb
+++ b/app/controllers/agents/files_controller.rb
@@ -16,12 +16,19 @@ module Agents
name: params[:name],
data: params[:data]
})
+
+ message = {
+ agent_id: params[:id],
+ name: params[:name],
+ data: params[:data]
+ }
+ Publisher.publish("events.scanned.#{@agent.id}", message)
end
private
def load_agent
- Agent.find(params[:agent_id])
+ @agent = Agent.find(params[:agent_id])
end
end
end