AmqpProvider - トランスポート接続をリモートで閉じた

Question

私は、ApacheのcamelとQpidライブラリと並んでServiceMixを使用して、リモートノードに接続してJMSキューを取得しています。

マイビーンの設定は::このBeanを使用して

<bean id="amqp" class="org.apache.camel.component.amqp.AMQPComponent"> 
    <property name="connectionFactory"> 
     <bean class="org.apache.qpid.jms.JmsConnectionFactory"> 
      <property name="remoteURI" value="amqp://esesslxjks.se:9443" /> 
     </bean> 
    </property> 
    </bean> 

<camelContext xmlns="http://camel.apache.org/schema/blueprint"> 
    <!-- Master Data Queue --> 
    <route> 
     <from uri="amqp:queue:///CS_output" /> 
     <log message="Copying o the output directory"/> 
     <to uri="amqp:queue:///CS_input" /> 
    </route> 

である私は自分のアプリケーションを起動し、いくつかの肯定応答::

| DEBUG | mix-7.0.0/deploy | JmsProducer      | 43 - org.apache.camel.camel-core - 2.16.4 | Starting producer: Producer[amqp://queue:///CSDP_input] 
| DEBUG | mix-7.0.0/deploy | JmsConsumer      | 43 - org.apache.camel.camel-core - 2.16.4 | Starting consumer: Consumer[amqp://queue:///CSDP_output] 
| DEBUG | mix-7.0.0/deploy | BlueprintCamelContext   | 43 - org.apache.camel.camel-core - 2.16.4 | Route: route1 >>> EventDrivenConsumerRoute[Endpoint[amqp://queue:///CS_output] -> Pipeline[[Channel[Log(route1)[Copying o the output directory]], Channel[sendTo(Endpoint[amqp://queue:///CS_input])]]]] 
| DEBUG | mix-7.0.0/deploy | faultJmsMessageListenerContainer | 154 - org.apache.servicemix.bundles.spring-jms - 3.2.17.RELEASE_1 | Established shared JMS Connection 

を参照してくださいしかし、私は、下記のERROR ::

を取得します

| DEBUG | esesslxjks.se:9443] | AmqpProvider      | 226 - qpid-jms-client.jar - 0.0.0 | Transport connection remotely closed 
| DEBUG | esesslxjks.se:9443] | JmsConnection     | 226 - qpid-jms-client.jar - 0.0.0 | Async exception with no exception listener: java.io.IOException: Connection remotely closed. 
java.io.IOException: Connection remotely closed. 
    at org.apache.qpid.jms.provider.amqp.AmqpProvider$18.run(AmqpProvider.java:727)[226:qpid-jms-client.jar:0.0.0] 
    at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)[:1.8.0_121] 
    at java.util.concurrent.FutureTask.run(FutureTask.java:266)[:1.8.0_121] 
    at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:180)[:1.8.0_121] 
    at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:293)[:1.8.0_121] 
    at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)[:1.8.0_121] 
    at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)[:1.8.0_121] 
    at java.lang.Thread.run(Thread.java:745)[:1.8.0_121] 

私は現在、なぜこのようなことが起こるのかが分かりません。他にどのようなデバッグが可能ですか？どんなポインタも強く推奨されます。

Answer 1

あなたの例のように実行している春のラクダであなたのユースケースを持っていません。しかし私はあなたが私の単体テストの間に持っていたのと同じ正確なスタックトレースに遭遇しました。私が明らかにしたことは、ブローカインスタンスを明示的にクローズしようとすると、私のqpid jmsクライアントも接続をクローズしようと試みることでした。したがって、その例外をスローします。私のユースケースはあなたのものとまったく同じではないが、これが少し助けてくれることを願っています。がんばろう。