Skip to content

Commit 77cc9ca

Browse files
committed
test: remove timeouts for pubsub test run
1 parent 7a7efd0 commit 77cc9ca

File tree

1 file changed

+0
-6
lines changed

1 file changed

+0
-6
lines changed

pubsub/pubsub-client/src/test/java/com/salesforce/multicloudj/pubsub/client/AbstractPubsubIT.java

Lines changed: 0 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -17,7 +17,6 @@
1717
import org.junit.jupiter.api.Disabled;
1818
import org.junit.jupiter.api.Test;
1919
import org.junit.jupiter.api.TestInstance;
20-
import org.junit.jupiter.api.Timeout;
2120

2221
import java.util.ArrayList;
2322
import java.util.List;
@@ -109,7 +108,6 @@ public void testSendBatchMessages() throws Exception {
109108
}
110109

111110
@Test
112-
@Timeout(30) // Integration test that calls receive() - fail fast if recordings are missing
113111
public void testReceiveAfterSend() throws Exception {
114112
try (AbstractTopic topic = harness.createTopicDriver();
115113
AbstractSubscription subscription = harness.createSubscriptionDriver()) {
@@ -136,7 +134,6 @@ public void testReceiveAfterSend() throws Exception {
136134
}
137135

138136
@Test
139-
@Timeout(30) // Integration test that calls receive() - fail fast if recordings are missing
140137
public void testAckAfterReceive() throws Exception {
141138
try (AbstractTopic topic = harness.createTopicDriver();
142139
AbstractSubscription subscription = harness.createSubscriptionDriver()) {
@@ -162,7 +159,6 @@ public void testAckAfterReceive() throws Exception {
162159
}
163160

164161
@Test
165-
@Timeout(30) // Integration test that calls receive() - fail fast if recordings are missing
166162
public void testNackAfterReceive() throws Exception {
167163
try (AbstractTopic topic = harness.createTopicDriver();
168164
AbstractSubscription subscription = harness.createSubscriptionDriver()) {
@@ -232,7 +228,6 @@ public void testBatchAck() throws Exception {
232228
}
233229

234230
@Test
235-
@Timeout(120) // Integration test with batch operations - allow time for message delivery
236231
public void testBatchNack() throws Exception {
237232
try (AbstractTopic topic = harness.createTopicDriver();
238233
AbstractSubscription subscription = harness.createSubscriptionDriver()) {
@@ -351,7 +346,6 @@ public void testGetAttributes() throws Exception {
351346
}
352347

353348
@Test
354-
@Timeout(30)
355349
public void testMultipleSendReceiveWithoutBatch() throws Exception {
356350
Assumptions.assumeFalse(AWS_PROVIDER_ID.equals(harness.getProviderId()));
357351
try (AbstractTopic topic = harness.createTopicDriver();

0 commit comments

Comments
 (0)