Azure Service Bus Java: korištenje AMQP-a preko WebSocketa uz proxy

Savremeni Java klijent za razmjenu poruka Azure Service Busa koristi AMQP. Njegov graditelj zahtijeva AMQP_WEB_SOCKETS kada je konfiguriran proxy.

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

Varijable računa provjeravaju se kod proxyja koji prihvata Basic. Niz za povezivanje i naziv reda i dalje identificiraju Service Bus resurs. Zadržite dobijenog pošiljaoca tokom predviđenog vijeka trajanja i zatvorite ga kada aplikacija završi s njim.

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

Ovo konfigurira vezu za razmjenu poruka. Aplikacija koja koristi samostalno kreirane vjerodajnice identiteta možda će morati konfigurirati i HTTP transport tokena tih vjerodajnica.

Stari primjeri za Azure SDK 0.9 odnose se na drugu generaciju klijenta. Nemojte zaključivati da njegove konstante konfiguracije ili opća HTTP svojstva opisuju savremeni AMQP graditelj.