Upgrade version for prod

samagra-comms · Jun 2, 2023 · 95da03c · 95da03c
1 parent a657116
commit 95da03c
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 4 deletions.
diff --git 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
@@ -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) {