Uploaded image for project: 'ActiveMQ Artemis'
  1. ActiveMQ Artemis
  2. ARTEMIS-1022

Artemis does not deliver large message to OpenWire consumer when it is sent from JMS

    XMLWordPrintableJSON

Details

    • Bug
    • Status: Closed
    • Major
    • Resolution: Fixed
    • 1.5.3, 2.3.0
    • 2.5.0
    • OpenWire
    • None

    • Windows OS, Wildfly with Artemis 1.1 or standalone Artemis 1.1 - 1.5.3,
      producer - java spring boot app, consumer (durable) - NMS.ActiveMQ

    Description

      When sending message through a JMS which has size more than min-large-message-size, it is not delivered to consumer. In standalone Artemis broker there is an exception in logs:

      16:02:26,609 WARN [org.apache.activemq.artemis.core.server] Error during message dispatch: java.lang.NullPointerException
      at org.apache.activemq.artemis.core.buffers.impl.ResetLimitWrappedActiveMQBuffer.<init>(ResetLimitWrappedActiveMQBuffer.java:49) [artemis-core-client-1.5.3.jar:1.5.3]
      at org.apache.activemq.artemis.core.message.impl.MessageImpl.getBodyBuffer(MessageImpl.java:252) [artemis-core-client-1.5.3.jar:1.5.3]
      at org.apache.activemq.artemis.core.message.impl.MessageImpl.getBodyBufferDuplicate(MessageImpl.java:281) [artemis-core-client-1.5.3.jar:1.5.3]
      at org.apache.activemq.artemis.core.protocol.openwire.OpenWireMessageConverter.toAMQMessage(OpenWireMessageConverter.java:478) [artemis-openwire-protocol-1.5.3.jar:]
      at org.apache.activemq.artemis.core.protocol.openwire.OpenWireMessageConverter.createMessageDispatch(OpenWireMessageConverter.java:419) [artemis-openwire-protocol-1.5.3.jar:]
      at org.apache.activemq.artemis.core.protocol.openwire.amq.AMQConsumer.handleDeliver(AMQConsumer.java:194) [artemis-openwire-protocol-1.5.3.jar:]
      at org.apache.activemq.artemis.core.protocol.openwire.amq.AMQSession.sendMessage(AMQSession.java:204) [artemis-openwire-protocol-1.5.3.jar:]
      at org.apache.activemq.artemis.core.server.impl.ServerConsumerImpl.deliverStandardMessage(ServerConsumerImpl.java:1019) [artemis-server-1.5.3.jar:1.5.3]
      at org.apache.activemq.artemis.core.server.impl.ServerConsumerImpl.proceedDeliver(ServerConsumerImpl.java:415) [artemis-server-1.5.3.jar:1.5.3]
      at org.apache.activemq.artemis.core.server.impl.QueueImpl.proceedDeliver(QueueImpl.java:2551) [artemis-server-1.5.3.jar:1.5.3]
      at org.apache.activemq.artemis.core.server.impl.QueueImpl.deliver(QueueImpl.java:2052) [artemis-server-1.5.3.jar:1.5.3]
      at org.apache.activemq.artemis.core.server.impl.QueueImpl.access$1700(QueueImpl.java:101) [artemis-server-1.5.3.jar:1.5.3]
      at org.apache.activemq.artemis.core.server.impl.QueueImpl$DeliverRunner.run(QueueImpl.java:2784) [artemis-server-1.5.3.jar:1.5.3]
      at org.apache.activemq.artemis.utils.OrderedExecutorFactory$OrderedExecutor$ExecutorTask.run(OrderedExecutorFactory.java:101) [artemis-commons-1.5.3.jar:1.5.3]
      at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142) [rt.jar:1.8.0_102]
      at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617) [rt.jar:1.8.0_102]
      at java.lang.Thread.run(Thread.java:745) [rt.jar:1.8.0_102]

      16:02:26,609 WARN [org.apache.activemq.artemis.core.server] Error during message dispatch: java.lang.NullPointerException
      at org.apache.activemq.artemis.core.buffers.impl.ResetLimitWrappedActiveMQBuffer.<init>(ResetLimitWrappedActiveMQBuffer.java:49) [artemis-core-client-1.5.3.jar:1.5.3]
      at org.apache.activemq.artemis.core.message.impl.MessageImpl.getBodyBuffer(MessageImpl.java:252) [artemis-core-client-1.5.3.jar:1.5.3]
      at org.apache.activemq.artemis.core.message.impl.MessageImpl.getBodyBufferDuplicate(MessageImpl.java:281) [artemis-core-client-1.5.3.jar:1.5.3]
      at org.apache.activemq.artemis.core.protocol.openwire.OpenWireMessageConverter.toAMQMessage(OpenWireMessageConverter.java:478) [artemis-openwire-protocol-1.5.3.jar:]
      at org.apache.activemq.artemis.core.protocol.openwire.OpenWireMessageConverter.createMessageDispatch(OpenWireMessageConverter.java:419) [artemis-openwire-protocol-1.5.3.jar:]
      at org.apache.activemq.artemis.core.protocol.openwire.amq.AMQConsumer.handleDeliver(AMQConsumer.java:194) [artemis-openwire-protocol-1.5.3.jar:]
      at org.apache.activemq.artemis.core.protocol.openwire.amq.AMQSession.sendMessage(AMQSession.java:204) [artemis-openwire-protocol-1.5.3.jar:]
      at org.apache.activemq.artemis.core.server.impl.ServerConsumerImpl.deliverStandardMessage(ServerConsumerImpl.java:1019) [artemis-server-1.5.3.jar:1.5.3]
      at org.apache.activemq.artemis.core.server.impl.ServerConsumerImpl.proceedDeliver(ServerConsumerImpl.java:415) [artemis-server-1.5.3.jar:1.5.3]
      at org.apache.activemq.artemis.core.server.impl.QueueImpl.proceedDeliver(QueueImpl.java:2551) [artemis-server-1.5.3.jar:1.5.3]
      at org.apache.activemq.artemis.core.server.impl.QueueImpl.deliver(QueueImpl.java:2052) [artemis-server-1.5.3.jar:1.5.3]
      at org.apache.activemq.artemis.core.server.impl.QueueImpl.access$1700(QueueImpl.java:101) [artemis-server-1.5.3.jar:1.5.3]
      at org.apache.activemq.artemis.core.server.impl.QueueImpl$DeliverRunner.run(QueueImpl.java:2784) [artemis-server-1.5.3.jar:1.5.3]
      at org.apache.activemq.artemis.utils.OrderedExecutorFactory$OrderedExecutor$ExecutorTask.run(OrderedExecutorFactory.java:101) [artemis-commons-1.5.3.jar:1.5.3]
      at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142) [rt.jar:1.8.0_102]
      at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617) [rt.jar:1.8.0_102]
      at java.lang.Thread.run(Thread.java:745) [rt.jar:1.8.0_102]

      Attachments

        Activity

          People

            Unassigned Unassigned
            olegich Oleg Kozakevych
            Votes:
            3 Vote for this issue
            Watchers:
            5 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved: