Spring/spring-pulsar
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Fix pulsar functions IT

Browse Source 
- Does not fail when `/connectors` not available
This commit is contained in:
Chris Bono
2023-01-18 17:44:49 -06:00
parent d45af6979b
commit d74404ff3c
1 changed files with 15 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

21
spring-pulsar-spring-boot-autoconfigure/src/test/java/org/springframework/pulsar/autoconfigure/PulsarFunctionAdministrationIntegrationTests.java
View File

@@ -79,17 +79,26 @@ class PulsarFunctionAdministrationIntegrationTests {
private static final String PULSAR_TOPIC = "pft_foo-topic";
private static final PulsarContainer PULSAR_CONTAINER = new PulsarContainer(
PulsarTestContainerSupport.getPulsarImage()).withFunctionsWorker()
.withClasspathResourceMapping("/connectors/", "/pulsar/connectors", BindMode.READ_ONLY);
PulsarTestContainerSupport.getPulsarImage());
private static final RabbitMQContainer RABBITMQ_CONTAINER = new RabbitMQContainer("rabbitmq")
.withNetworkAliases("rabbitmq").withExposedPorts(5672, 15672).withStartupTimeout(Duration.ofMinutes(1));
private static final RabbitMQContainer RABBITMQ_CONTAINER = new RabbitMQContainer("rabbitmq");
@BeforeAll
static void startContainers() {
Network sharedNetwork = Network.newNetwork();
PULSAR_CONTAINER.withNetwork(sharedNetwork).start();
RABBITMQ_CONTAINER.withNetwork(sharedNetwork).start();
// @formatter:off
PULSAR_CONTAINER
.withNetwork(sharedNetwork)
.withFunctionsWorker()
.withClasspathResourceMapping("/connectors/", "/pulsar/connectors", BindMode.READ_ONLY)
.start();
RABBITMQ_CONTAINER
.withNetwork(sharedNetwork)
.withNetworkAliases("rabbitmq")
.withExposedPorts(5672, 15672)
.withStartupTimeout(Duration.ofMinutes(1))
.start();
// @formatter:on
}
private static final CountDownLatch RECEIVED_MESSAGE_LATCH = new CountDownLatch(10);