#166 ETH Supply Service

-- Fix config variable type
cybercongress · Jun 8, 2018 · 3d38fab · 3d38fab
1 parent 5c25c1e
commit 3d38fab
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 2 deletions.
diff --git a/...on/src/main/kotlin/fund/cyber/contract/common/delta/apply/UpdateContractSummaryProcess.kt b/...on/src/main/kotlin/fund/cyber/contract/common/delta/apply/UpdateContractSummaryProcess.kt
@@ -252,5 +252,7 @@ class UpdateContractSummaryProcess<R, S : CqlContractSummary, D : ContractSummar
         }
     }
 
-    private fun <T> Flux<T>.await() = this.collectList().block()!!
 }
+
+private fun <T> Flux<T>.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
@@ -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
 ) {
-Original file line number
+Diff line change
@@ Expand Up @@
             }
         }
-        private fun <T> Flux<T>.await() = this.collectList().block()!!
     }
+    private fun <T> Flux<T>.await() = this.collectList().block()!!