Update BinlogEventListenerTest.java

dinujoh · Nov 12, 2024 · 3f8fa94 · 3f8fa94
1 parent 346f1ef
commit 3f8fa94
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/...st/java/org/opensearch/dataprepper/plugins/source/rds/stream/BinlogEventListenerTest.java b/...st/java/org/opensearch/dataprepper/plugins/source/rds/stream/BinlogEventListenerTest.java
@@ -165,7 +165,7 @@ void test_given_DeleteRows_event_then_calls_correct_handler(EventType eventType)
     }
 
     private BinlogEventListener createObjectUnderTest() {
-        return new BinlogEventListener(buffer, sourceConfig, s3Prefix, pluginMetrics, binaryLogClient,
+        return BinlogEventListener.create(streamPartition, buffer, sourceConfig, s3Prefix, pluginMetrics, binaryLogClient,
                 streamCheckpointer, acknowledgementSetManager, dbTableMetadata, cascadingActionDetector);
     }
 
@@ -176,4 +176,4 @@ private void verifyHandlerCallHelper() {
         Runnable capturedRunnable = runnableArgumentCaptor.getValue();
         capturedRunnable.run();
     }
-}
+}