class Protobuf::Rpc::Connectors::Zmq

def zmq_recoverable_error_check(return_code, source)
  return if ::ZMQ::Util.resultcode_ok?(return_code || -1)
  fail ZmqRecoverableError, <<-ERROR
  Last ZMQ API call to #{source} failed with "#{::ZMQ::Util.error_string}".
  #{caller(1).join($INPUT_RECORD_SEPARATOR)}
  ERROR
end