use a single topic exchange instead of multiple fanout exchanges.

1 files changed, 3 insertions, 1 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