lib/rrj/janus/processus/event.rb in ruby_rabbitmq_janus-2.5.1 vs lib/rrj/janus/processus/event.rb in ruby_rabbitmq_janus-2.6.0.pre.226

@@ -42,10 +42,10 @@
         end
 
         private
 
         def transaction_running
-          publisher = Rabbit::Publisher::Listener.new(rabbit)
+          publisher = Rabbit::Listener::From.new(rabbit)
           @thread.thread_variable_set(NAME_VAR, publisher)
         end
       end
     end
   end