Azure Service Bus Java: AMQP prek WebSockets s posrednikom

Sodobni javanski odjemalec za sporočila Azure Service Bus uporablja AMQP. Njegov graditelj zahteva AMQP_WEB_SOCKETS, kadar je nastavljen posrednik.

Z azure-messaging-servicebus 7.18.0 pošiljatelja zgradite takole:

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();

Spremenljivke računa se preverijo pri posredniku, ki sprejema Basic. Niz za povezavo in ime čakalne vrste še vedno določata vir Service Bus. Ohranite ustvarjenega pošiljatelja ves predvideni čas njegovega delovanja in ga zaprite, ko aplikacija konča z njim.

Tu uporabite com.azure.core.amqp.ProxyOptions. Sklad HTTP v Azure ima drug razred možnosti posrednika s podobnim imenom; to ni vrsta, ki jo sprejema ta graditelj.

To nastavi povezavo za sporočila. Aplikacija, ki uporablja samostojno ustvarjene poverilnice identitete, bo morda morala nastaviti tudi prenos HTTP žetona teh poverilnic.

Stari primeri za Azure SDK 0.9 se nanašajo na drugo generacijo odjemalca. Ne sklepajte, da njegove konfiguracijske konstante ali splošne lastnosti HTTP opisujejo sodobnega graditelja AMQP.