Azure Service Bus Java: korišćenje AMQP-a preko WebSocketa uz proksi

Savremeni Java klijent za razmenu poruka Azure Service Busa koristi AMQP. Njegov graditelj zahteva AMQP_WEB_SOCKETS kada je konfigurisan proksi.

Uz azure-messaging-servicebus 7.18.0 pošiljaoca gradite ovako:

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

Promenljive naloga proveravaju se kod proksija koji prihvata Basic. Niz za povezivanje i naziv reda i dalje identifikuju Service Bus resurs. Zadržite dobijenog pošiljaoca tokom predviđenog životnog veka i zatvorite ga kada aplikacija završi s njim.

Ovde koristite com.azure.core.amqp.ProxyOptions. HTTP stek Azurea ima drugu klasu sličnog naziva za proksi opcije; to nije tip koji ovaj graditelj prihvata.

Ovo konfiguriše vezu za razmenu poruka. Aplikacija koja koristi samostalno kreirane akreditive identiteta možda će morati da konfiguriše i HTTP prenos tokena tih akreditiva.

Stari primeri za Azure SDK 0.9 odnose se na drugu generaciju klijenta. Nemojte zaključivati da njegove konfiguracione konstante ili opšta HTTP svojstva opisuju savremeni AMQP graditelj.