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

WARN [org.apache.activemq.artemis.protocol.amqp.proton.ProtonServerSenderContext] null: java.lang.IllegalArgumentException

XMLWordPrintable

    • Icon: Bug Bug
    • Resolution: Done
    • Icon: Minor Minor
    • AMQ 7.14.0.GA
    • AMQ 7.10.1.GA
    • broker-core
    • None
    • 2
    • False
    • Hide

      None

      Show
      None
    • False
    • Hide

      Install AMQ 7.10.1. Add multicast address

       

      <address name="testTopic">
<multicast/>
</address>

       

      start consumer with command

      ./artemis consumer -destination topic://testTopic --user quickuser --password quick123+ --durable --clientID tomr --message-count 10000 --threads 15  -protocol amqp

      start prodcuer with command

      ./artemis producer --destination topic://testTopic --user quickuser --password quick123+ --message-count 10000 --message-size 1500000 --threads 15 --protocol amqp

      Wait until consumer finishes consuming messages then number of exceptions are logged in the broker's log file (see attached log file)

       

       

      Show
      Install AMQ 7.10.1. Add multicast address   <address name= "testTopic" > <multicast/> </address>   start consumer with command ./artemis consumer - destination topic://testTopic --user quickuser --password quick123+ --durable --clientID tomr --message-count 10000 --threads 15   -protocol amqp start prodcuer with command ./artemis producer --destination topic://testTopic --user quickuser --password quick123+ --message-count 10000 --message-size 1500000 --threads 15 --protocol amqp Wait until consumer finishes consuming messages then number of exceptions are logged in the broker's log file (see attached log file)    

      Closing an AMQP consumer in the middle of a large message streaming
      will make the server to log an exception:

      2022-10-20 08:55:37,603 WARN  [org.apache.activemq.artemis.protocol.amqp.proton.ProtonServerSenderContext] null: java.lang.IllegalArgumentException
	at org.apache.qpid.proton.engine.impl.SenderImpl.send(SenderImpl.java:72) [proton-j-0.33.10.redhat-00001.jar:0.33.10.redhat-00001]
	at org.apache.activemq.artemis.protocol.amqp.proton.ProtonServerSenderContext$LargeMessageDeliveryContext.deliverInitialPacket(ProtonServerSenderContext.java:686) [artemis-amqp-protocol-2.21.0.redhat-00030.jar:2.21.0.redhat-00030]
	at org.apache.activemq.artemis.protocol.amqp.proton.ProtonServerSenderContext$LargeMessageDeliveryContext.deliver(ProtonServerSenderContext.java:587) [artemis-amqp-protocol-2.21.0.redhat-00030.jar:2.21.0.redhat-00030]
	at org.apache.activemq.artemis.protocol.amqp.proton.handler.ProtonHandler.runNow(ProtonHandler.java:346) [artemis-amqp-protocol-2.21.0.redhat-00030.jar:2.21.0.redhat-00030]
	at org.apache.activemq.artemis.protocol.amqp.proton.AMQPConnectionContext.runNow(AMQPConnectionContext.java:308) [artemis-amqp-protocol-2.21.0.redhat-00030.jar:2.21.0.redhat-00030]
	at org.apache.activemq.artemis.protocol.amqp.proton.ProtonServerSenderContext$LargeMessageDeliveryContext.resume(ProtonServerSenderContext.java:569) [artemis-amqp-protocol-2.21.0.redhat-00030.jar:2.21.0.redhat-00030]
	at org.apache.activemq.artemis.core.remoting.impl.netty.NettyConnection.lambda$fireReady$0(NettyConnection.java:173) [artemis-core-client-2.21.0.redhat-00030.jar:2.21.0.redhat-00030]
	at java.base/java.util.ArrayList.forEach(ArrayList.java:1541) [java.base:]

        1. artemis.log
          135 kB

              rhn-support-tbish Tim Bish
              rhn-support-toross Tom Ross (Inactive)
              Votes:
              0 Vote for this issue
              Watchers:
              4 Start watching this issue

                Created:
                Updated:
                Resolved: