RabbitMQ Javaクライアント：コンシューマのhandleDelivery（）メソッドの内部でRuntimeExceptionがスローされるとどうなりますか？

Question

RabbitMQ JavaクライアントのConsumerインターフェイスには、handleException()メソッドのようなものはありません。

RuntimeExceptionが投げ込まれた結果はどうですか？Consumer.handleDelivery()？

例外が何らかの形で記録され、消費者が将来の配送のために作業を続けると予想できますが、わかりません。

Answer 1

例外を処理しない場合、channelは終了します。

autoAck = falseとすると、メッセージは再度キューに入れられます。

消費中にエラーを処理することは、常に良い習慣です。

ところで、それはあなたが使用できる例外ハンドラが存在する：

ConnectionFactory factory = new ConnectionFactory(); 
factory.setHost("localhost"); 
factory.setPort(5672); 
final ExceptionHandler eh = new DefaultExceptionHandler() { 
    @Override 
    public void handleConsumerException(Channel channel, Throwable exception, Consumer consumer, String consumerTag, String methodName) { 
     System.out.println(" - Error raised by: " + channel.getChannelNumber()); 
    } 
}; 
factory.setExceptionHandler(eh); 

final Connection connection = factory.newConnection(); 
final Channel channel = connection.createChannel(); 


channel.queueDeclare("my_queue",true,false,false,null); 
channel.basicConsume("my_queue", true, new DefaultConsumer(channel) { 
    @Override 
    public void handleDelivery(String consumerTag, Envelope envelope, AMQP.BasicProperties properties, byte[] body) throws IOException { 

     System.out.println("Received..."); 
     System.out.println("error:"+ Integer.parseInt("RAISE_AN_ERROR")); 

エラーハンドラにリダイレクトされ、チャネルがクローズされません。

私の側では、イベント内でエラーを常に処理する必要があります。