PawelPacholek
diff --git a/‎e-2-e-tests/src/test/java/com/e2e_tests/E2ETests.java
Lines changed: 7 additions & 1 deletion b/‎e-2-e-tests/src/test/java/com/e2e_tests/E2ETests.java
Lines changed: 7 additions & 1 deletion
diff --git a/‎main-owner-service/run/src/test/java/com/main_owner_service/run/test/UploadInitialOwnerControllerWithPubsubEmulatorTest.java
Lines changed: 5 additions & 0 deletions b/‎main-owner-service/run/src/test/java/com/main_owner_service/run/test/UploadInitialOwnerControllerWithPubsubEmulatorTest.java
Lines changed: 5 additions & 0 deletions
diff --git a/‎pubsub-emulator/src/main/java/com/pubsub_emulator/PubSubEmulator.java
Lines changed: 8 additions & 0 deletions b/‎pubsub-emulator/src/main/java/com/pubsub_emulator/PubSubEmulator.java
Lines changed: 8 additions & 0 deletions
@@ -27,6 +27,7 @@
 import java.io.IOException;
 import java.io.UncheckedIOException;
 import java.time.Duration;
+import java.util.List;
 
 //@AutoConfigureMockMvc
 @SpringBootTest(webEnvironment = SpringBootTest.WebEnvironment.NONE, classes = E2ETests.App.class)
@@ -99,7 +100,12 @@ public void simpleEndToEndTest() {
       MyResponse uploadResponse = sendRequest(uploadRequest);
       System.out.println(uploadResponse);
 
-      sleep(10);
+      sleep(5);
+
+      List<String> messages = PubSubEmulator.fetchRawMessages("label-owner-service-to-initialOwner-subscription");
+      System.out.println("Messages size: " + messages.size());
+
+      sleep(5);
 
       ClassicHttpRequest fetchRequest = createFetchRequest(ownerId, mainOwnerServiceMappedPort);
       MyResponse fetchResponse = sendRequest(fetchRequest);
 
@@ -31,6 +31,9 @@
 import org.springframework.test.web.servlet.MockMvc;
 import org.springframework.test.web.servlet.request.MockHttpServletRequestBuilder;
 
+import java.util.List;
+
+import static org.assertj.core.api.Assertions.assertThat;
 import static org.springframework.test.web.servlet.request.MockMvcRequestBuilders.post;
 import static org.springframework.test.web.servlet.result.MockMvcResultMatchers.status;
 
@@ -75,6 +78,8 @@ public void happyPath() throws Exception {
                     {"id":7,"name":"name1","address":"address2","phone":"phone3","email":"email4"}""";
         mockMvc.perform(uploadInitialOwner().contentType(MediaType.APPLICATION_JSON).content(mockBody))
                 .andExpect(status().isOk());
+        List<String> messages = PubSubEmulator.fetchRawMessages("label-owner-service-to-initialOwner-subscription");
+        assertThat(messages).hasSize(1);
     }
 
     private static MockHttpServletRequestBuilder uploadInitialOwner() {
 
@@ -4,6 +4,7 @@
 import com.fasterxml.jackson.databind.ObjectMapper;
 import com.google.cloud.spring.pubsub.PubSubAdmin;
 import com.google.cloud.spring.pubsub.core.PubSubTemplate;
+import com.google.protobuf.AbstractMessage;
 import org.assertj.core.api.Assertions;
 import org.assertj.core.api.ObjectAssert;
 import org.assertj.core.api.RecursiveComparisonAssert;
@@ -78,6 +79,13 @@ public static <T> List<T> fetchMessages(String subscriptionId, BiFunction<String
       .toList();
   }
 
+  public static List<String> fetchRawMessages(String subscriptionId) {
+    return template.get().pullAndAck(subscriptionId, 100, true)
+      .stream()
+      .map(AbstractMessage::toString)
+      .toList();
+  }
+
   public static void createTopicAndSubscription(String topicId, String subscriptionId) {
     admin.get().createTopic(topicId);
     admin.get().createSubscription(subscriptionId, topicId);