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

Konfigurirajte Java klijent za razmjenu poruka Azure Service Busa na AMQP preko WebSocketa i postavke proxyja iz AMQP biblioteke.

Suvremeni 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šiljatelja 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 prihvaća Basic. Niz za povezivanje i naziv reda i dalje identificiraju Service Bus resurs. Zadržite dobivenog pošiljatelja tijekom predviđenog životnog vijeka i zatvorite ga kada aplikacija završi s njim.

Ovdje upotrijebite com.azure.core.amqp.ProxyOptions. HTTP stog Azurea ima drugu klasu sličnog naziva za proxy mogućnosti; to nije tip koji ovaj graditelj prihvaća.

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

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

Povezani članci