Apache Artemis - регистрирует сбой подключения AMQ212037 и сброс подключения одноранговым узлом [code = GENERIC_EXCEPTION] - PullRequest
Новая
       90

Apache Artemis - регистрирует сбой подключения AMQ212037 и сброс подключения одноранговым узлом [code = GENERIC_EXCEPTION]

0 голосов
/ 03 августа 2020

Artemis настроен в HA, с одним главным и резервным подчиненным в разных виртуальных машинах.

Конфигурация broker.xml использует stati c параметры обнаружения и принимающие устройства, 61616 поддерживает все протоколы и AMQP .

Конфигурация аналогична этой ссылка

artemis.log (нижеприведенная проблема постоянно регистрируется) 

WARN [org.apache.activemq.artemis.core.client] AMQ212037: Connection failure to <ip-address> has been detected: readAddress(..) failed: Connection reset by peer [code=GENERIC_EXCEPTION]

Из журналов Информация об IP-адресе, похоже, один из клиентов / потребителей продвигает эту информацию.

В другом сообщении ссылка рекомендуется использовать confirmationWindowSize. Но не уверен, применимо ли это к моему случаю.

Конфигурация клиента использует Camel и клиент ActiveMQ OpenWire версии 5.13.2 для подключения: 

    <bean id="conxnFactory" class="org.apache.activemq.ActiveMQConnectionFactory">
      <property name="brokerURL" value="tcp://domain-name:port" />
    </bean>

    <bean id="pooledconxnFactory" class="org.apache.activemq.pool.PooledConnectionFactory" init-method="start" destroy-method="stop">
      <property name="maxConnections" value="5" />
      <property name="connectionFactory" ref="conxnFactory" />
    </bean>

    <bean id="config" class="org.apache.camel.component.jms.JmsConfiguration">
      <property name="connectionFactory" ref="pooledconxnFactory" />
      <property name="concurrentConsumers" value="5" />
    </bean>

    <bean id="jmsqueue" class="org.apache.activemq.camel.component.ActiveMQComponent">
      <property name="configuration" ref="config" />
    </bean>
    
    <camelContext id="camel" xmlns="http://camel.apache.org/schema/spring">
      <endpoint id="inputQueue" uri="jmsqueue:queue:dataqueue1" />
      
      <route>
        <from uri="ref:inputQueue" />
        <!-- process -->
        <to uri="ref:outputQueue"/> <!-- endpoint defined already not included in here-->
        ...
        ...

Любые вводы / идеи, почему это происходит.

...