Apache camel 与 rabbitmq 集成。

发布于 2022-09-11 19:26:32 字数 1030 浏览 22 评论 0

我想实现一个功能,在做完数据库操作后,将操作内容作为消息发送到rabbitmq队列中去。
学习了一下Apache camel ,不是很懂,要如何在数据库操作以后启动camel来发送消息,网上查找资料有代码的方式和xml配置两种方式,

from("").to("rabbitmq://localhost:5672/myexchange?username=guest&password=guest&queue=userQueue")
<bean id="customConnectionFactory" class="com.rabbitmq.client.ConnectionFactory">
        <property name="host" value="xx.xx.xx.xx"  />
        <property name="port"  value="5672"/>
        <property name="username" value="guest" />
        <property name="password" value="guest" />
    </bean>

    <camelContext id="camel" xmlns="http://camel.apache.org/schema/spring">                        
         <route>
            <from uri=""/>
            <to uri="rabbitmq://xx.xx.xx.xx:5672/myexchange?connectionFactory=#customConnectionFactory"/>
          </route>
    </camelContext>

这里的from中应该怎么调用?

如果是xml配置的方式,我要如何使它跟随spring一起启动,我已经添加了camel.xml文件并关联,但是好像不生效

如果你对这篇内容有疑问,欢迎到本站社区发帖提问 参与讨论,获取更多帮助,或者扫码二维码加入 Web 技术交流群。

扫码二维码加入Web技术交流群

发布评论

需要 登录 才能够评论, 你可以免费 注册 一个本站的账号。
列表为空,暂无数据
我们使用 Cookies 和其他技术来定制您的体验包括您的登录状态等。通过阅读我们的 隐私政策 了解更多相关信息。 单击 接受 或继续使用网站,即表示您同意使用 Cookies 和您的相关数据。
原文