Azure Service Bus Java: utilizarea AMQP prin WebSockets cu un proxy

Clientul Java de mesagerie modern Azure Service Bus folosește AMQP. Constructorul său necesită AMQP_WEB_SOCKETS atunci când este configurat un proxy.

Cu azure-messaging-servicebus 7.18.0, construiți expeditorul astfel:

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

Variabilele contului se autentifică la un proxy care acceptă Basic. Șirul de conexiune și numele cozii identifică în continuare resursa Service Bus. Păstrați expeditorul pe durata de viață prevăzută și închideți-l când aplicația termină cu el.

Folosiți aici com.azure.core.amqp.ProxyOptions. Stiva HTTP a Azure are o altă clasă de opțiuni de proxy cu nume similar; nu este tipul acceptat de acest constructor.

Aceasta configurează conexiunea de mesagerie. O aplicație care folosește acreditări de identitate create independent poate avea nevoie să configureze și transportul HTTP al tokenului acelor acreditări.

Exemplele vechi pentru Azure SDK 0.9 se referă la o altă generație de client. Nu presupuneți că constantele sale de configurare sau proprietățile HTTP generale descriu constructorul AMQP modern.