diff --git a/echo-pipelinetriggers/src/main/java/com/netflix/spinnaker/echo/pipelinetriggers/BuildEventMonitor.java b/echo-pipelinetriggers/src/main/java/com/netflix/spinnaker/echo/pipelinetriggers/BuildEventMonitor.java index 5b76cffee..e75309cad 100644 --- a/echo-pipelinetriggers/src/main/java/com/netflix/spinnaker/echo/pipelinetriggers/BuildEventMonitor.java +++ b/echo-pipelinetriggers/src/main/java/com/netflix/spinnaker/echo/pipelinetriggers/BuildEventMonitor.java @@ -52,8 +52,8 @@ public void processEvent(Event event) { return; } - val buildEvent = objectMapper.convertValue(event, BuildEvent.class); - Observable.from(Collections.singletonList(buildEvent)) + BuildEvent buildEvent = objectMapper.convertValue(event, BuildEvent.class); + Observable.just(buildEvent) .doOnNext(this::onEchoResponse) .subscribe(triggerEachMatchFrom(pipelineCache.getPipelines())); }