Issue with RabbitMQSource exception during nextDelivery

[kalondar]

Consumer reports an error during consuming rabbit messages, but the exception handling mechanism went into infinite recursion loop.

2018-03-06 12:48:45,930 ERROR org.apache.flume.source.rabbitmq.RabbitMQSource: sourceName - Exception thrown while pulling from queue. java.lang.InterruptedException at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.reportInterruptAfterWait(AbstractQueuedSynchronizer.java:2014) at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2048) at java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442) at com.rabbitmq.client.QueueingConsumer.nextDelivery(QueueingConsumer.java:214) at org.apache.flume.source.rabbitmq.RabbitMQSource.doProcess(RabbitMQSource.java:117) at org.apache.flume.source.AbstractPollableSource.process(AbstractPollableSource.java:58) at org.apache.flume.source.PollableSourceRunner$PollingRunner.run(PollableSourceRunner.java:137) at java.lang.Thread.run(Thread.java:745) 2018-03-06 12:48:45,932 WARN org.apache.flume.source.rabbitmq.RabbitMQSource: sourceName - Closing RabbitMQ connection and channel due to exception. 2018-03-06 12:48:46,943 ERROR org.apache.flume.node.PollingPropertiesFileConfigurationProvider: Unhandled error java.lang.StackOverflowError at org.apache.flume.source.BasicSourceSemantics.stop(BasicSourceSemantics.java:96) at org.apache.flume.source.rabbitmq.RabbitMQSource.doStop(RabbitMQSource.java:178) at org.apache.flume.source.BasicSourceSemantics.stop(BasicSourceSemantics.java:96) at org.apache.flume.source.rabbitmq.RabbitMQSource.doStop(RabbitMQSource.java:178) at org.apache.flume.source.BasicSourceSemantics.stop(BasicSourceSemantics.java:96) at org.apache.flume.source.rabbitmq.RabbitMQSource.doStop(RabbitMQSource.java:178) at org.apache.flume.source.BasicSourceSemantics.stop(BasicSourceSemantics.java:96) at org.apache.flume.source.rabbitmq.RabbitMQSource.doStop(RabbitMQSource.java:178) at org.apache.flume.source.BasicSourceSemantics.stop(BasicSourceSemantics.java:96) at org.apache.flume.source.rabbitmq.RabbitMQSource.doStop(RabbitMQSource.java:178) ...

Recursion look is caused by below code: (RabbitMQSource.java line 176)

@Override protected void doStop() throws FlumeException { RabbitMQUtil.close(_Connection, _Channel); super.stop(); }

Where super.stop(); will call doStop internally.