if (annotation != null) {
LOG.info("Creating a consumer for: " + annotation);
// lets bind this method to a listener
String injectionPointName = method.getName();
Endpoint endpoint = getEndpointInjection(annotation.uri(), annotation.name(), injectionPointName);
if (endpoint != null) {
try {
Processor processor = createConsumerProcessor(bean, method, endpoint);
LOG.info("Created processor: " + processor);
Consumer consumer = endpoint.createConsumer(processor);