apache-camel

0熱度

2回答

使用這個例子，下面：表達體（）的toString（）產生「簡單{} AA」 ... 但是，我真的只希望「AA」值... ，我要如何提取字符串（在本例中：「AA」）？從「簡單{}」表達...... from("timer://foo?fixedRate=true&period=" + 5000) //5 seconds... .setBody(constant(s))

1熱度

2回答

在Apache的駱駝RouteBuilder配置，是什麼.ID（）和.routeId（）之間的區別

是什麼從「駱駝」的傢伙 configure { from (blah blah) .id(blah) .... } 和 configure { from (blah blah) .routeId(blah) .. .. }

0熱度

2回答

camel-ssh基於密鑰的認證

我試圖通過駱駝路由執行ssh命令。我得到低於錯誤任何人都可以幫助我解決這個問題。我能夠通過使用用戶名和密碼執行命令。我在authorized_keys中複製的公鑰在服務器中。我正在使用blueprint dsl。 < to uri="ssh://[email protected]:22? certResource=classpath:test_rsa&timeout=5000"/>

2熱度

1回答

駱駝RabbitMQ默認ConnectionFactory？

我正在使用Camel在RabbitMQ中使用和生成消息。另外，我正在使用Spring引導，所以我創建了一個具有我想要的所有配置的ConnectionFactory bean。這很好用，但我必須在創建的每個端點字符串中聲明bean的名稱。有沒有辦法讓駱駝默認使用這個特定的bean？

2熱度

4回答

阿帕奇駱駝的XPath條件路由

我在我的應用程序上下文駱駝路線定義爲 <camelContext xmlns="http://camel.apache.org/schema/spring" trace="true" id="camel"> <route id="wsProxyRedirection"> <from uri="cxf:bean:cdcPocProxyWebServiceStartP

1熱度

1回答

Camel ActiveMQ：使用基於JMSTimestamp的消息

我已經定義了一個Route，它消耗隊列中的消息沒有任何問題，現在我試圖使用已經在隊列中12小時的消息，我得到了想法使用selector，但不知道如何使用JMSTimestamp來滿足12小時的標準。這是Route： <route id="INBOUND.RECEIVE.IN"> <from uri="activemq:queue:QXL.INBOUND.RECEIVE.IN

0熱度

2回答

從XML DSL動態啓動駱駝路由

我試圖根據屬性文件中的布爾值條件啓動XML DSL中的路由。但它有點不起作用。我不確定這是否是正確的做法。任何幫助表示讚賞，謝謝:) 這是我blueprint.xml <bean id="bridgePropertyPlaceholder" class="org.apache.camel.spring.spi.BridgePropertyPlaceholderConfigurer"> <

2熱度

1回答

on處理器路由範圍在路由中間觸發

我遇到了Camel 2.19.1的問題。和onCompletion具有路由範圍的處理程序。運行時是Java 8，Karaf 4.0.9。駱駝上下文是用藍圖構建的。我與每次onCompletion處理程序中定義3條路線： <onCompletion mode="BeforeConsumer" parallelProcessing="false" onCompleteOnly="true" useO

0熱度

1回答

運行

我寫HTTP requests.and端點的通用路由過程中獲取端點apche的駱駝是不是路線靜態value.Code： from("direct:processRequests") .split(body().method("getItems"), new GroupedBodyAggregationStrategy()) .parallelProcessing()

1熱度

2回答

Apache的駱駝「不與方案找到的組件：流」

我剛剛認識駱駝（和Maven），我有這個非常簡單的Java例子： public static void main(String[] args) throws Exception { CamelContext context = new DefaultCamelContext(); context.addRoutes(new RouteBuilder() {