2017-01-13 21 views
2

私はJava RabbitMQ Clientを使用しています。私はメッセージ(basicPublish)を公開してから、チャンネルを閉じます。消費者、channel.basicAck投げる例外では:RabbitMQ Connection close call.close()

com.rabbitmq.client.AlreadyClosedException: connection is already closed due to connection error; cause: java.util.concurrent.RejectedExecutionException: Task [email protected]5de7c7 rejected from [email protected][Running, pool size = 5, active threads = 5, queued tasks = 0, completed tasks = 5] 

(削除channel.closeの場合)、エラーが再現されません。なぜ私はチャンネルを閉じると、接続が閉じた?

交流にメッセージを送信:

Channel channel = connection.createChannel(); 
Set<String> expectedMessages = new HashSet<>(MESSAGES_COUNT); 
for (int i = 0; i < MESSAGES_COUNT; i++) { 
    String message = Integer.toString(i); 
    channel.basicPublish(
     TEST_EXCHANGE, 
     ROUTE_KEY, 
     TEXT_PLAIN, 
     message.getBytes("UTF-8") 
    ); 
    expectedMessages.add(message); 
} 
channel.close(); 

消費者:

try { 
    channel.basicAck(deliveryTag, false); 
} catch (Exception e) { 
    log.error("Error during message handling: " + consumerTag, e); 
    channel.basicNack(deliveryTag, false, true); 
} 
+0

あなたは接続を閉じていない、あなたは多分あなたのコード内で別のエラーを持っています。 – Gabriele

+0

このような動作の理由は何でしょうか?チャンネルを閉じることはできませんか? – Dmitriy

+0

whitoutコード知るのは難しい! – Gabriele

答えて

0

問題が間違ったのConnectionFactory設定していました。 誤:正しい仕事のため

executorService = new ThreadPoolExecutor(
      properties.minThreads, properties.maxThreads, 
      properties.maxThreadIdle, TimeUnit.SECONDS, 
      new SynchronousQueue<>() 
    ); 
    connectionFactory.setSharedExecutor(executorService); 

:あなたがチャネルを閉じると

executorService = new ThreadPoolExecutor(
      properties.minThreads, properties.maxThreads, 
      properties.maxThreadIdle, TimeUnit.SECONDS, 
      new LinkedBlockingQueue<>() 
    ); 
    connectionFactory.setSharedExecutor(executorService);