Прочная подписка ActiveMQ

Question

Я пытаюсь установить надежного подписчика для своих сообщений, чтобы они сохранялись в теме даже после перезапуска сервера.

Но во время настройки я получаю ошибку, связанную с XML:

Вот моя конфигурация xml:

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
       xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
       xmlns:context="http://www.springframework.org/schema/context"
       xmlns:int="http://www.springframework.org/schema/integration"
       xmlns:int-jms="http://www.springframework.org/schema/integration/jms"
       xmlns:oxm="http://www.springframework.org/schema/oxm"
       xmlns:int-jme="http://www.springframework.org/schema/integration"
       xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-2.5.xsd
                http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-2.5.xsd
                http://www.springframework.org/schema/integration http://www.springframework.org/schema/integration/spring-integration.xsd
                http://www.springframework.org/schema/integration/jms http://www.springframework.org/schema/integration/jms/spring-integration-jms.xsd
                http://www.springframework.org/schema/oxm http://www.springframework.org/schema/oxm/spring-oxm-3.0.xsd">


    <!-- Component scan to find all Spring components -->
    <context:component-scan base-package="com.geekcap.springintegrationexample" />

    <bean class="org.springframework.web.servlet.mvc.annotation.AnnotationMethodHandlerAdapter">
        <property name="order" value="1" />
        <property name="messageConverters">
            <list>
                <!-- Default converters -->
                <bean class="org.springframework.http.converter.StringHttpMessageConverter"/>
                <bean class="org.springframework.http.converter.FormHttpMessageConverter"/>
                <bean class="org.springframework.http.converter.ByteArrayHttpMessageConverter" />
                <bean class="org.springframework.http.converter.xml.SourceHttpMessageConverter"/>
                <bean class="org.springframework.http.converter.BufferedImageHttpMessageConverter"/>
                <bean class="org.springframework.http.converter.json.MappingJackson2HttpMessageConverter" />
            </list>
        </property>
    </bean>

    <!-- Define a channel to communicate out to a JMS Destination -->
    <int:channel id="topicChannel"/>

    <!-- Define the ActiveMQ connection factory -->
    <bean id="connectionFactory" class="org.apache.activemq.spring.ActiveMQConnectionFactory">
        <property name="brokerURL" value="tcp://localhost:61616"/>
    </bean>

    <!--
        Define an adaptor that route topicChannel messages to the myTopic topic; the outbound-channel-adapter
        automagically fines the configured connectionFactory bean (by naming convention
      -->
    <int-jms:outbound-channel-adapter channel="topicChannel"
                                      destination-name="topic.myTopic"
                                      pub-sub-domain="true" />

    <!-- Create a channel for a listener that will consume messages-->
    <int:channel id="listenerChannel" />

    <int-jms:message-driven-channel-adapter id="messageDrivenAdapter"
                                            channel="getPayloadChannel"
                                            subscription-durable="true"
                                            durable-subscription-name="myDurableSubscription"
                                            destination-name="topic.myTopic"
                                            pub-sub-domain="true" />

    <int:service-activator input-channel="listenerChannel" ref="messageListenerImpl" method="processMessage" />

    <int:channel id="getPayloadChannel" />

    <int:service-activator input-channel="getPayloadChannel" output-channel="listenerChannel" ref="retrievePayloadServiceImpl" method="getPayload" />

</beans>

Но в message-driven-channel-adapter следующие атрибуты выдают ошибку:

Это говорит:

В этой строке найдено несколько аннотаций:

• cvc-complex-type.3.2.2: Атрибут 'subscription-durable ' не может появляться в элементе 'int-jms:message-driven-channel- adapter'.
• cvc-complex-type.3.2.2: Атрибут 'durable-subscription-name ' не может появляться в элементе 'int-jms:message-driven-channel- adapter'.

Но во многих других примерах я вижу, что атрибуты работают нормально.

• subscription-durable="true"

• durable-subscription-name="myDurableSubscription"

Тогда что может быть не так с моей конфигурацией.

РЕДАКТИРОВАТЬ: Spring Integration зависимости в POM.xml

<!-- Spring Integration -->
        <dependency>
            <groupId>org.springframework.integration</groupId>
            <artifactId>spring-integration-core</artifactId>
            <version>4.2.0.RELEASE</version>
        </dependency>
        <dependency>
            <groupId>org.springframework.integration</groupId>
            <artifactId>spring-integration-jms</artifactId>
            <version>4.2.0.RELEASE</version>
        </dependency>

РЕДАКТИРОВАТЬ:

Пожалуйста, смотрите прикрепленное изображение:

Также посмотрите мой журнал, который показывает, что целевой метод был вызван, что должно происходить, когда сообщение было использовано клиентом. Пожалуйста помоги.

Answer 1

Какую версию Spring Integration вы используете? Поддержка долговременных подписок была добавлена ​​в версии 2.1.0.RELEASE, более 4 лет назад.

Текущая версия 4.2.0. ВЫПУСК.

РЕДАКТИРОВАТЬ:

Я забыл упомянуть, что вам нужен идентификатор клиента для длительных подписок.

Вы смотрели сообщения журнала? Это кажется довольно ясным...

14: 12: 39.557 WARN [jmsIn.container-1] [org.springframework.jms.listener.DefaultMessageListenerContainer] Настройка вызова приемника прослушивателя сообщений JMS завершилась неудачно для пункта назначения. Topic://topic.demo - попытка восстановления. Причина. Невозможно создать надежного подписчика, не указав уникальный идентификатор клиента в соединении.

Добавить clientId к вашей фабрике соединений...

    <property name="clientId" value="myClient"/>