lib/message_bus/backends/redis.rb in message_bus-3.3.8 vs lib/message_bus/backends/redis.rb in message_bus-3.4.0

@@ -56,9 +56,10 @@
         @max_global_backlog_size = 2000
         @max_in_memory_publish_backlog = 1000
         @in_memory_backlog = []
         @lock = Mutex.new
         @flush_backlog_thread = nil
+        @pub_redis = nil
         # after 7 days inactive backlogs will be removed
         @max_backlog_age = 604800
       end
 
       # Reconnects to Redis; used after a process fork, typically triggered by a forking webserver