Actualizando la versión de Spring Boot está trayendo consigo una nueva versión del cliente Artemis (2.19), pero mi servidor aún utiliza la versión 2.16 (puede ser actualizada en el futuro). Actualmente tengo un problema de NPE en ActiveMQSession: if ((!subResponse.isExists() || !Objects.equals(subResponse.getAddress(), dest.getSimpleAddress()) || !Objects.equals(subResponse.getFilterString(), coreFilterString)) && !subResponse.isConfigurationManaged()) { Esto . . . Read more
Estoy intentando iniciar el oyente JMS usando jmsListenerEndpointRegistry.start(), que se detuvo usando jmsListenerEndpointRegistry.stop(). Pero parece que no se está iniciando. Cuando intento consumir los mensajes, no me permite hacerlo porque todavía está detenido. Por favor, ayúdeme a reiniciarlo usando el método start. En application.properties tengo spring.jms.listener.auto-startup=true. Usando Apache ActiveMQ (Versión-5.16.3). . . . Read more
Intento persistir mensajes de mensajería de activeMQ en una base de datos de postgres. Este primer paso fue fácil. Agregué esta CLI. /subsystem=datasources/data-source=messagingDS:add(jndi-name=”java:jboss/datasources/messagingDS”,use-java-context=true, \ use-ccm=true,connection-url=”{{ pg_db_connection_url_messaging }}”,driver-name=postgres,transaction-isolation=TRANSACTION_READ_COMMITTED,min-pool-size=0, \ max-pool-size=20,user-name={{ pg_db_user_pg }},password={{ pg_db_password_pg }},blocking-timeout-wait-millis=10000,check-valid-connection-sql=select 1,validate-on-match=true, \ valid-connection-checker-class-name=”org.jboss.jca.adapters.jdbc.extensions.postgres.PostgreSQLValidConnectionChecker”,validate-on-match=true, \ exception-sorter-class-name=”org.jboss.jca.adapters.jdbc.extensions.postgres.PostgreSQLExceptionSorter”) /subsystem=datasources/data-source=messagingDS:test-connection-in-pool /subsystem=messaging-activemq/server=default:write-attribute(name=journal-datasource, value=messagingDS) Pero quiero usar el mismo esquema de base de . . . Read more
Aquí tienes un ejemplo primitivo de un broker Artemis incorporado que envía y recibe mensajes utilizando el envío y la recepción punto a punto. Este ejemplo es autosuficiente y no requiere ninguna configuración adicional con XML u otro archivo externo. En este ejemplo se crea una nueva cola básica bajo . . . Read more
Mi servidor de MQ está construido con ActiveMQ Artemis 2.17.0. Recientemente me di cuenta de que algunos clientes se están conectando a mi ActiveMQ Artemis sin establecer un identificador y una suscripción de cliente, y están suscribiéndose a algunos temas. Sus colas se convirtieron en UUID como se muestra a . . . Read more