問題タブ [reply]

私は、MongoDB に入り、XML ドキュメントに応答するキューに XML ドキュメントを送信する JMeter JMS ポイント ツー ポイント テストを行っています。

JMeter でテストを実行すると、リクエストが Mongo に送られ、正しく返されたことを RedHat ログで確認できます。JMeter 内ではテストが失敗し、次のメッセージが表示されます。

「返信メッセージがありません」

communication-style' ' を ' 'に設定するとRequest Only、テストに合格します。私の接続はすべて正しく、JMeter バージョン 2.11 を使用しています。

フォーラムを読んで、jmeter.properties ファイルを enable に変更しましたJMSSampler.useSecurity.properties=false。これはうまくいきませんでした。

これについてのご意見は大歓迎です。

ありがとう、

現金

ユーザーが「返信」をクリックし、結果のコメントボックスにテキストを追加し（「あなたの心はどうですか」）、「コメント」をクリックするページindex.phpを作成しました。このテキストは下のボックスに投稿されます。私が経験している問題は、[返信] ボタンが複数回クリックされた場合、テキストがコメント ボックスに入力され、[コメント] がクリックされると、テキストが下のボックス (およびデータベース) に対応する番号に入力されることです。の回。これを回避する方法がわかりません。以下のコードを参照してください - 一般的な connect.php ファイルがありますが、これを追加する必要はありません。前もって感謝します。

index.php

index2.php

css.css:

現在、私はapache camelを使用しています。私のアプリケーションでは、2 つのルートがあります。

最初のルートには、入力としての HTTP、いくつかのプロセス、および WMQ が含まれます (この WMQ は書き込み専用に使用されます)。

2 番目のルートには、from タグといくつかのマッピング プロセス用の WMQ (読み取り専用に使用) があります。

私がやりたいことは、2 番目のルートの WMQ から最初のルートの HTTP に応答を送信することです。

その方法は？

これまでの私の構成は次のとおりです。

前もって感謝します。

現在、Websphere MQ から読み書きするために apache camel を使用しています。

私のプロジェクトでは、2 つの WMQ があります。1 つは書き込み用 (Queue.W)、もう 1 つは読み取り用 (Queue.R) です。アプリを構成する方法は次のとおりです。

私がやりたいことは、最初のフローで読み取りキュー (Queue.R) からの応答を http エンドポイントに送り返すことです。

それを実現するために、InOut パターンを使用しようとしました。ただし、InOut パターンは、同じエンドポイントがある場合にのみ機能したようです (たとえば、最初のフローの送信が Queue.W の場合、2 番目のフローの受信も Queue.W である必要があります)。しかし、書き込み用と読み取り用に別の WMQ を使用したため、動作させることができません。

私の構成でわかるように、inOnlyパターンをQueue.Wに追加してから追加することで解決しようとしました

その後、2 番目のフローで、追加して Queue.R からの応答を送り返そうとしました。

しかし、それもうまくいきませんでした！さらに、そうした後、次のエラーが発生しました。

org.apache.camel.component.direct.DirectConsumerNotAvailableException: エンドポイントで使用できるコンシューマーがありません: エンドポイント[direct://result]。Exchange[メッセージ: http://security.fraport.de/zks-eap/uebermittleAusweisdatenurn:uuid:ID-FRA000000085404-64407-1402571267690-0-2esbp://services.fraport.de/lsmh/mobakoesbp://services.fraport.de/lsmh/zks-eapesbp://services.fraport.de/ lsmh/mobako12.1] org.apache.camel.component.direct.DirectProducer.process(DirectProducer.java:47) org.apache.camel.processor.SendProcessor.process(SendProcessor.java:113) org.apache .camel.management.InstrumentationProcessor.process(InstrumentationProcessor.java:72) org.apache.camel.processor.RedeliveryErrorHandler.process(RedeliveryErrorHandler.java:398) org.apache.camel.processor.CamelInternalProcessor.process(CamelInternalProcessor.java) :191) org.apache.camel.processor.Pipeline.process(Pipeline.java:118) で org.apache.camel.processor.Pipeline.process(Pipeline.java:80) で org.apache.camel.processor. CamelInternalProcessor。プロセス (CamelInternalProcessor.java:191) で org.apache.camel.component.jetty.CamelContinuationServlet.service(CamelContinuationServlet.java:149) で javax.servlet.http.HttpServlet.service(HttpServlet.java:668) で org.eclipse .jetty.servlet.ServletHolder.handle(ServletHolder.java:684) org.eclipse.jetty.servlet.ServletHandler$CachedChain.doFilter(ServletHandler.java:1496) org.eclipse.jetty.servlets.MultiPartFilter.doFilter(MultiPartFilter) .java:136) org.apache.camel.component.jetty.CamelFilterWrapper.doFilter(CamelFilterWrapper.java:44) で org.eclipse.jetty.servlet.ServletHandler$CachedChain.doFilter(ServletHandler.java:1467) で org. org.eclipse.jetty.server.handler.ContextHandler.doHandle(ContextHandler.java:) の eclipse.jetty.servlet.ServletHandler.doHandle(ServletHandler.java:499)1086) org.eclipse.jetty.servlet.ServletHandler.doScope(ServletHandler.java:428) で org.eclipse.jetty.server.handler.ContextHandler.doScope(ContextHandler.java:1020) で org.eclipse.jetty.server .handler.ScopedHandler.handle(ScopedHandler.java:135) の org.eclipse.jetty.server.handler.HandlerWrapper.handle(HandlerWrapper.java:116) の org.eclipse.jetty.server.Server.handle(Server.java) :370) org.eclipse.jetty.server.AbstractHttpConnection.handleRequest(AbstractHttpConnection.java:494) で org.eclipse.jetty.server.AbstractHttpConnection.headerComplete(AbstractHttpConnection.java:971) で org.eclipse.jetty.server. AbstractHttpConnection$RequestHandler.headerComplete(AbstractHttpConnection.java:1033) at org.eclipse.jetty.http.HttpParser.parseNext(HttpParser.java:644) at org.eclipse.jetty.http.HttpParser.parseAvailable(HttpParser.java:235) at org.eclipse.jetty.server.AsyncHttpConnection.handle(AsyncHttpConnection.java:82) at org.eclipse.jetty.io.nio.SelectChannelEndPoint.handle(SelectChannelEndPoint.java:667) org.eclipse.jetty.io.nio.SelectChannelEndPoint$1.run(SelectChannelEndPoint.java:52) で org.eclipse.jetty.util.thread.QueuedThreadPool.runJob(QueuedThreadPool.java:608) で org.eclipse.jetty. java.lang.Thread.run の util.thread.QueuedThreadPool$3.run(QueuedThreadPool.java:543) (不明なソース)52) org.eclipse.jetty.util.thread.QueuedThreadPool.runJob(QueuedThreadPool.java:608) で org.eclipse.jetty.util.thread.QueuedThreadPool$3.run(QueuedThreadPool.java:543) で java.lang. Thread.run(不明なソース)52) org.eclipse.jetty.util.thread.QueuedThreadPool.runJob(QueuedThreadPool.java:608) で org.eclipse.jetty.util.thread.QueuedThreadPool$3.run(QueuedThreadPool.java:543) で java.lang. Thread.run(不明なソース)

私の問題を解決する方法について何か提案はありますか? 本当にありがとう。あなたの助けはとても感謝しています!

現在、Apache Camel を使用しています。私がやりたいのは、リクエスト応答を構成することです。これが私のルートです：

これらの reoutes では、入力に使用される http エンドポイントと、書き込み用に 1 つ、読み取り用に 1 つの 2 つの wmq エンドポイントがあることがわかります。

私が欲しいのは：

1. http からリクエストを受け取り、それを処理し、リクエスト メッセージを Queue.Write wmq に書き込みます。
2. 要求メッセージが Queue.Write wmq に書き込まれた後、Queue.Read wmq から応答を読み取り、それを最初のルートに送り返し、データ変換を行いたいと考えています。
3. すべての処理が完了したら、応答を http エンドポイントに送り返したいと思います。

Apache Camel から次のドキュメントを読み、提案どおりに実行しようとしました。

1. http://camel.apache.org/request-reply.html
2. http://camel.apache.org/jms.html
3. その他の関連リソース

しかし、何もうまくいきません。

1. リクエストとリプライに別のエンドポイントを使用したため、InOut 交換パターンが機能しません
2. 以下を追加して、Queue.Read エンドポイントで JMSCorrelationID と JMSReplyTo を宣言しようとしました。

しかし、それも機能しませんでした。さらに、次のエラーが継続的に発生しました。

org.apache.camel.ExchangeTimedOutException: OUT メッセージは次の時間内に受信されませんでした: 20000 ミリ秒の期限内に、correlationID を持つ応答メッセージ: cid が受信されませんでした。Exchange[メッセージ: http://security.fraport.de/zks-eap/uebermittleAusweisdatenurn:uuid:ID-FRA000000085404-55438-1402901836300-0-2esbp://services.fraport.de/lsmh/mobakoesbp://services.fraport.de/lsmh/zks-eapesbp://services.fraport.de/ lsmh/mobako11.2] org.apache.camel.component.jms.reply.ReplyManagerSupport.processReply(ReplyManagerSupport.java:133) org.apache.camel.component.jms.reply.TemporaryQueueReplyHandler.onTimeout(TemporaryQueueReplyHandler.java: 61) org.apache.camel.component.jms.reply.CorrelationTimeoutMap.onEviction(CorrelationTimeoutMap.java:53) で org.apache.camel.component.jms.reply.CorrelationTimeoutMap.onEviction(CorrelationTimeoutMap.java:30) で org .apache.camel.support.DefaultTimeoutMap.purge(DefaultTimeoutMap.java:212) at org.apache.camel.support.DefaultTimeoutMap.run(DefaultTimeoutMap.java:162) at java.util.concurrent.Executors$RunnableAdapter.java.util.concurrent.FutureTask.runAndReset (不明なソース) で java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$301 で (不明なソース) を呼び出します (不明なソース) java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(Unknown) でソース) java.util.concurrent.ThreadPoolExecutor.runWorker (不明なソース) で java.util.concurrent.ThreadPoolExecutor$Worker.run (不明なソース) で java.lang.Thread.run (不明なソース)ThreadPoolExecutor$Worker.run(不明なソース) at java.lang.Thread.run(不明なソース)ThreadPoolExecutor$Worker.run(不明なソース) at java.lang.Thread.run(不明なソース)

参考までに、私は Mule ESB でこれを実行し、以下を使用して正常に実装しようとしました。

と追加

2 番目のフローでの Queue.Read の後。

しかし、今のところ、Apache Camel で行う必要があります。Camelでこれを行う方法はありますか? または、私の問題を解決する方法について何か考えがありますか (wmq エンドポイントを変更せずに)。ご協力いただきありがとうございます。