This is an automated email from the ASF dual-hosted git repository. reta pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/cxf.git
commit b9634cbd2e8adf7ad1186c2471d396dd2119d388 Author: Andriy Redko <[email protected]> AuthorDate: Wed Dec 14 21:03:11 2022 -0500 Fixing jms_spring_config --- .../example/customerservice/broker/EmbeddedBroker.java | 11 ++++++++++- .../client/CustomerServiceSpringClient.java | 16 +++++++++------- 2 files changed, 19 insertions(+), 8 deletions(-) diff --git a/distribution/src/main/release/samples/jms_spring_config/src/main/java/com/example/customerservice/broker/EmbeddedBroker.java b/distribution/src/main/release/samples/jms_spring_config/src/main/java/com/example/customerservice/broker/EmbeddedBroker.java index d4db3ac371..00a6df389f 100644 --- a/distribution/src/main/release/samples/jms_spring_config/src/main/java/com/example/customerservice/broker/EmbeddedBroker.java +++ b/distribution/src/main/release/samples/jms_spring_config/src/main/java/com/example/customerservice/broker/EmbeddedBroker.java @@ -20,6 +20,7 @@ package com.example.customerservice.broker; import java.io.File; +import java.util.Collections; import java.util.HashSet; import java.util.Set; @@ -27,6 +28,7 @@ import org.apache.activemq.artemis.core.config.Configuration; import org.apache.activemq.artemis.core.config.impl.ConfigurationImpl; import org.apache.activemq.artemis.core.server.ActiveMQServer; import org.apache.activemq.artemis.core.server.impl.ActiveMQServerImpl; +import org.apache.activemq.artemis.core.settings.impl.AddressSettings; public final class EmbeddedBroker { private EmbeddedBroker() { @@ -38,7 +40,14 @@ public final class EmbeddedBroker { config.setSecurityEnabled(false); config.addAcceptorConfiguration("tcp", "tcp://localhost:61616"); config.setBrokerInstance(new File("target/activemq-data")); - + + AddressSettings addressSettings = new AddressSettings(); + addressSettings.setAutoCreateAddresses(true); + addressSettings.setAutoCreateQueues(true); + addressSettings.setAutoDeleteQueues(false); + addressSettings.setAutoDeleteAddresses(false); + config.setAddressSettings(Collections.singletonMap("tcp", addressSettings)); + final ActiveMQServer server = new ActiveMQServerImpl(config); server.start(); diff --git a/distribution/src/main/release/samples/jms_spring_config/src/main/java/com/example/customerservice/client/CustomerServiceSpringClient.java b/distribution/src/main/release/samples/jms_spring_config/src/main/java/com/example/customerservice/client/CustomerServiceSpringClient.java index daae425e43..2afb0f8229 100644 --- a/distribution/src/main/release/samples/jms_spring_config/src/main/java/com/example/customerservice/client/CustomerServiceSpringClient.java +++ b/distribution/src/main/release/samples/jms_spring_config/src/main/java/com/example/customerservice/client/CustomerServiceSpringClient.java @@ -18,6 +18,7 @@ */ package com.example.customerservice.client; +import org.apache.activemq.artemis.api.core.client.ActiveMQClient; import org.springframework.context.support.ClassPathXmlApplicationContext; /** @@ -28,12 +29,13 @@ public final class CustomerServiceSpringClient { } public static void main(String[] args) throws Exception { - ClassPathXmlApplicationContext context - = new ClassPathXmlApplicationContext(new String[] {"classpath:client-applicationContext.xml"}); - CustomerServiceTester client = (CustomerServiceTester)context.getBean("tester"); - - client.testCustomerService(); - - context.close(); + try (ClassPathXmlApplicationContext context + = new ClassPathXmlApplicationContext(new String[] {"classpath:client-applicationContext.xml"})) { + CustomerServiceTester client = (CustomerServiceTester)context.getBean("tester"); + client.testCustomerService(); + } + + // Shutdown ActiveMQ client pools + ActiveMQClient.clearThreadPools(); } }
