lib/queue-bus.rb in queue-bus-0.6.0 vs lib/queue-bus.rb in queue-bus-0.7.0
- old
+ new
@@ -36,11 +36,11 @@
:default_queue=, :default_queue,
:local_mode=, :local_mode,
:before_publish=, :before_publish_callback,
:logger=, :logger, :log_application, :log_worker,
:hostname=, :hostname,
- :adapter=, :adapter,
+ :adapter=, :adapter, :has_adapter?,
:incoming_queue=, :incoming_queue,
:redis, :worker_middleware_stack
def_delegators :_dispatchers, :dispatch, :dispatchers, :dispatcher_by_key, :dispatcher_execute
@@ -58,7 +58,6 @@
def _dispatchers
@_dispatchers ||= ::QueueBus::Dispatchers.new
end
end
-
end