Как создать ConsumerTemplate в Apache Camel - PullRequest
Новая
       44

Как создать ConsumerTemplate в Apache Camel

0 голосов
/ 18 января 2019

У меня есть верблюжий процессор, который читает файл из каталога, используя ConsumerTemplate, как показано ниже 

@Component
public class FileReaderProcessor implements Processor {

    @Consume
    private ConsumerTemplate consumerTemplate;

    /**
     * {@inheritDoc}
     */
    @Override
    public void process(Exchange exchange) throws Exception {
        final byte[] filecontent = consumerTemplate.receiveBody(SOURCE_FILE_COMPONENT,
                byte[].class);

    }
}

Однако, когда я попробовал приведенный ниже код, он работает 

final byte[] filecontent = exchange.getContext().createConsumerTemplate().receiveBody(SOURCE_FILE_COMPONENT,
                byte[].class);

Проблема в том, что мне нужно аннотировать шаблон ConsumerTemplate и использовать его в своем коде. Пожалуйста, помогите мне использовать ConsumerTemplate с аннотацией 

@Consume
    private ConsumerTemplate consumerTemplate;
...