[ARTEMIS-3308] Federated queue will not move large messages

• Type: Bug
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 2.17.0
• Fix Version/s: 2.19.1, 2.20.0
• Component/s: Broker, Federation

Environment

Windows 10 Pro (jdk 1.8 oracle last) artemis 2.17.0

• Assignee: Gary Tully
• Reporter: Alexander Andreevich Revkov
• Created: 19/May/21 16:38
• Updated: 14/Feb/24 17:07
• Resolved: 20/Jan/22 14:02

Description

Hello. I'am create two artemis broker:

artemis01:

artemis create --max-hops=1  artemis01

artemis02:

artemis create --max-hops=1 --port-offset=10 artemis02

user: artemis

password: artemis

 

In artemis01/etc/broker.xml i add:

 

<connectors> 
   <connector name="artemis02-connector">tcp://localhost:61626</connector>
</connectors>
<federations> 
  <federation name="artemis01-federation" user="artemis" password="artemis"> 
    <upstream name="artemis02"> 
      <static-connectors> 
        <connector-ref>artemis02-connector</connector-ref> 
      </static-connectors> 
      <policy ref="artemis-queue-federation"/> 
    </upstream>
    <queue-policy name="artemis-queue-federation" priority-adjustment="-5" include-federated="false"> 
      <include queue-match="#" address-match="TEST.FEDERATED"/> 
    </queue-policy> 
  </federation>
</federations>

then run both brokers.

I send large message to artemis02:

artemis producer --url tcp://localhost:61626 --text-size 8000000 --destination TEST.FEDERATED --message-count 1 --user artemis --password artemis

And then try get it from artemis01:

artemis consumer --url tcp://localhost:61616 --destination TEST.FEDERATED --message-count 1 --user artemis --password artemis

But i can't received message. Consumer stuck it loop. And artemis01 write in logs many NPE:

***** durable queues TEST.FEDERATED:
- queueID=30 address:TEST.FEDERATED name:TEST.FEDERATED filter:null
***** non durable for TEST.FEDERATED:
..................................................
, direct: true, rejectDuplicates: true
2021-05-19 19:27:18,001 DEBUG [org.apache.activemq.artemis.core.server.plugin.impl] AMQ843017: onMessageRouteError message: ClientLargeMessageImpl[messageID=1518976, durable=true, address=TEST.FEDERATED::TEST.FEDERATED,userID=50cb6a04-b8bd-11eb-85ab-00155d7523cb,properties=TypedProperties[__AMQ_CID=50bf3501-b8bd-11eb-85ab-00155d7523cb,_AMQ_ROUTING_TYPE=1,count=0,_AMQ_LARGE_SIZE=16014077,ThreadSent=Producer ActiveMQQueue[TEST.FEDERATED], thread=0]], with context: RoutingContextImpl(Address=null, routingType=null, PreviousAddress=null previousRoute:null, reusable=false, version=0)
..................................................
***** durable queues TEST.FEDERATED:
- queueID=30 address:TEST.FEDERATED name:TEST.FEDERATED filter:null
***** non durable for TEST.FEDERATED:
..................................................
, direct: true, rejectDuplicates: true
2021-05-19 19:27:18,002 INFO [org.apache.activemq.artemis.core.server.plugin.impl] AMQ841018: error routing message with ID: 1518976, exception: java.lang.NullPointerException

 
I see some source code and find what NPE occurs in CoreMessage.java class at 717 line because buffer is NULL:

buffer.setIndex(0, 0);

Not large messages works fine. Please fix it.

Issue Links

• requires: ARTEMIS-3533 Have federation configuration respect extra url parameters from the connector-ref
• links to: GitHub Pull Request #3802