From 3d38fab83cb3003428ba77a39b0eb5d095233e6b Mon Sep 17 00:00:00 2001 From: Hleb Albau Date: Fri, 1 Jun 2018 15:08:51 +0300 Subject: [PATCH] #166 ETH Supply Service -- Fix config variable type --- .../common/delta/apply/UpdateContractSummaryProcess.kt | 4 +++- .../fund/cyber/dump/ethereum/ApplcationConfiguration.kt | 2 +- 2 files changed, 4 insertions(+), 2 deletions(-) diff --git a/contract-summary/common/src/main/kotlin/fund/cyber/contract/common/delta/apply/UpdateContractSummaryProcess.kt b/contract-summary/common/src/main/kotlin/fund/cyber/contract/common/delta/apply/UpdateContractSummaryProcess.kt index ea307cd5..1a09f9e3 100644 --- a/contract-summary/common/src/main/kotlin/fund/cyber/contract/common/delta/apply/UpdateContractSummaryProcess.kt +++ b/contract-summary/common/src/main/kotlin/fund/cyber/contract/common/delta/apply/UpdateContractSummaryProcess.kt @@ -252,5 +252,7 @@ class UpdateContractSummaryProcess Flux.await() = this.collectList().block()!! } + +private fun Flux.await() = this.collectList().block()!! + diff --git a/dumps/ethereum/src/main/kotlin/fund/cyber/dump/ethereum/ApplcationConfiguration.kt b/dumps/ethereum/src/main/kotlin/fund/cyber/dump/ethereum/ApplcationConfiguration.kt index f2e475b9..8a811cb0 100644 --- a/dumps/ethereum/src/main/kotlin/fund/cyber/dump/ethereum/ApplcationConfiguration.kt +++ b/dumps/ethereum/src/main/kotlin/fund/cyber/dump/ethereum/ApplcationConfiguration.kt @@ -42,7 +42,7 @@ private const val AUTO_COMMIT_INTERVAL_MS_CONFIG = 10 * 1000 class ApplicationConfiguration( private val chain: EthereumFamilyChain, @Value("\${$KAFKA_LISTENER_MAX_POLL_RECORDS:$KAFKA_LISTENER_MAX_POLL_RECORDS_DEFAULT}") - private val maxPollRecords: Int, + private val maxPollRecords: Long, @Value("\${$REALTIME_INDEXATION_TRESHOLD:$REALTIME_INDEXATION_TRESHOLD_DEFAULT}") private val realtimeIndexationThreshold: Long ) {