lib/resque-bus.rb in resque-bus-0.6.1 vs lib/resque-bus.rb in resque-bus-0.7.0

@@ -14,6 +14,11 @@
   autoload :Heartbeat,   'resque_bus/compatibility/heartbeat'
 
   extend ::ResqueBus::Deprecated
 end
 
-QueueBus.adapter = QueueBus::Adapters::Resque.new
+if QueueBus.has_adapter?
+  warn '[ResqueBus] Not setting adapter on queue-bus because ' \
+      "#{QueueBus.adapter.class.name} is already the adapter"
+else
+  QueueBus.adapter = QueueBus::Adapters::Resque.new
+end