public Class<?> getInputType() {
        return inputType;
    }
Returns the input type of the stream that is to be processed
spring-xd-reactor/src/main/java/org/springframework/xd/reactor/AbstractReactorMessageHandler.java