Tryo

2026-02-06 17:37:00 +00:00 · 2017-04-21 20:51:45 +00:00 · 2017-04-21 20:51:45 +00:00 · ef9066079a
commit ef9066079a
parent 5f77cbc612
1 changed files with 1 additions and 1 deletions
--- a/src/main/scala/code/bankconnectors/KafkaHelper.scala
+++ b/src/main/scala/code/bankconnectors/KafkaHelper.scala
@ -51,7 +51,7 @@ class KafkaHelper extends MdcLoggable {
  def getResponse(reqId: String): json.JValue = {
    println("RECEIVING...")
    val response = for {
-      consumerMap <- consumer.poll(100)
+      consumerMap <- tryo{consumer.poll(100)}
      record: ConsumerRecord[String, String]  <- consumerMap
      if record.key == reqId
    } yield