String body = gson.toJson(status);
return this.restClient.post(job.getJobStatusUrl(), body) //
.doOnNext(response -> logger.debug("Consumer notified OK {}", job.getId())) //
String body = gson.toJson(status);
return this.restClient.post(job.getJobStatusUrl(), body) //
.doOnNext(response -> logger.debug("Consumer notified OK {}", job.getId())) //