Az Azure Service Bus modern Java üzenetküldő kliense AMQP-t használ. A szerkesztője AMQP_WEB_SOCKETS értéket követel meg, ha proxy van beállítva.

Az azure-messaging-servicebus 7.18.0 verzióval a küldőt így építse fel:

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

A fiók változói egy Basic hitelesítést elfogadó proxy felé hitelesítenek. A kapcsolati karakterlánc és a várólista neve továbbra is azonosítja a Service Bus erőforrást. Tartsa meg a létrehozott küldőt a tervezett élettartama alatt, és zárja le, amikor az alkalmazás végzett vele.

Itt a com.azure.core.amqp.ProxyOptions osztályt használja. Az Azure HTTP veremének van egy másik, hasonló nevű proxybeállítás-osztálya; az nem az a típus, amelyet ez a szerkesztő elfogad.

Ez állítja be az üzenetküldési kapcsolatot. Egy önállóan létrehozott identitáshitelesítő adatokat használó alkalmazásnak esetleg ezek tokenjének HTTP-szállítását is be kell állítania.

A régi Azure SDK 0.9 példák egy másik kliensgenerációra utalnak. Ne következtessen arra, hogy a konfigurációs állandói vagy általános HTTP-tulajdonságai a modern AMQP-szerkesztőt írják le.

Kapcsolódó cikkek