lib/queue_bus/publisher.rb in queue-bus-0.5.2 vs lib/queue_bus/publisher.rb in queue-bus-0.5.3

@@ -1,19 +1,11 @@
 module QueueBus
   # publishes on a delay
   class Publisher
 
     class << self
-      def perform(*args)
-        # TODO: move this to just resquebus for fallback
-        if args.size > 1
-          # handles older arguments
-          event_type = args.first
-          attributes = args.last
-        else
-          attributes = args.first
-          event_type = attributes["bus_event_type"]
-        end
+      def perform(attributes)
+        event_type = attributes["bus_event_type"]
         ::QueueBus.log_worker("Publisher running: #{event_type} - #{attributes.inspect}")
         ::QueueBus.publish(event_type, attributes)
       end
     end
 
\ No newline at end of file