Azure Service Bus Java: uzi AMQP per WebSockets kun prokurilo

Agordu la Java-mesaĝklienton de Azure Service Bus por AMQP per WebSockets kun la prokurilaj agordoj de la AMQP-biblioteko.

La moderna Java-mesaĝkliento de Azure Service Bus uzas AMQP. Ĝia konstruilo postulas AMQP_WEB_SOCKETS kiam prokurilo estas agordita.

Kun azure-messaging-servicebus 7.18.0, konstruu la sendilon jene:

var address = new java.net.Proxy(
    java.net.Proxy.Type.HTTP,
    new java.net.InetSocketAddress("proxy.example", 8080));

var proxy = new com.azure.core.amqp.ProxyOptions(
    com.azure.core.amqp.ProxyAuthenticationType.BASIC,
    address, proxyUser, proxyPassword);

var sender = new com.azure.messaging.servicebus.ServiceBusClientBuilder()
    .connectionString(serviceBusConnectionString)
    .transportType(com.azure.core.amqp.AmqpTransportType.AMQP_WEB_SOCKETS)
    .proxyOptions(proxy)
    .sender()
    .queueName(queueName)
    .buildClient();

La kontaj variabloj aŭtentikiĝas ĉe prokurilo, kiu akceptas Basic. La konekta ĉeno kaj la atendovica nomo ankoraŭ identigas la rimedon de Service Bus. Konservu la kreitan sendilon dum ĝia celata vivodaŭro kaj fermu ĝin kiam la aplikaĵo finos kun ĝi.

Uzu com.azure.core.amqp.ProxyOptions ĉi tie. La HTTP-stako de Azure havas alian simile nomatan klason por prokurilaj opcioj; ĝi ne estas la tipo, kiun ĉi tiu konstruilo akceptas.

Ĉi tio agordas la mesaĝan konekton. Aplikaĵo, kiu uzas sendepende kreitajn identecajn akreditaĵojn, eble ankaŭ devos agordi la HTTP-transporton de la ĵetono de tiuj akreditaĵoj.

Malnovaj ekzemploj por Azure SDK 0.9 rilatas al alia klienta generacio. Ne konkludu, ke ĝiaj agordaj konstantoj aŭ ĝeneralaj HTTP-ecoj priskribas la modernan AMQP-konstruilon.

Rilataj artikoloj