fstn
10/13/2017, 5:04 AMval result= CompletableFuture<String>()
eventBus.consumer<context.Context>(eventName, this).completionHandler {
if(it.succeeded()){
<http://logger.info|logger.info>("Register ${this::class.simpleName} for event $eventName")
result.complete(this::class.simpleName)
}else{
logger.error("Unable to register ${this::class.simpleName} for event $eventName")
result.completeExceptionally(UnableToRegisterServiceTaskException())
}
}
return result
uli
10/13/2017, 12:08 PM