diff options
author | Trygve Laugstøl <trygvis@inamo.no> | 2012-12-23 00:21:57 +0100 |
---|---|---|
committer | Trygve Laugstøl <trygvis@inamo.no> | 2012-12-23 00:21:57 +0100 |
commit | eaa0a2a0828037227312970668eba7bf951b4049 (patch) | |
tree | eced0d4f6c1b53abe0b2af527ecba3bd493684cd /src/main/java/io/trygvis/esper/testing/jenkins/JenkinsJob.java | |
parent | 78e7933c0af1d11d9476c5ee213c64ad87066f55 (diff) | |
download | esper-testing-eaa0a2a0828037227312970668eba7bf951b4049.tar.gz esper-testing-eaa0a2a0828037227312970668eba7bf951b4049.tar.bz2 esper-testing-eaa0a2a0828037227312970668eba7bf951b4049.tar.xz esper-testing-eaa0a2a0828037227312970668eba7bf951b4049.zip |
o Storing the raw bytes with the parsed data from Jenkins.
Diffstat (limited to 'src/main/java/io/trygvis/esper/testing/jenkins/JenkinsJob.java')
-rw-r--r-- | src/main/java/io/trygvis/esper/testing/jenkins/JenkinsJob.java | 5 |
1 files changed, 3 insertions, 2 deletions
diff --git a/src/main/java/io/trygvis/esper/testing/jenkins/JenkinsJob.java b/src/main/java/io/trygvis/esper/testing/jenkins/JenkinsJob.java index 7199bd8..5ca449e 100644 --- a/src/main/java/io/trygvis/esper/testing/jenkins/JenkinsJob.java +++ b/src/main/java/io/trygvis/esper/testing/jenkins/JenkinsJob.java @@ -1,5 +1,6 @@ package io.trygvis.esper.testing.jenkins; +import fj.*; import fj.data.*; import static fj.data.Option.*; import static io.trygvis.esper.testing.jenkins.JenkinsClient.apiXml; @@ -23,7 +24,7 @@ public class JenkinsJob implements Closeable { this.client = client; this.url = apiXml(url); - long initialDelay = (long) Math.random() + 1; + long initialDelay = (long) (Math.random() + 1); long period = (long) (Math.random() * 100d) + 1; future = executorService.scheduleAtFixedRate(new Runnable() { public void run() { @@ -48,7 +49,7 @@ public class JenkinsJob implements Closeable { try { logger.info("Updating " + name); long start = currentTimeMillis(); - latestStatus = client.fetchJob(url); + latestStatus = client.fetchJob(url).map(P2.<JenkinsJobXml, byte[]>__1()); long end = currentTimeMillis(); logger.info("Updated " + name + " in " + (end - start) + "ms"); } catch (Throwable e) { |