use a single topic exchange instead of multiple fanout exchanges.

2 files changed, 11 insertions, 2 deletions

diff --git a/app/controllers/agents/events_controller.rb b/app/controllers/agents/events_controller.rb
index abe9c04..8b1d158 100644
--- a/app/controllers/agents/events_controller.rb
+++ b/app/controllers/agents/events_controller.rb
@@ -11,7 +11,9 @@ module Agents
     end
 
     def create
-      Publisher.publish("events", event_params.merge({agent_id: @agent.id}))
+      message = event_params.merge({agent_id: @agent.id})
+      routing_key = "events.#{event_params[:name]}.#{@agent.id}"
+      Publisher.publish(routing_key, message)
       redirect_to agent_events_url, notice: 'Event was successfully created.'
     end
 
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