Camel IgniteMessagingComponent - PullRequest
Новая
       40

Camel IgniteMessagingComponent

0 голосов
/ 11 октября 2019

Здравствуйте. Я пытаюсь использовать компонент обмена сообщениями о воспламенении верблюда, чтобы создавать и потреблять сообщения через кластер.

Пожалуйста, найдите образец кода: 

IgniteMessagingComponent igniteMessagingComponent = IgniteMessagingComponent.fromConfiguration(igniteConfiguration);
igniteMessagingComponent.setCamelContext(camelContext);
igniteMessagingComponent.setIgniteConfiguration(igniteConfiguration);
igniteMessagingComponent.setIgnite(ignite);
igniteMessagingComponent.setIgniteConfiguration(igniteConfiguration);

Endpoint enp = igniteMessagingComponent.createEndpoint("ignite-messaging:topic?Topic=testtopicname&SendMode=ORDERED&Timeout=30000");

producerTemplate.sendBody(enp,"Test");

Я получаю сообщение об ошибке ниже: java.lang.IllegalArgumentException: CamelContext must be specified on: Message[]

Пожалуйста, укажите, что я пропустил.

1 Ответ

0 голосов
/ 15 октября 2019

Решил, что это была проблема с настройкой, так как я запустил конечную точку моего подписчика на сообщения верблюдов. После явной настройки CamelContext для конечной точки он успешно работает.

Пример кода: 

    **IgniteMessagingComponent igniteMessagingComponent= 
    IgniteMessagingComponent.fromConfiguration(igniteConfiguration);
    igniteMessagingComponent.setIgnite(ignite);
    Map<String,Object> parameters = new HashMap();
    IgniteMessagingEndpoint psenp = new IgniteMessagingEndpoint("ignite-messaging:", "topic1", parameters,igniteMessagingComponent);
psenp.setCamelContext(camelContext);
    from(psenp).process(processor).end();**
...