Normally you will just call shutdown on the connector. Is there a
particular reason that you need to interrupt it?
Thanks,
Jun
On Wed, Jan 29, 2014 at 2:07 PM, paresh shah <paresh.s...@ecofactor.com>wrote:
> We are interrupting the thread that uses the consumer connector. The
> question I had was if the LeaderFinderThread is interruptible then it is
> one that is generating the exception due to the await() call( highlighted )
>
> def shutdown(): Unit = {
> info("Shutting down")
> isRunning.set(false)
> if (isInterruptible)
> interrupt()
> shutdownLatch.await()
> info("Shutdown completed")
> }
>
> The above is invoked as a part of the
> ConsumerFetcherManager.stopConnections() in the shutdown path. In this case
> should the shutdown() method not explicitly catch the exception around the
> call to stopConnections().
>
> Please confirm if my understanding is correct.
>
> thanks
> Paresh
>
>
