В Azure IOThub используется компонент Camel, висящий на client.open();

Question

У меня есть полевой шлюз, который собирает данные с некоторых устройств, и я пытаюсь отправить эти данные в IOThub. Шлюз находится в Camel, поэтому я должен сделать отправку данных в IOThub как компонент. Я добавил следующее в методе конечных точек старта()

 connString= "xxxxxxxx"; 
     protocol = IotHubClientProtocol.AMQPS; 
     System.out.println("In start2"); 
     client = new DeviceClient(connString, protocol); 
     System.out.println("In start3"); 
     client.open(); 
     System.out.println("In start4"); 

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

Message msg = new Message(payloadBytes); 
    Object lockobj = new Object(); 
    EventCallback callback = new EventCallback();   
    client.sendEventAsync(msg, callback, lockobj); 

Когда я бегу тестовый маршрут (с приветственным мировым сообщением), данные поступают на Iothub, но он показывает предупреждение ниже. Но когда я запускаю шлюз, он зависает на client.open() ... Только в start2 и In start3 печатаются. В start4 нет.

Sep 15, 2016 7:06:10 AM org.apache.qpid.proton.engine.impl.ssl.SslEngineFacadeFactory getClass 
WARNING: unable to load org.bouncycastle.openssl.PEMReader 
Sep 15, 2016 7:06:10 AM org.apache.qpid.proton.engine.impl.ssl.SslEngineFacadeFactory getClass 
WARNING: unable to load org.bouncycastle.openssl.PasswordFinder 
Sep 15, 2016 7:06:10 AM org.apache.qpid.proton.engine.impl.ssl.SslEngineFacadeFactory <clinit> 
WARNING: unable to load bouncycastle provider 

Я добавил client.close() в метод stop() конечной точки. Возможно, я размещаю открытые и закрытые в неправильных местах. Пожалуйста помоги!!

Answer 1

я должен был добавить следующие зависимости

<dependency> 
<groupId>com.microsoft.azure.iot</groupId> 
<artifactId>proton-j-azure-iot</artifactId> 
<version>0.12.2</version> 
</dependency> 
<!-- https://mvnrepository.com/artifact/commons-codec/commons-codec --> 
<dependency> 
<groupId>commons-codec</groupId> 
<artifactId>commons-codec</artifactId> 
<version>1.10</version> 
</dependency>