Uploaded image for project: 'AMQ Broker'
  1. AMQ Broker
  2. ENTMQBR-5618

Federation does not work with large messages

    XMLWordPrintable

Details

    Description

      When trying to send a large message over federated address the message never gets sent. The following message can be seen in the broker log file:

      [Thread-2 (ActiveMQ-server-org.apache.activemq.artemis.core.server.impl.ActiveMQServerImpl$6@4470f8a6)] 16:10:27,660 TRACE [org.apache.activemq.artemis.core.server.impl.ServerConsumerImpl] ServerConsumerImpl$LargeMessageDeliverer[ref=[Reference[25]:RELIABLE:LargeServerMessage[messageID=25,durable=true,userID=070e8b6c-2dca-11ec-b96a-a860b6278e8f,priority=4, timestamp=Fri Oct 15 16:10:26 IST 2021,expiration=0, durable=true, address=testFederatedQueueRemoteConsumeUpstream, properties=TypedProperties[_AMQ_GROUP_ID=groupA,__AMQ_CID=06c1caed-2dca-11ec-b96a-a860b6278e8f,_AMQ_ROUTING_TYPE=1,_AMQ_LARGE_SIZE=20971525]]@1092615761]]::FlowControl::delivery largeMessage interrupting as there are no more credits, available=-78504
      [Thread-1 (ActiveMQ-server-org.apache.activemq.artemis.core.server.impl.ActiveMQServerImpl$6@4470f8a6)] 16:10:27,660 TRACE [org.apache.activemq.artemis.core.server.impl.ServerConsumerImpl] ServerConsumerImpl::ServerConsumerImpl [id=0, filter=null, binding=LocalQueueBinding [address=testFederatedQueueRemoteConsumeUpstream, queue=QueueImpl[name=testFederatedQueueRemoteConsumeUpstream, postOffice=PostOfficeImpl [server=ActiveMQServerImpl::name=localhost], temp=false]@350226fe, filter=null, name=testFederatedQueueRemoteConsumeUpstream, clusterName=testFederatedQueueRemoteConsumeUpstream0689a3e4-2dca-11ec-b96a-a860b6278e8f]] Preparing Cancelling list for me
      

      Attachments

        Activity

          People

            gtully@redhat.com Gary Tully
            rhn-support-toross Tom Ross
            Roman Vais Roman Vais
            Votes:
            0 Vote for this issue
            Watchers:
            4 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved: