@Override
    public void destroy() throws Exception {
        if (ringBufferProcessor != null) {
            ringBufferProcessor.awaitAndShutdown(getStopTimeout(), TimeUnit.MILLISECONDS);
        }
        getEnvironment().shutdown();
    }
Construct a new BroadcasterMessageHandler given the reactor based Processor to delegate
processing to.

@param processor The stream based reactor processor
spring-xd-reactor/src/main/java/org/springframework/xd/reactor/BroadcasterMessageHandler.java