lib/queue_bus/config.rb in queue-bus-0.8.0 vs lib/queue_bus/config.rb in queue-bus-0.8.1

@@ -25,10 +25,10 @@
 
     LOCAL_MODE_VAR = :queue_bus_local_mode
 
     # Returns the current local mode of QueueBus
     def local_mode
-      if Thread.current.thread_variable?(LOCAL_MODE_VAR)
+      if Thread.current.thread_variable_get(LOCAL_MODE_VAR).is_a?(Wrap)
         Thread.current.thread_variable_get(LOCAL_MODE_VAR).value
       else
         @local_mode
       end
     end