Outbox

Author: oklemenz2

java/project/srv/src/test/java/com/github/capjscommunity/sapafcsdk/scheduling/outbox/SchedulingProviderOutboxCancelTest.java

@@ -21,20 +21,13 @@
 import org.springframework.boot.test.autoconfigure.web.servlet.AutoConfigureMockMvc;
 import org.springframework.boot.test.context.SpringBootTest;
 import org.springframework.security.test.context.support.WithMockUser;
-import org.springframework.test.context.DynamicPropertyRegistry;
-import org.springframework.test.context.DynamicPropertySource;
 import org.springframework.test.web.servlet.MockMvc;
 import org.springframework.test.web.servlet.MvcResult;
 
 @AutoConfigureMockMvc
 @SpringBootTest
 public class SchedulingProviderOutboxCancelTest {
 
-  @DynamicPropertySource
-  static void overrideProps(DynamicPropertyRegistry registry) {
-    registry.add("cds.persistence.schema", () -> "OUTBOX_PROVIDER_CANCEL");
-  }
-
   @Autowired
   private MockMvc mockMvc;
 

java/project/srv/src/test/java/com/github/capjscommunity/sapafcsdk/scheduling/outbox/SchedulingProviderOutboxCreateTest.java

@@ -20,20 +20,13 @@
 import org.springframework.boot.test.autoconfigure.web.servlet.AutoConfigureMockMvc;
 import org.springframework.boot.test.context.SpringBootTest;
 import org.springframework.security.test.context.support.WithMockUser;
-import org.springframework.test.context.DynamicPropertyRegistry;
-import org.springframework.test.context.DynamicPropertySource;
 import org.springframework.test.web.servlet.MockMvc;
 import org.springframework.test.web.servlet.MvcResult;
 
 @AutoConfigureMockMvc
 @SpringBootTest
 public class SchedulingProviderOutboxCreateTest {
 
-  @DynamicPropertySource
-  static void overrideProps(DynamicPropertyRegistry registry) {
-    registry.add("cds.persistence.schema", () -> "OUTBOX_PROVIDER_CREATE");
-  }
-
   @Autowired
   private MockMvc mockMvc;
 

java/project/srv/src/test/java/com/github/capjscommunity/sapafcsdk/scheduling/outbox/SchedulingWebsocketOutboxTest.java

@@ -20,18 +20,11 @@
 import org.springframework.boot.test.autoconfigure.web.servlet.AutoConfigureMockMvc;
 import org.springframework.boot.test.context.SpringBootTest;
 import org.springframework.security.test.context.support.WithMockUser;
-import org.springframework.test.context.DynamicPropertyRegistry;
-import org.springframework.test.context.DynamicPropertySource;
 
 @AutoConfigureMockMvc
 @SpringBootTest
 public class SchedulingWebsocketOutboxTest {
 
-  @DynamicPropertySource
-  static void overrideProps(DynamicPropertyRegistry registry) {
-    registry.add("cds.persistence.schema", () -> "OUTBOX_WEBSOCKET");
-  }
-
   @Autowired
   private CdsRuntime cdsRuntime;
 

java/project/srv/src/test/java/com/github/capjscommunity/sapafcsdk/test/OutboxTestSetup.java

@@ -41,7 +41,11 @@ public OutboxTestSetup(String serviceName, CdsRuntime cdsRuntime, PersistenceSer
         return;
       }
       String message = ((CdsCreateEventContextImpl) context).getCqn().entries().getFirst().get("msg").toString();
+      System.out.println("-----> Outbox message created");
       messageEvents.add(new JSONObject(message));
+      try {
+        Thread.sleep(100);
+      } catch (InterruptedException ignored) {}
       messageCreated.countDown();
     });
 
@@ -55,6 +59,10 @@ public OutboxTestSetup(String serviceName, CdsRuntime cdsRuntime, PersistenceSer
           new ChangeSetListener() {
             @Override
             public void afterClose(boolean completed) {
+              System.out.println("-----> Outbox message deleted");
+              try {
+                Thread.sleep(100);
+              } catch (InterruptedException ignored) {}
               messageDeleted.countDown();
             }
           }