Вам необходимо импортировать CamelContext, Exchange, ProducerTemplate и ExchangeBuilder.
import org.apache.camel.CamelContext;
import org.apache.camel.Exchange;
import org.apache.camel.ProducerTemplate;
import org.apache.camel.builder.ExchangeBuilder;
Затем необходимо создать экземпляры шаблона производителя и верблюжьего контекста. Я использую весеннюю загрузку, поэтому я могу просто вставить зависимости.
@Autowired
private ProducerTemplate producer;
@Autowired
private CamelContext camelContext;
В вашем определении метода вам нужно создать запрос на обмен с ExchangeBuilder. Здесь вы можете создать тело и добавить заголовки для обмена сообщениями.
Exchange exchangeRequest = ExchangeBuilder.anExchange(camelContext)
.withBody("Hello World!")
.withHeader("username", "jdoe")
.withHeader("password", "pass")
.build();
Затем вы можете вызвать метод send для объекта-производителя, чтобы подключиться к вашему маршруту и захватить ответ.
Exchange exchangeResponse = producer.send("direct:startRoute", exchangeRequest)