From b916f2e1d891bc67c219c021a9a258a7b143d1bb Mon Sep 17 00:00:00 2001
From: "bartlomiej.zylinski" <bartlomiej.zylinski@softwaremill.pl>
Date: Mon, 10 Jun 2024 05:13:35 +0200
Subject: [PATCH] Fix tests setup

---
 .../java/otter/jet/plaintext/PlainTextMessageReaderTest.java   | 2 +-
 src/test/java/otter/jet/proto/AnyProtoMessageReaderTest.java   | 3 ++-
 .../java/otter/jet/proto/SimpleProtoMessageReaderTest.java     | 3 ++-
 src/test/resources/application-local.yml                       | 1 +
 4 files changed, 6 insertions(+), 3 deletions(-)

diff --git a/src/test/java/otter/jet/plaintext/PlainTextMessageReaderTest.java b/src/test/java/otter/jet/plaintext/PlainTextMessageReaderTest.java
index 4809f12..5d795d0 100644
--- a/src/test/java/otter/jet/plaintext/PlainTextMessageReaderTest.java
+++ b/src/test/java/otter/jet/plaintext/PlainTextMessageReaderTest.java
@@ -21,7 +21,7 @@
 import otter.jet.store.Filters;
 import otter.jet.store.MessageStore;
 
-@TestPropertySource(properties = {"read.mode=plaintext", "read.subject=plaintext"})
+@TestPropertySource(properties = {"read.mode=plaintext", "read.subject=plaintext", "read.beginTimestamp="})
 class PlainTextMessageReaderTest extends AbstractIntegrationTest {
 
   private static final LocalDateTime ignoredMessageTimestamp =
diff --git a/src/test/java/otter/jet/proto/AnyProtoMessageReaderTest.java b/src/test/java/otter/jet/proto/AnyProtoMessageReaderTest.java
index e42e751..5f3ee49 100644
--- a/src/test/java/otter/jet/proto/AnyProtoMessageReaderTest.java
+++ b/src/test/java/otter/jet/proto/AnyProtoMessageReaderTest.java
@@ -28,7 +28,8 @@
     properties = {
       "read.mode=proto",
       "read.subject=any_person",
-      "read.proto.pathToDescriptor=src/test/resources/person.desc"
+      "read.proto.pathToDescriptor=src/test/resources/person.desc",
+      "read.beginTimestamp="
     })
 class AnyProtoMessageReaderTest extends AbstractIntegrationTest {
 
diff --git a/src/test/java/otter/jet/proto/SimpleProtoMessageReaderTest.java b/src/test/java/otter/jet/proto/SimpleProtoMessageReaderTest.java
index ec6d3a3..0927859 100644
--- a/src/test/java/otter/jet/proto/SimpleProtoMessageReaderTest.java
+++ b/src/test/java/otter/jet/proto/SimpleProtoMessageReaderTest.java
@@ -28,7 +28,8 @@
       "read.mode=proto",
       "read.subject=typed_person",
       "read.proto.messageTypeName=protobuf.Person",
-      "read.proto.pathToDescriptor=src/test/resources/person.desc"
+      "read.proto.pathToDescriptor=src/test/resources/person.desc",
+      "read.beginTimestamp="
     })
 class SimpleProtoMessageReaderTest extends AbstractIntegrationTest {
 
diff --git a/src/test/resources/application-local.yml b/src/test/resources/application-local.yml
index 3c3b48b..adf5b63 100644
--- a/src/test/resources/application-local.yml
+++ b/src/test/resources/application-local.yml
@@ -1,5 +1,6 @@
 read:
   mode: "proto"
+  beginTimestamp: ""
   proto:
     pathToDescriptor: "src/test/resources/person.desc"
   subject: "*"