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