From 95da03c0b16219e5fa4e47257cbb52e7a0c023a3 Mon Sep 17 00:00:00 2001
From: pankajjangid05 <pankaj.jangid@aurigait.com>
Date: Fri, 2 Jun 2023 20:11:35 +0530
Subject: [PATCH] Upgrade version for prod

---
 pom.xml                                                     | 2 +-
 .../com/uci/outbound/consumers/OutboundKafkaController.java | 6 +++---
 2 files changed, 4 insertions(+), 4 deletions(-)

diff --git a/pom.xml b/pom.xml
index 632177d..9ed06f5 100644
--- a/pom.xml
+++ b/pom.xml
@@ -11,7 +11,7 @@
 	</parent>
 	<groupId>com.uci</groupId>
 	<artifactId>outbound</artifactId>
-	<version>2.2.6</version>
+	<version>2.2.7</version>
 	<name>outbound</name>
 	<description>outbound</description>
 
diff --git a/src/main/java/com/uci/outbound/consumers/OutboundKafkaController.java b/src/main/java/com/uci/outbound/consumers/OutboundKafkaController.java
index 2b8de0d..5a1c94f 100644
--- a/src/main/java/com/uci/outbound/consumers/OutboundKafkaController.java
+++ b/src/main/java/com/uci/outbound/consumers/OutboundKafkaController.java
@@ -81,9 +81,9 @@ public void onMessage() {
             reactiveKafkaReceiver
                     .doOnNext(this::logMessage)
                     .flatMap(this::sendOutboundMessage)
-//                    .onBackpressureBuffer()
-//                    .bufferTimeout(1000, Duration.ofSeconds(5))
-//                    .flatMap(this::persistToCassandra)
+                    .onBackpressureBuffer()
+                    .bufferTimeout(1000, Duration.ofSeconds(10))
+                    .flatMap(this::persistToCassandra)
                     .doOnError(this::handleKafkaFluxError)
                     .subscribe();
         } catch (Exception ex) {