[
https://issues.apache.org/jira/browse/ARTEMIS-1022?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16174881#comment-16174881
]
David Edwards commented on ARTEMIS-1022:
----------------------------------------
Looks like the issue is still present in 1.5.5, and affects both Openwire and
JMX, if the large message was sent via JMS. If the message was sent via
Openwire originally, all is fine.
We have created a small sample project to demonstrate the problem:
[https://github.com/CJSCommonPlatform/artemis-failure-test|https://github.com/CJSCommonPlatform/artemis-failure-test]
Run it using Maven. It starts up the broker and runs a couple of integration
tests which will fail as described.
> Artemis does not deliver large message to OpenWire consumer when it is sent
> from JMS
> ------------------------------------------------------------------------------------
>
> Key: ARTEMIS-1022
> URL: https://issues.apache.org/jira/browse/ARTEMIS-1022
> Project: ActiveMQ Artemis
> Issue Type: Bug
> Components: OpenWire
> Affects Versions: 1.5.3
> Environment: Windows OS, Wildfly with Artemis 1.1 or standalone
> Artemis 1.1 - 1.5.3,
> producer - java spring boot app, consumer (durable) - NMS.ActiveMQ
> Reporter: Oleg Kozakevych
>
> 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]
--
This message was sent by Atlassian JIRA
(v6.4.14#64029)
