[#60feature/#60-restlib] refactoring

Signed-off-by: huluvu424242 <huluvu424242@gmail.com>
Huluvu424242 · Jan 25, 2023 · 03d2b23 · 03d2b23
1 parent 09f12d3
commit 03d2b23
Showing 1 changed file with 10 additions and 16 deletions.
diff --git a/src/main/java/com/github/funthomas424242/jenkinsmonitor/jenkins/JenkinsHttpClient.java b/src/main/java/com/github/funthomas424242/jenkinsmonitor/jenkins/JenkinsHttpClient.java
@@ -22,7 +22,6 @@
  * #L%
  */
 
-import java.util.ArrayList;
 import java.util.concurrent.ExecutionException;
 import java.util.concurrent.Executors;
 import java.util.concurrent.Future;
@@ -48,31 +47,26 @@ public void ladeJobsStatus(final AbstractJobBeschreibungen<JobStatusBeschreibung
                     final Future<JobStatusBeschreibung> jobAbfrageFuture = executor.submit(jobAbfrage);
                     return new JobAbfrageFutureWrapper(jobAbfrage, jobAbfrageFuture);
                 })
-                // CHECK REFACTORED  optimieren nach https://www.concretepage.com/java/jdk-8/java-8-stream-collect-example#collect
-                //.collect(Collectors.toList())
-                .collect(ArrayList<JobAbfrageFutureWrapper>::new,ArrayList::add,ArrayList::addAll)
-                .forEach(jobAbfrageFutureWrapper -> {
+                .map(jobAbfrageFutureWrapper -> {
                     final Future<JobStatusBeschreibung> future = jobAbfrageFutureWrapper.getJobAbfrageFuture();
+                    JobStatusBeschreibung jobStatusBeschreibung;
                     try {
-                        final JobStatusBeschreibung jobStatus = future.get(3, TimeUnit.SECONDS);
-                        jobStatusBeschreibungen.put(jobStatus.getPrimaryKey(), jobStatus);
-                        LOG.debug("JobStatus geladen: {} : {}  at {} ", jobStatus.getJobName(), jobStatus.getJobStatus(), jobStatus.getJobUrl().toExternalForm());
+                        jobStatusBeschreibung = future.get(5, TimeUnit.SECONDS);
                     } catch (InterruptedException | TimeoutException | ExecutionException ex) {
-
                         LOG.warn("Read Future Result goes wrong with exception: \n {}", ex.toString());
-                        addStatusOTHER(jobStatusBeschreibungen, jobAbfrageFutureWrapper);
+                        jobStatusBeschreibung =getJobStatusOTHER(jobAbfrageFutureWrapper);
                         future.cancel(true);
                     }
-                });
+                    LOG.debug("JobStatus geladen: {} : {}  at {} ", jobStatusBeschreibung.getJobName(), jobStatusBeschreibung.getJobStatus(), jobStatusBeschreibung.getJobUrl().toExternalForm());
+                    return jobStatusBeschreibung;
+                })
+                .forEach(jobStatusBeschreibung -> jobStatusBeschreibungen.put(jobStatusBeschreibung.getPrimaryKey(), jobStatusBeschreibung));
         executor.shutdown();
     }
 
-    private static void addStatusOTHER(final AbstractJobBeschreibungen<JobStatusBeschreibung> jobStatusBeschreibungen, final JobAbfrageFutureWrapper jobAbfrageFutureWrapper) {
+    private static JobStatusBeschreibung getJobStatusOTHER( final JobAbfrageFutureWrapper jobAbfrageFutureWrapper) {
         final JobAbfrage jobAbfrage = jobAbfrageFutureWrapper.getJobAbfrage();
-        final JobStatusBeschreibung jobStatusBeschreibung
-                = new JobStatusBeschreibung("Connection Timeout" + jobAbfrage.getAbfrageUrl().toExternalForm(), JobStatus.OTHER, jobAbfrage.getAbfrageUrl(), jobAbfrage.getJobOrderId());
-        jobStatusBeschreibungen.put(jobAbfrage.getPrimaryKey(), jobStatusBeschreibung);
-
+        return new JobStatusBeschreibung("Connection Timeout" + jobAbfrage.getAbfrageUrl().toExternalForm(), JobStatus.OTHER, jobAbfrage.getAbfrageUrl(), jobAbfrage.getJobOrderId());
     }
 }