@Override
    @SuppressWarnings("rawtypes")
    public void destroy() throws Exception {
        for (RingBufferProcessor ringBufferProcessor : reactiveProcessorMap.values()) {
            ringBufferProcessor.awaitAndShutdown(getStopTimeout(), TimeUnit.MILLISECONDS);
        }
        getEnvironment().shutdown();
    }
Construct a new MessageHandler given the reactor based Processor to delegate
processing to and a partition expression.

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