[
https://issues.apache.org/jira/browse/ARTEMIS-1336?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Justin Bertram resolved ARTEMIS-1336.
-------------------------------------
Resolution: Cannot Reproduce
Both of these tests now succeed when adapted to run with OpenWire.
> JMS test DivertAndACKClientTest fails with OpenWire protocol (activemq-client
> JMS library)
> ------------------------------------------------------------------------------------------
>
> Key: ARTEMIS-1336
> URL: https://issues.apache.org/jira/browse/ARTEMIS-1336
> Project: ActiveMQ Artemis
> Issue Type: Test
> Components: Broker, OpenWire
> Affects Versions: 2.3.0
> Reporter: Jiri Daněk
> Priority: Minor
>
> Consider tests
> {{org.apache.activemq.artemis.tests.integration.jms.divert.DivertAndACKClientTest#testClientACK}}
> and {{#testAutoACK}} in the same class.
> When adapted to run with multiple JMS libraries, the Core and AMQP versions
> pass, while the OpenWire variant fails in both tests.
> The error message is
> {noformat}
> [Thread-1 (activemq-netty-threads)] 19:18:06,649 WARN
> [org.apache.activemq.artemis.core.protocol.openwire.amq.AMQSession] Cannot
> publish to a non-existent Destination: queue://Source:
> javax.jms.InvalidDestinationException: Cannot publish to a non-existent
> Destination: queue://Source
> at
> org.apache.activemq.artemis.core.protocol.openwire.amq.AMQSession.lambda$send$0(AMQSession.java:360)
> [:]
> at
> org.apache.activemq.artemis.core.paging.impl.PagingStoreImpl.checkMemory(PagingStoreImpl.java:706)
> [:]
> at
> org.apache.activemq.artemis.core.protocol.openwire.amq.AMQSession.send(AMQSession.java:353)
> [:]
> at
> org.apache.activemq.artemis.core.protocol.openwire.OpenWireConnection$CommandProcessor.processMessage(OpenWireConnection.java:1458)
> [:]
> at
> org.apache.activemq.command.ActiveMQMessage.visit(ActiveMQMessage.java:768)
> [activemq-client-5.14.5.jar:5.14.5]
> at
> org.apache.activemq.artemis.core.protocol.openwire.OpenWireConnection.bufferReceived(OpenWireConnection.java:273)
> [:]
> at
> org.apache.activemq.artemis.core.remoting.server.impl.RemotingServiceImpl$DelegatingBufferHandler.bufferReceived(RemotingServiceImpl.java:631)
> [:]
> at
> org.apache.activemq.artemis.core.remoting.impl.netty.ActiveMQChannelHandler.channelRead(ActiveMQChannelHandler.java:68)
> [:]
> at
> io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
> [netty-all-4.1.9.Final.jar:4.1.9.Final]
> at
> io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
> [netty-all-4.1.9.Final.jar:4.1.9.Final]
> at
> io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340)
> [netty-all-4.1.9.Final.jar:4.1.9.Final]
> at
> io.netty.handler.codec.ByteToMessageDecoder.fireChannelRead(ByteToMessageDecoder.java:293)
> [netty-all-4.1.9.Final.jar:4.1.9.Final]
> at
> io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:267)
> [netty-all-4.1.9.Final.jar:4.1.9.Final]
> at
> io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
> [netty-all-4.1.9.Final.jar:4.1.9.Final]
> at
> io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
> [netty-all-4.1.9.Final.jar:4.1.9.Final]
> at
> io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340)
> [netty-all-4.1.9.Final.jar:4.1.9.Final]
> at
> io.netty.channel.DefaultChannelPipeline$HeadContext.channelRead(DefaultChannelPipeline.java:1334)
> [netty-all-4.1.9.Final.jar:4.1.9.Final]
> at
> io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
> [netty-all-4.1.9.Final.jar:4.1.9.Final]
> at
> io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
> [netty-all-4.1.9.Final.jar:4.1.9.Final]
> at
> io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:926)
> [netty-all-4.1.9.Final.jar:4.1.9.Final]
> at
> io.netty.channel.epoll.AbstractEpollStreamChannel$EpollStreamUnsafe.epollInReady(AbstractEpollStreamChannel.java:1017)
> [netty-all-4.1.9.Final.jar:4.1.9.Final]
> at
> io.netty.channel.epoll.EpollEventLoop.processReady(EpollEventLoop.java:394)
> [netty-all-4.1.9.Final.jar:4.1.9.Final]
> at io.netty.channel.epoll.EpollEventLoop.run(EpollEventLoop.java:299)
> [netty-all-4.1.9.Final.jar:4.1.9.Final]
> at
> io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:858)
> [netty-all-4.1.9.Final.jar:4.1.9.Final]
> at java.lang.Thread.run(Thread.java:748) [rt.jar:1.8.0_131]
> [Thread-1 (activemq-netty-threads)] 19:18:07,986 WARN
> [org.apache.activemq.artemis.core.protocol.openwire.amq.AMQSession] Cannot
> publish to a non-existent Destination: queue://Source:
> javax.jms.InvalidDestinationException: Cannot publish to a non-existent
> Destination: queue://Source
> at
> org.apache.activemq.artemis.core.protocol.openwire.amq.AMQSession.lambda$send$0(AMQSession.java:360)
> [:]
> at
> org.apache.activemq.artemis.core.paging.impl.PagingStoreImpl.checkMemory(PagingStoreImpl.java:706)
> [:]
> at
> org.apache.activemq.artemis.core.protocol.openwire.amq.AMQSession.send(AMQSession.java:353)
> [:]
> at
> org.apache.activemq.artemis.core.protocol.openwire.OpenWireConnection$CommandProcessor.processMessage(OpenWireConnection.java:1458)
> [:]
> at
> org.apache.activemq.command.ActiveMQMessage.visit(ActiveMQMessage.java:768)
> [activemq-client-5.14.5.jar:5.14.5]
> at
> org.apache.activemq.artemis.core.protocol.openwire.OpenWireConnection.bufferReceived(OpenWireConnection.java:273)
> [:]
> at
> org.apache.activemq.artemis.core.remoting.server.impl.RemotingServiceImpl$DelegatingBufferHandler.bufferReceived(RemotingServiceImpl.java:631)
> [:]
> at
> org.apache.activemq.artemis.core.remoting.impl.netty.ActiveMQChannelHandler.channelRead(ActiveMQChannelHandler.java:68)
> [:]
> at
> io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
> [netty-all-4.1.9.Final.jar:4.1.9.Final]
> at
> io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
> [netty-all-4.1.9.Final.jar:4.1.9.Final]
> at
> io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340)
> [netty-all-4.1.9.Final.jar:4.1.9.Final]
> at
> io.netty.handler.codec.ByteToMessageDecoder.fireChannelRead(ByteToMessageDecoder.java:293)
> [netty-all-4.1.9.Final.jar:4.1.9.Final]
> at
> io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:267)
> [netty-all-4.1.9.Final.jar:4.1.9.Final]
> at
> io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
> [netty-all-4.1.9.Final.jar:4.1.9.Final]
> at
> io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
> [netty-all-4.1.9.Final.jar:4.1.9.Final]
> at
> io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340)
> [netty-all-4.1.9.Final.jar:4.1.9.Final]
> at
> io.netty.channel.DefaultChannelPipeline$HeadContext.channelRead(DefaultChannelPipeline.java:1334)
> [netty-all-4.1.9.Final.jar:4.1.9.Final]
> at
> io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
> [netty-all-4.1.9.Final.jar:4.1.9.Final]
> at
> io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
> [netty-all-4.1.9.Final.jar:4.1.9.Final]
> at
> io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:926)
> [netty-all-4.1.9.Final.jar:4.1.9.Final]
> at
> io.netty.channel.epoll.AbstractEpollStreamChannel$EpollStreamUnsafe.epollInReady(AbstractEpollStreamChannel.java:1017)
> [netty-all-4.1.9.Final.jar:4.1.9.Final]
> at
> io.netty.channel.epoll.EpollEventLoop.processReady(EpollEventLoop.java:394)
> [netty-all-4.1.9.Final.jar:4.1.9.Final]
> at io.netty.channel.epoll.EpollEventLoop.run(EpollEventLoop.java:299)
> [netty-all-4.1.9.Final.jar:4.1.9.Final]
> at
> io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:858)
> [netty-all-4.1.9.Final.jar:4.1.9.Final]
> at java.lang.Thread.run(Thread.java:748) [rt.jar:1.8.0_131]
> {noformat}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
