AMQP и служебная шина для реактивных сообщений с Open Liberty - PullRequest
0 голосов
/ 09 ноября 2019

Open Liberty поставляется с функцией mpReactiveMessaging-1.0, которая включает в себя соединитель Kafka.

Я хочу интегрироваться с служебной шиной Azure и использую соединитель Smallrye AMQP (версия 1.0.8).

При попытке отправить в очередь служебной шины с помощью @Outgoing -аннотации я получаю

javax.net.ssl.SSLHandshakeException: Failed to create SSL connection

, которую я заметил при отладке реализации Smallrye.

Iпросмотрел документы AMQP Proton, vert.x и Azure Service Bus, но не могу найти примеров или указаний на то, что не так с моим набором свойств конфигурации MP для работающего подключения AMQP Service Bus.

mp.messaging.outgoing.servicebus.address=xxxxxxx 
mp.messaging.outgoing.servicebus.connector=smallrye-amqp
mp.messaging.outgoing.servicebus.host=xxxxx.servicebus.windows.net
mp.messaging.outgoing.servicebus.port=5672
mp.messaging.outgoing.servicebus.username=my_saspolicyname
mp.messaging.outgoing.servicebus.password=the_saskey
mp.messaging.outgoing.servicebus.use-ssl=true
mp.messaging.outgoing.servicebus.hostname-verification-algorithm=''
mp.messaging.outgoing.servicebus.containerId=mycontainer
mp.messaging.outgoing.servicebus.amqp-use-ssl=true
...