[
https://issues.apache.org/jira/browse/ARTEMIS-3308?focusedWorklogId=667541&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-667541
]
ASF GitHub Bot logged work on ARTEMIS-3308:
-------------------------------------------
Author: ASF GitHub Bot
Created on: 20/Oct/21 08:43
Start Date: 20/Oct/21 08:43
Worklog Time Spent: 10m
Work Description: gtully commented on pull request #3802:
URL: https://github.com/apache/activemq-artemis/pull/3802#issuecomment-947454614
the bridge does handle large messages, but the consumer is local and the
producer is remote, so the large message is present for the producers.
with federation, the consumer is remote, so the core client needs to deal
with the large message chunks, prepare a server large message and then route.
good thinking though :-)
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: gitbox-unsubscr...@activemq.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
Issue Time Tracking
-------------------
Worklog Id: (was: 667541)
Time Spent: 40m (was: 0.5h)
> Federated queue will not move large messages
> --------------------------------------------
>
> Key: ARTEMIS-3308
> URL: https://issues.apache.org/jira/browse/ARTEMIS-3308
> Project: ActiveMQ Artemis
> Issue Type: Bug
> Components: Broker, Federation
> Affects Versions: 2.17.0
> Environment: Windows 10 Pro (jdk 1.8 oracle last) artemis 2.17.0
> Reporter: Alexander Andreevich Revkov
> Assignee: Gary Tully
> Priority: Major
> Time Spent: 40m
> Remaining Estimate: 0h
>
> Hello. I'am create two artemis broker:
> artemis01:
> {code:java}
> artemis create --max-hops=1 artemis01{code}
> artemis02:
> {code:java}
> artemis create --max-hops=1 --port-offset=10 artemis02{code}
> user: artemis
> password: artemis
>
> In artemis01/etc/broker.xml i add:
>
> {code:java}
> <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>{code}
> then run both brokers.
> I send large message to artemis02:
> {code:java}
> artemis producer --url tcp://localhost:61626 --text-size 8000000
> --destination TEST.FEDERATED --message-count 1 --user artemis --password
> artemis{code}
> And then try get it from artemis01:
> {code:java}
> artemis consumer --url tcp://localhost:61616 --destination TEST.FEDERATED
> --message-count 1 --user artemis --password artemis{code}
> But i can't received message. Consumer stuck it loop. And artemis01 write in
> logs many NPE:
> {code:java}
> ***** 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
> {code}
>
> I see some source code and find what NPE occurs in CoreMessage.java class at
> 717 line because buffer is NULL:
> {code:java}
> buffer.setIndex(0, 0);{code}
> Not large messages works fine. Please fix it.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
