update libs (#290)
This commit is contained in:
@@ -16,6 +16,7 @@
|
||||
*/
|
||||
package io.emeraldpay.dshackle
|
||||
|
||||
import io.netty.handler.ssl.OpenSsl
|
||||
import org.slf4j.LoggerFactory
|
||||
import org.springframework.boot.ResourceBanner
|
||||
import org.springframework.boot.SpringApplication
|
||||
@@ -30,6 +31,8 @@ open class Starter
|
||||
private val log = LoggerFactory.getLogger(Starter::class.java)
|
||||
|
||||
fun main(args: Array<String>) {
|
||||
OpenSsl.ensureAvailability()
|
||||
|
||||
Schedulers.enableMetrics()
|
||||
|
||||
val maxMemory: Long = Runtime.getRuntime().maxMemory() / (1024 * 1024).toLong()
|
||||
|
||||
@@ -89,10 +89,12 @@ open class EthereumLikeRpcUpstream(
|
||||
validatorSubscription = validator.start()
|
||||
.subscribe(this::setStatus)
|
||||
}
|
||||
livenessSubscription = connector.hasLiveSubscriptionHead().subscribe {
|
||||
livenessSubscription = connector.hasLiveSubscriptionHead().subscribe({
|
||||
hasLiveSubscriptionHead.set(it)
|
||||
eventPublisher?.publishEvent(UpstreamChangeEvent(chain, this, UpstreamChangeEvent.ChangeType.UPDATED))
|
||||
}
|
||||
}, {
|
||||
log.debug("Error while checking live subscription for ${getId()}", it)
|
||||
})
|
||||
labelsDetector.detectLabels()
|
||||
.toStream()
|
||||
.forEach {
|
||||
|
||||
Reference in New Issue
Block a user