Uso de Azure Service Bus con JMS

Este artículo se aplica a: ✔️ Versión 4.14.0 ✔️ versión 5.8.0

En este artículo se describe cómo usar Azure Service Bus con la API de JMS integrada en el marco de Spring JMS.

Debe proporcionar una cadena de conexión de Azure Service Bus, que se analiza en el nombre de usuario de inicio de sesión, la contraseña y el URI remoto para el agente AMQP.

Configuración de dependencias

Agregue las siguientes dependencias si desea migrar la aplicación Spring JMS para usar Azure Service Bus.

<dependency>
    <groupId>com.azure.spring</groupId>
    <artifactId>spring-cloud-azure-starter-servicebus-jms</artifactId>
</dependency>

Configuración

En la tabla siguiente se describen las propiedades configurables al usar la compatibilidad con Spring JMS:

Propiedad	Descripción
spring.jms.servicebus.connection-string	La cadena de conexión de Azure Service Bus, para cuando quiera proporcionar directamente el cadena de conexión.
spring.jms.servicebus.topic-client-id	Identificador de cliente de JMS. Sólo funciona para el topicJmsListenerContainerFactory bean.
spring.jms.servicebus.enabled	Valor que indica si se va a habilitar la configuración automática de JMS de Servive Bus. El valor predeterminado es true.
spring.jms.servicebus.idle-timeout	La duración del tiempo de espera de inactividad de la conexión que indica cuánto tiempo espera que el cliente de Service Bus mantenga activa una conexión cuando no se entregue ningún mensaje. El valor predeterminado es 2m.
spring.jms.servicebus.pricing-tier	Nivel de precio de Azure Service Bus. Los valores admitidos son premium y estándar. El nivel Premium usa Java Message Service (JMS) 2.0, mientras que el nivel estándar usa JMS 1.1 para interactuar con Azure Service Bus.
spring.jms.servicebus.listener.reply-pub-sub-domain	Valor que indica si el tipo de destino de respuesta es un tema. Sólo funciona para el topicJmsListenerContainerFactory bean.
spring.jms.servicebus.listener.phase	Fase en la que se debe iniciar y detener este contenedor.
spring.jms.servicebus.listener.reply-qos-settings	Configura el objeto QosSettings que se va a usar al enviar una respuesta.
spring.jms.servicebus.listener.subscription-durable	Valor que indica si se debe hacer que la suscripción sea duradera. Sólo funciona para el topicJmsListenerContainerFactory bean. El valor predeterminado es true.
spring.jms.servicebus.listener.subscription-shared	Valor que indica si se va a compartir la suscripción. Sólo funciona para el topicJmsListenerContainerFactory bean.
spring.jms.servicebus.pool.block-if-full	Valor que indica si se va a bloquear cuando se solicita una conexión y el grupo está lleno. Establézcalo en false para iniciar en JMSException su lugar.
spring.jms.servicebus.pool.block-if-full-timeout	El período de bloqueo antes de iniciar una excepción si el grupo sigue lleno.
spring.jms.servicebus.pool.enabled	Valor que indica si se debe crear un JmsPoolConnectionFactory , en lugar de un objeto normal ConnectionFactory.
spring.jms.servicebus.pool.idle-timeout	Tiempo de espera de inactividad del grupo de conexiones.
spring.jms.servicebus.pool.max-connections	Número máximo de conexiones agrupadas.
spring.jms.servicebus.pool.max-sessions-per-connection	Número máximo de sesiones agrupadas por conexión en el grupo.
spring.jms.servicebus.pool.time-between-expiration-check	El tiempo de suspensión entre las ejecuciones del subproceso de expulsión de conexión inactiva. Cuando es negativo, no se ejecuta ningún subproceso de expulsión de conexión inactiva.
spring.jms.servicebus.pool.use-anonymous-producers	Valor que indica si se va a usar solo una instancia anónima MessageProducer . Establézcalo en false para crear uno MessageProducer cada vez que sea necesario.
spring.jms.servicebus.prefetch-policy.all	Valor de reserva de la opción de captura previa en este espacio de nombres de Service Bus. El valor predeterminado es 0.
spring.jms.servicebus.prefetch-policy.durable-topic-prefetch	Número de captura previa para el tema duradero. El valor predeterminado es 0.
spring.jms.servicebus.prefetch-policy.queue-browser-prefetch	Número de captura previa para el explorador de colas. El valor predeterminado es 0.
spring.jms.servicebus.prefetch-policy.queue-prefetch	Número de captura previa para la cola. El valor predeterminado es 0.
spring.jms.servicebus.prefetch-policy.topic-prefetch	Número de captura previa del tema. El valor predeterminado es 0.

Nota:

Se omite la configuración general de Spring JMS para abreviar.

Para obtener más información, consulte documento de Spring JMS.

Uso básico

Uso de la cadena de conexión de Service Bus

La manera más sencilla de conectarse a la aplicación Service Bus para Spring JMS es con el cadena de conexión.

Agregue las siguientes propiedades y es bueno ir.

spring:
  jms:
    servicebus:
      connection-string: ${AZURE_SERVICEBUS_CONNECTION_STRING}
      pricing-tier: ${PRICING_TIER}

Nota:

El valor predeterminado habilitado ConnectionFactory es CachingConnectionFactory, que agrega Session almacenamiento en caché, así como MessageProducer almacenamiento en caché. Si desea activar la característica de agrupación de conexiones de JmsPoolConnectionFactory, establezca en truespring.jms.servicebus.pool.enabled . Puede encontrar otras opciones de configuración de agrupación (propiedades con prefijo spring.jms.servicebus.pool.) en la sección Configuración .

Ejemplos

Para más información, consulte el repositorio azure-spring-boot-samples en GitHub.