Minor fix

pokki-deploy · pokki-deploy · commit 6c5d5016b07b · 2018-04-10T14:35:35.000+01:00
diff --git a/src/main/java/in/erail/service/RESTServiceImpl.java b/src/main/java/in/erail/service/RESTServiceImpl.java
@@ -27,9 +27,9 @@ public void start() {
               .<JsonObject>consumer(getServiceUniqueId())
               .toFlowable()
               .subscribeOn(Schedulers.io())
-              .doOnSubscribe((s) -> getLog().info(String.format("%s[%s] service started", getServiceUniqueId(), Thread.currentThread().getName())))
-              .doOnTerminate(() -> getLog().info(String.format("%s[%s] service stopped", getServiceUniqueId(), Thread.currentThread().getName())))
-              .subscribe(this::process);
+              .doOnSubscribe((s) -> getLog().info(() -> String.format("%s[%s] service started", getServiceUniqueId(), Thread.currentThread().getName())))
+              .doOnTerminate(() -> getLog().info(() -> String.format("%s[%s] service stopped", getServiceUniqueId(), Thread.currentThread().getName())))
+              .subscribe(this::process, err -> getLog().error(() -> String.format("Process exception:[%s],Error:[%s]", getServiceUniqueId(), err)));
     }
   }
 

Original file line number	Diff line number	Diff line change
`@@ -27,9 +27,9 @@ public void start() {`
`27`	`27`	`.<JsonObject>consumer(getServiceUniqueId())`
`28`	`28`	`.toFlowable()`
`29`	`29`	`.subscribeOn(Schedulers.io())`
`30`		`- .doOnSubscribe((s) -> getLog().info(String.format("%s[%s] service started", getServiceUniqueId(), Thread.currentThread().getName())))`
`31`		`- .doOnTerminate(() -> getLog().info(String.format("%s[%s] service stopped", getServiceUniqueId(), Thread.currentThread().getName())))`
`32`		`- .subscribe(this::process);`
	`30`	`+ .doOnSubscribe((s) -> getLog().info(() -> String.format("%s[%s] service started", getServiceUniqueId(), Thread.currentThread().getName())))`
	`31`	`+ .doOnTerminate(() -> getLog().info(() -> String.format("%s[%s] service stopped", getServiceUniqueId(), Thread.currentThread().getName())))`
	`32`	`+ .subscribe(this::process, err -> getLog().error(() -> String.format("Process exception:[%s],Error:[%s]", getServiceUniqueId(), err)));`
`33`	`33`	`}`
`34`	`34`	`}`
`35`	`35`