Цель
Я хочу отправить сообщение в тему, которую я обработаю позже с помощью клиентских приложений. Для этой цели я использую Spring Boot и Spring Integration Java DSL с его модулем JMS. В качестве брокера сообщений я использую собственный ActiveMQ Artemis.
Вот мои настройки
DemoApplication.java
@SpringBootApplication
public class DemoApplication {
private static final Logger logger = LoggerFactory.getLogger(DemoApplication.class);
public interface StarGate {
void sendHello(String helloText);
}
@Autowired
private ConnectionFactory connectionFactory;
@Bean
public IntegrationFlow mainFlow() {
return IntegrationFlows
.from(StarGate.class)
.handle(Jms.outboundAdapter(connectionFactory)
.configureJmsTemplate(jmsTemplateSpec -> jmsTemplateSpec
.deliveryPersistent(true)
.pubSubDomain(true)
.sessionTransacted(true)
.sessionAcknowledgeMode(Session.CLIENT_ACKNOWLEDGE)
.explicitQosEnabled(true)
)
.destination(new ActiveMQTopic("wormhole")))
.get();
}
public static void main(String[] args) {
ConfigurableApplicationContext context = SpringApplication.run(DemoApplication.class, args);
StarGate stargate = context.getBean(StarGate.class);
stargate.sendHello("Jaffa, kree!");
logger.info("Hello message sent.");
}
}
application.properties
spring.artemis.mode=native
spring.artemis.host=localhost
spring.artemis.port=61616
spring.artemis.user=artemis
spring.artemis.password=simetraehcapa
spring.jms.pub-sub-domain=true
spring.jms.template.delivery-mode=persistent
spring.jms.template.qos-enabled=true
spring.jms.listener.acknowledge-mode=client
logging.level.org.springframework=INFO
build.gradle (важные части)
springBootVersion = '2.0.2.RELEASE'
dependencies {
compile('org.springframework.boot:spring-boot-starter-artemis')
compile('org.springframework.boot:spring-boot-starter-integration')
compile('org.springframework.integration:spring-integration-jms')
testCompile('org.springframework.boot:spring-boot-starter-test')
}
В качестве сервера ActiveMQ Artemis я использую образ докера vromero / artemis (2.6.0) с конфигурацией по умолчанию.
Проблема
На стороне производителя сообщение кажется успешно отправленным, но на стороне сообщения брокера сообщение отсутствует. Адрес создан, но очередь отсутствует.
Название темы будет динамическим в будущем, поэтому мне не разрешено создавать тему вручную в broker.xml. Я полагаюсь на функцию автоматического создания очереди Artemis.
Почему в этом случае не работает отправка сообщений?
Примечание для ботаников: я знаю, что Звездные врата в основном связаны через червоточины по принципу точка-точка, но ради вопроса давайте проигнорируем этот факт.
