aboutsummaryrefslogtreecommitdiff
path: root/src/main/java/io/trygvis/esper/testing/jenkins/JenkinsJob.java
diff options
context:
space:
mode:
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.java5
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) {