AsyncBaseLifeCycle.doStart() invokes only once:
                consumerExecutor.execute(new Runnable() {
                    public void run() {
                        poller = Thread.currentThread();
                        pollDeliveryChannel();
                    }
                });