lib/queue_bus/driver.rb in queue-bus-0.5.0 vs lib/queue_bus/driver.rb in queue-bus-0.5.1

@@ -1,9 +1,8 @@
 module QueueBus
   # fans out an event to multiple queues
   class Driver
-    include ::QueueBus::Worker
 
     class << self
       def subscription_matches(attributes)
         out = []
         Application.all.each do |app|
@@ -19,11 +18,17 @@
         ::QueueBus.log_worker("Driver running: #{attributes.inspect}")
 
         subscription_matches(attributes).each do |sub|
           ::QueueBus.log_worker("  ...sending to #{sub.queue_name} queue with class #{sub.class_name} for app #{sub.app_key} because of subscription: #{sub.key}")
 
-          bus_attr = {"bus_driven_at" => Time.now.to_i, "bus_rider_queue" => sub.queue_name, "bus_rider_app_key" => sub.app_key, "bus_rider_sub_key" => sub.key, "bus_rider_class_name" => sub.class_name}
-          ::QueueBus.enqueue_to(sub.queue_name, sub.class_name, bus_attr.merge(attributes || {}))
+          bus_attr = {  "bus_driven_at" => Time.now.to_i,
+                        "bus_rider_queue" => sub.queue_name,
+                        "bus_rider_app_key" => sub.app_key,
+                        "bus_rider_sub_key" => sub.key,
+                        "bus_rider_class_name" => sub.class_name}
+          bus_attr = bus_attr.merge(attributes || {})
+          bus_attr["bus_class_proxy"] = sub.class_name
+          ::QueueBus.enqueue_to(sub.queue_name, ::QueueBus::Worker, bus_attr)
         end
       end
     end
 
   end