protected Processor createConsumerProcessor(final Object pojo, final Method method, final Endpoint endpoint) {
BeanInfo info = new BeanInfo(getCamelContext(), method);
BeanProcessor answer = new BeanProcessor(pojo, info);
// must ensure the consumer is being executed in an unit of work so synchronization callbacks etc is invoked
CamelInternalProcessor internal = new CamelInternalProcessor(answer);
internal.addAdvice(new CamelInternalProcessor.UnitOfWorkProcessorAdvice(null));
return internal;
}
public Endpoint getEndpointInjection(Object bean, String uri, String name, String propertyName,
String injectionPointName, boolean mandatory) {