Active MQ / CAMEL - Установка долговечного идентификатора клиента ⇐ JAVA

[Гость]

Я использую CachingConnectionFactory для настройки контекста ActiveMQ для Camel; и затем сам верблюда для подключения к активному mq. < /p>
Когда я запускаю свое приложение, он выбрасывает следующую ошибку: < /p>

Вызов SetClientId не поддерживается на прокси для общего соединения. Вместо этого установите свойство ClientId на SingleConnectionFactory. Lang-Java PrettyPrint-Override ">ActiveMQComponent amqComponent = new ActiveMQComponent();
ActiveMQConnectionFactory cf = new ActiveMQConnectionFactory();
cf.setBrokerURL("tcp://" + amqServer + ":" + amqPort + "?jms.watchTopicAdvisories=false");

UserCredentialsConnectionFactoryAdapter uca = new UserCredentialsConnectionFactoryAdapter();
uca.setUsername(amqUser);
uca.setPassword(amqPassword);
uca.setTargetConnectionFactory(cf);

CachingConnectionFactory ccf = new CachingConnectionFactory(uca);
ccf.setClientId(amqClientID);

amqComponent.setConnectionFactory(ccf);
amqComponent.setMaxConcurrentConsumers(1);

context.addComponent("activemq", amqComponent);

...

from("activemq:topic:" + amqFeedTopic + "?clientId=" + id + "&durableSubscriptionName=" + id + "-sub")
.id(id)
.bean(messageHandlerClass, "process")
.to("kafka:" + kafkaTopic + "?brokers=" + kafkaBootstrapServers);


Подробнее здесь: https://stackoverflow.com/questions/794 ... -client-id