Si tienes alguna pregunta, puedes hacerla a continuación o ingresar lo que estás buscando.
Tengo un servicio de bus old.servicebus.windows.net donde mis clientes están conectados. Estoy creando un nuevo servicio de bus con diferentes configuraciones llamado new.servicebus.windows.net. ¿Cuáles son las opciones donde puedo darles a mis clientes un nombre común y luego redirigir las solicitudes? ¿Es posible? Así, en el futuro, incluso si cambio . . . Read more
Estamos utilizando una función de Azure que se activa mediante una cola de Service Bus. El archivo host.json de nuestra función es el siguiente: { “version”: “2.0”, “extensions”: { “serviceBus”: { “prefetchCount”: 0, “autoCompleteMessages”: true, “maxAutoLockRenewalDuration”: “00:05:00”, “maxConcurrentCalls”: 16, “maxConcurrentSessions”: 2000, “maxMessages”: 1000, “sessionIdleTimeout”: “00:01:00”, “enableCrossEntityTransactions”: false } }, “logging”: . . . Read more
Quiero actualizar los valores de secreto del depósito de claves obteniendo la clave predeterminada de la aplicación de funciones y la cadena de conexión del bus de servicio mediante un script de PowerShell/CLI. Así que, ¿podría alguien ayudarme con este problema por favor?
Estoy utilizando el paquete Python Azure ServiceBus y tengo el siguiente fragmento de código: <h1>receiver.py</h1> import logging logger = logging.getLogger(“test”) def receive_message( connection_str, queue_name ) -> None: “”” Llama a la API de Azure ServiceBus para obtener el mensaje de una cola. “”” with ServiceBusClient.from_connection_string( connection_str, logging_enable=True ) as servicebus_client: . . . Read more
Tengo una aplicación Spring Boot, donde recibo un único mensaje de una sesión de cola de Azure Service Bus. El código es: @Autowired ServiceBusSessionReceiverAsyncClient apiMessageQueueIntegrator; . . . Mono<ServiceBusReceiverAsyncClient> receiverMono = apiMessageQueueIntegrator.acceptSession(sessionid); Disposable subscription = Flux.usingWhen(receiverMono, receiver -> receiver.receiveMessages(), receiver -> Mono.fromRunnable(() -> receiver.close())) .subscribe(message -> { // Process message. . . . Read more