lib/rflow/connections/zmq_connection.rb in rflow-1.0.0 vs lib/rflow/connections/zmq_connection.rb in rflow-1.0.1

- old
+ new

@@ -78,10 +78,9 @@ def send_message(message) RFlow.logger.debug "#{name}: Sending message of type '#{message.data_type_name.to_s}'" begin output_socket.send_msg(message.data_type_name.to_s, message.to_avro) - RFlow.logger.debug "#{name}: Successfully sent message of type '#{message.data_type_name.to_s}'" rescue Exception => e RFlow.logger.debug "Exception #{e.class}: #{e.message}, retrying send" retry end end