apache-camel

1熱度

1回答

我有一個JBoss Fuse項目，我從外部接收數據（實體）並處理它。我想實施事件採購，以便能夠模擬之後的數據消耗。有沒有可能在駱駝路線中包含某種事件採購？是否有某個活動存儲區，與駱駝最適合，並且可以輕鬆集成？在此先感謝！最好的問候，桑德拉

0熱度

2回答

爪哇8的Apache駱駝接收的I具有監聽活性MQ駱駝路由。我的隊列包含JSON負載。我已經crated mapper bean想知道如何將json響應轉換爲映射器對象列表。 from ("activemq:queue:my.queue") .log("msg received").log("body" + ${body}"); class myMapper{ String name;

0熱度

1回答

是否有Apache Camel的KairosDB組件？

我找不到KairosDB的Camel組件。有沒有？我應該寫一個自定義組件還是有更智能的方法？謝謝

0熱度

1回答

camel netty4 ChannelHandlerFactory ByteToMessageDecoder錯誤

因爲我是駱駝的初學者。我想得到一個提示來解決我的問題。這裏是我的代碼完整的源鏈接：https://github.com/kcy0142/camel_netty_test @Configuration public class ChannelHandlerFactoryByteArrayDecoder implements ChannelHandlerFactory { @Bean

1熱度

1回答

基於某些條件，禁用路由被添加到駱駝上下文

我需要根據某些條件來限制添加到駱駝上下文的特定路由。試過RoutePolicy.onStart - >但是這個方法在啓動路由後被調用。我需要一種方法來完全避免生成/添加到駱駝上下文的路線。 private List<String> eligibleRoutes; @Override public void onStart(Route route) { LOGGER.inf

0熱度

1回答

駱駝卡夫卡登錄不正確細節messageHistory

我使用駱駝卡夫卡組件2.19（最新）。我正在用「my-topic」初始化kafka製作人端點。但話題是在運行時計算的說：「我的錯誤話題」，我把它的頭所以該消息被產生的「我的錯誤話題」。一切正常。問題是，當記錄messageHistory時，它記錄了初始路由和我用於初始化的主題，這使得它爲支持人員提供誤導信息，因爲它給了他們一個想法，即將消息生成爲「我的話題」。作爲解決方法，我已經停止記錄消息歷史

3熱度

1回答

如何在apache + spring中動態加載屬性文件的值

我是一個新手，在spring中使用駝鹿2.17。我有從web服務接收的錯誤代碼的處理器和我配置在屬性文件中的錯誤描述等 myproject.errorCode=1001:error1 description, 1002:error2 description, 1003:.... 目前我使用屬性注射讀取值myproject.errorCode和解析所有的errorCode與描述這是工作正常。但是

0熱度

1回答

空的@Link字段不在CSV中，缺失列

我試圖用多個實體的字段生成一個CSV文件。在我的駱駝路線中，我有一個BindyCsvDataFormat用於我的實體。但是，如果SubEntity爲null，則SubEntity字段不會以「」形式導出到CSV文件。所以某些行缺少列。 MainEntity中的空值被導出爲「」。當SubEntity爲空時，如何配置Bindy將SubEntity列導出爲「」？的實體連在了一起，像這樣： @Entity

1熱度

1回答

負載枚舉成駱駝頭

我有以下類包括枚舉： package com.xxx.enumeration; public class Message { public enum Severity { INFO, ERROR, WARNING; } } 如何創建具有誤差值藍圖駱駝頭？我試着做以下 <setHeader headerName="CamelLogSeverity">

0熱度

1回答

Came jmsComponent：在不同的bean中設置異常Listener有什麼區別？

我設置了這樣的方式春天JMS組件： <bean id="jmsConnectionFactory" class="org.apache.activemq.ActiveMQConnectionFactory"> <property name="brokerURL" value="tcp://localhost:61616" /> </bean> <bean id="cach