@Override
    protected void handleMessageInternal(Message<?> message) throws Exception {
        invokeProcessor(message, ringBufferProcessor);
    }
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