@Override
        public void onComplete() {
            logger.info("Consumer completed for [" + s + "]");
        }
Returns the input type of the stream that is to be processed
spring-xd-reactor/src/main/java/org/springframework/xd/reactor/AbstractReactorMessageHandler.java