lib/kafkr/message_broker.rb in kafkr-0.018.1 vs lib/kafkr/message_broker.rb in kafkr-0.21.0

@@ -14,10 +14,10 @@
 
     def broadcast(message)
       encrypted_message = Kafkr::Encryptor.new.encrypt(message) 
       @subscribers.each do |subscriber|
         if !subscriber.closed?
-          subscriber.Kafkr.log(encrypted_message)
+          subscriber.puts(encrypted_message)
           @last_sent[subscriber] = encrypted_message
         end
       rescue Errno::EPIPE
         # Optionally, handle broken pipe error
       rescue IOError