apache-camel

0熱

1答えて

それぞれの環境を定義するJVMオプションがあります。それは-Denv = "development"のようなものです。 camelコンテキストでこのJVMオプションにアクセスし、env値に基づいてルートを決定するにはどうすればよいですか？ camel-propertiesコンポーネントを使用

0熱

2答えて

DefaultMessageを拡張してクラスを作成する

DefautMessageクラスを再利用してbodyをseda componnetに送信しようとしています。私のメッセージクラスは実装なしで以下に与えられています。その後 public class TestMessage extends DefaultMessage{ } 私は TestMessage msg = new TestMessage(); msg.setBody(

0熱

1答えて

AMQからファイルを読み取る

こんにちは私は消費者とプロデューサーをAMQで作成しています。今ポイントは、私はファイルを読んでいます（それはxml、csv、またはシンプルなテキストファイルです）。AMQトピックに送信してください。問題は、別の消費者がそのファイルを読んでみたいときです。ファイル（xml、txt、またはcsv）をコンシューマに送信します。私はアーキテクチャからラクダを取り除き、ファイルをバイトに変換し、次にByt

5熱

2答えて

キャメル述語の例では、XML DSLに私は春DSLに述語例<a href="http://camel.apache.org/predicate.html" rel="noreferrer">given</a>を次実装することができますどのように

：このように Predicate isWidget = header("type").isEqualTo("widget"); from("jms:queue:order") .choice() .when(isWidget).to("bean:widgetOrder") .when(isWombat).to("bean:wombatOrder")

1熱

1答えて

SpringのアプリケーションコンテキストxmlのJVMオプションにアクセス

SpringのapplicationContext.xmlで-Dオプション値（JVMオプション）にアクセスする方法はありますか？私はSpringのapplicationContest.xmlからApache Camel Contextにアクセスし、-Denv = "preprod"に基づいて私のルートまたはcamelContextを分離しています。

1熱

2答えて

SFTPとCamel。ディレクトリをに変更することはできません。無効なプライベートキー

sftp経由でftpサーバーに接続する必要があります。私はftpとftpsを介してラクダとうまく接続しました。 public static RouteBuilder getRouteBuilderSFTPS() { return new RouteBuilder() { public void configure() { from("sftp://666.

3熱

2答えて

私は次のようなコードを使用してルートを駆動するのActiveMQを呼び出すためのApacheキャメルを使用してのApache ServiceMixの上に配備Webサービス持ってActiveMQのトランスポートと接続スレッド

ハンギング：呼び出しが正常に動作しますが、いくつかの後 context.createProducerTemplate().sendBody("activemq:startComplex", xml); を私のLinuxマシン上のファイル記述子の制限が当たった時。リソースは、一束（数千）のActiveMQスレッドによって消費されます。 JMXコンソールの下に、私は次のようなスレッドの多くを見るこ

2熱

1答えて

Apache CamelはApache Commonsパイプラインを置き換えますか

私は、複数のステージを移動する際に、一連の変換とデータのフィルタを含む並列化されたデータ処理システムを実装しています。私はApache Commons Pipelineプロジェクトがこの要件に適していると認識していますが、Apache Camelはその機能のスーパーセットを提供しているようです。 CamelはCommons Pipelineを置き換えますか？

1熱

1答えて

webserviceとcxfおよびguiceとの接触時のエラー500

私はcfx 2.5.1とguice 2.0を使用しています。 Iは、WS @WebService(targetNamespace="http://com.example.firstapp/") public interface IWSEchoService { @WebMethod(operationName="echoService") String echoServi

2熱

1答えて

WebSphere Camel JMS、spring、taskExecutor、haningingスレッド

私はCamelとWebSphereを統合しようとしています。一つのことを除いて、うまくいきます。このシナリオは、 JMS（WMQ） - >ルーティング/変換 - > BEAN（JPA（OpenJPA1.2/DB2）コミットを行います）のようになります。差し込むことができるようにトランザクションマネージャとmangaedスレッドWAS、私はラクダでのTaskExecutorとしてワークマネージャ