camel

不念不忘少年蓝@ 2022-05-10 15:28 144阅读 0赞

import org.apache.camel.CamelContext;  
import org.apache.camel.component.activemq.ActiveMQComponent;  
import org.apache.camel.component.activemq.ActiveMQConfiguration;  
import org.apache.camel.impl.DefaultCamelContext;  
import org.apache.camel.spring.SpringRouteBuilder;  
  
  
public final class CamelJmsToRemoteExample \{  
  
    private CamelJmsToRemoteExample() \{  
    \}  
  
    public static void main(String args\[\]) throws Exception \{  
        CamelContext context = new DefaultCamelContext();  
  
        final String localBrokerURL = "tcp://localhost:61616";  
        final String remoteBrokerURL = "tcp://remoteip:61616";  
  
        ActiveMQComponent localComponent = new ActiveMQComponent();  
        ActiveMQConfiguration localConfiguration = new ActiveMQConfiguration();  
        localConfiguration.setBrokerURL(localBrokerURL);  
        localComponent.setConfiguration(localConfiguration);  
  
        ActiveMQComponent remoteComponent = new ActiveMQComponent();  
        ActiveMQConfiguration remoteConfiguration = new ActiveMQConfiguration();  
        remoteConfiguration.setBrokerURL(remoteBrokerURL);  
        remoteComponent.setConfiguration(remoteConfiguration);  
  
        // context.addComponent("activemq", localComponent);  
        context.addComponent("remoteActivemq", remoteComponent);  
  
        context.addRoutes(new CamelRouteBuilder());  
  
        context.start();  
    \}  
  
\}  
  
class CamelRouteBuilder extends SpringRouteBuilder \{  
  
    @Override  
    public void configure() throws Exception \{  
        from("activemq:TEST.FOO").to("remoteActivemq:TEST.FOO");  
    \}  
  
\}

发表评论取消回复

表情：

评论列表（有 0 条评论，144人围观）

还没有评论，来说两句吧...

相关阅读

相关 Camel实战第二版第二章 Camel路由

Camel实战第二版第二章 Camel路由第一部分：迈出第一步第一章：[初识Camel][Camel] 第二章：[Camel路由][Camel 1]

冷不防/ 2024年03月31日 12:07/ 0 赞/ 36 阅读

相关 Apache Camel异常处理

直接看代码 package com.lala.bean; import org.apache.camel.Exchange; import

雨点打透心脏的1/2处/ 2022年08月05日 11:15/ 0 赞/ 153 阅读

相关 camel+activemq入门整合

摘要： Apache Camel是Apache基金会下的一个开源项目,它是一个基于规则路由和中介引擎，提供企业集成模式的Java对象的实现，通过应用程序接口（或称为陈述式的

た入场券/ 2022年06月10日 11:51/ 0 赞/ 329 阅读

相关 camel读取配置信息

摘要：有时候我们常把一些配置信息写在xxx.properties文件中，为的是改动的时候轻松一点，那么笔者在用camel时也尝试了一下参考地址：[http://camel

浅浅的花香味﹌/ 2022年06月10日 09:26/ 0 赞/ 197 阅读

相关 camel

import org.apache.camel.CamelContext; import org.apache.camel.component.activemq.Ac

不念不忘少年蓝@/ 2022年05月10日 15:28/ 0 赞/ 145 阅读

相关 springboot整合camel,kafka

camel 就是定义路由 maven依赖  <dependency>

野性酷女/ 2022年05月09日 14:14/ 0 赞/ 288 阅读

相关 springboot camel mqtt activemq

前面写类一篇kafka的，这里就不说了 springboot版本 2.0.4.RELEASE maven <dependency>

电玩女神/ 2022年03月15日 01:58/ 0 赞/ 154 阅读

相关 springboot camel mqtt kafka

设备通过mqtt协议传送数据包到服务器，但是现在处理数据是通过kafka，所以就整合了camel转发 maven <dependency>

爱被打了一巴掌/ 2022年03月15日 01:24/ 0 赞/ 297 阅读

相关 Apache Camel - 事务

> Apache Camel是一个基于Enterprise Integration Pattern(企业整合模式，简称EIP)的开源框架。 1. 概述关于`Apach

水深无声/ 2022年02月16日 01:21/ 0 赞/ 247 阅读

相关 Apache camel

什么时候使用Apache camel 　　 Enterprise Application Integration 企业应用集成(EAI) 　　企业应用集成是必要的，几乎

忘是亡心i/ 2021年12月18日 16:27/ 0 赞/ 334 阅读