是否可以从另一个应用程序(在单独的进程中启动)连接到Spring Boot嵌入式ActiveMQ实例?

gstackoverflow:

我已经阅读了一些有关Spring Boot中对jms支持的示例

通常,发送者,接收者和active-mq(实际上可以是任何其他与jms兼容的消息代理)都位于同一应用程序中。

我知道我可以使用独立的主动mq并使用属性 s:

spring.activemq.broker-url=tcp://192.168.1.210:9876
spring.activemq.user=admin
spring.activemq.password=secret

但是我想要2个应用程序:

1-发送器(从嵌入式接收器连接到jms并在其中发送消息)
2-接收器(up应用程序和嵌入式activemq)

可行吗?

加里·罗素:

只需BrokerService在您的应用程序中添加一个bean:

@SpringBootApplication
public class So48504265Application {

    public static void main(String[] args) {
        SpringApplication.run(So48504265Application.class, args);
    }

    @Bean
    public BrokerService broker() throws Exception {
        BrokerService broker = new BrokerService();
        broker.addConnector("tcp://localhost:61616");
        return broker;
    }

    @Bean
    public ApplicationRunner runner(JmsTemplate template) {
        return args -> template.convertAndSend("foo", "AMessage");
    }

    @JmsListener(destination = "foo")
    public void listen(String in) {
        System.out.println(in);
    }

}

spring.activemq.broker-url=tcp://localhost:61616

并将其添加到您的pom

<dependency>
    <groupId>org.apache.activemq</groupId>
    <artifactId>activemq-kahadb-store</artifactId>
</dependency>

本文收集自互联网,转载请注明来源。

如有侵权,请联系 [email protected] 删除。

编辑于
0

我来说两句

0 条评论
登录 后参与评论

相关文章

带有嵌入式 ActiveMQ Broker 的 Spring Boot WebSocket

如何使用Spring Boot配置嵌入式ActiveMQ Broker URL

是否可以在另一个Spring Boot应用程序中嵌套一个Spring Boot应用程序?

当两个应用程序都使用嵌入式activemq时,如何将Jms消息从一个弹簧启动应用程序发送到另一个

如何在另一个可可应用程序中嵌入一个可可应用程序并将其作为子进程启动

Spring Boot数据嵌入式Cassandra

用于Spring Boot的嵌入式Redis

Spring Boot嵌入式tomcat日志

Spring Boot + GWT嵌入式配置

Spring Boot嵌入式Tomcat性能

是否可以从Spring Boot应用程序压缩嵌入式HSQL DB?

我可以从另一个应用程序(Spring Boot 或 Micronaut 应用程序)内部启动另一个应用程序(启动 Redis 缓存服务器)吗?

无法在不同的Spring Boot应用程序中的不同端口上启动2个嵌入式active-mq

如何通过SIP将一个Twilio应用程序实例连接到另一个?

Spring Boot应用程序未启动嵌入式Tomcat

如何从另一个Maven模块启动Spring Boot应用程序?

访问嵌入式内存中的HSQLDB实例

Spring Boot:WebServerException:无法启动嵌入式Tomcat

通过嵌入式DLL将多个应用程序连接到一个Firebird数据库

在Spring Boot嵌入式Tomcat中配置maxKeepAliveRequests

Spring Boot 中的非嵌入式 postgresql

在Spring Boot应用程序中以嵌入式模式的SymmetricDS作为客户端

在Linux的嵌入式Tomcat服务器中运行Spring Boot应用程序

如何使用Spring Boot应用程序在嵌入式Jetty中配置异步超时

在Spring Boot中使用多个嵌入式数据存储

Spring Boot找不到嵌入式KafkaBroker Bean

如何关闭Spring Boot嵌入式服务器

修改Spring Boot嵌入式Tomcat提取路径

Spring Boot,无法初始化嵌入式tomcat