File tree Expand file tree Collapse file tree 1 file changed +7
-2
lines changed
sdk-tests/src/test/java/io/dapr/it/spring/messaging Expand file tree Collapse file tree 1 file changed +7
-2
lines changed Original file line number Diff line number Diff line change 20
20
import io .dapr .testcontainers .DaprContainer ;
21
21
import io .dapr .testcontainers .DaprLogLevel ;
22
22
import org .junit .jupiter .api .BeforeAll ;
23
+ import org .junit .jupiter .api .BeforeEach ;
23
24
import org .junit .jupiter .api .Tag ;
24
25
import org .junit .jupiter .api .Test ;
25
26
import org .slf4j .Logger ;
@@ -80,10 +81,14 @@ public static void beforeAll(){
80
81
org .testcontainers .Testcontainers .exposeHostPorts (APP_PORT );
81
82
}
82
83
83
- @ Test
84
- public void testDaprMessagingTemplate () throws InterruptedException {
84
+ @ BeforeEach
85
+ public void beforeEach () {
86
+ // Ensure the subscriptions are registered
85
87
Wait .forLogMessage (SUBSCRIPTION_MESSAGE_PATTERN , 1 ).waitUntilReady (DAPR_CONTAINER );
88
+ }
86
89
90
+ @ Test
91
+ public void testDaprMessagingTemplate () throws InterruptedException {
87
92
for (int i = 0 ; i < 10 ; i ++) {
88
93
var msg = "ProduceAndReadWithPrimitiveMessageType:" + i ;
89
94
You can’t perform that action at this time.
0 commit comments