Update logsoracle, add new info logs for oracle (#388)
This commit is contained in:
@@ -24,12 +24,15 @@ class LogsOracle(
|
|||||||
subscription = upstream.getHead().getFlux()
|
subscription = upstream.getHead().getFlux()
|
||||||
.publishOn(scheduler)
|
.publishOn(scheduler)
|
||||||
.doOnError { t -> log.error("Failed to subscribe head for oracle", t) }
|
.doOnError { t -> log.error("Failed to subscribe head for oracle", t) }
|
||||||
|
.doFinally { log.info("unsubscribe head") }
|
||||||
.subscribe { setHeight(it.height) }
|
.subscribe { setHeight(it.height) }
|
||||||
|
|
||||||
setUpstream(config.rpc)
|
setUpstream(config.rpc)
|
||||||
}
|
}
|
||||||
|
|
||||||
fun stop() {
|
fun stop() {
|
||||||
|
log.info("liboracle closed")
|
||||||
|
|
||||||
subscription?.dispose()
|
subscription?.dispose()
|
||||||
subscription = null
|
subscription = null
|
||||||
|
|
||||||
|
|||||||
Binary file not shown.
Reference in New Issue
Block a user