Michal Toth created ARTEMIS-1457:
------------------------------------
Summary: Diverts are not working with Openwire protocol
Key: ARTEMIS-1457
URL: https://issues.apache.org/jira/browse/ARTEMIS-1457
Project: ActiveMQ Artemis
Issue Type: Bug
Components: Broker, OpenWire
Affects Versions: 2.3.0
Environment: Diverts exclusive/non-exclusive
Openwire clients
Reporter: Michal Toth
Both type of diverts are not working with OpenWire protocol.
Broker stacktrace error
{noformat}
12:58:10,848 WARN
[org.apache.activemq.artemis.core.protocol.openwire.amq.AMQSession] Cannot
publish to a non-existent Destination: queue://testDivert:
javax.jms.InvalidDestinationException: Cannot publish to a non-existent
Destination: queue://testDivert
at
org.apache.activemq.artemis.core.protocol.openwire.amq.AMQSession.lambda$send$0(AMQSession.java:360)
[artemis-openwire-protocol-2.0.0.amq-700013-redhat-1.jar:]
at
org.apache.activemq.artemis.core.paging.impl.PagingStoreImpl.checkMemory(PagingStoreImpl.java:696)
[artemis-server-2.0.0.amq-700013-redhat-1.jar:2.0.0.amq-700013-redhat-1]
at
org.apache.activemq.artemis.core.protocol.openwire.amq.AMQSession.send(AMQSession.java:353)
[artemis-openwire-protocol-2.0.0.amq-700013-redhat-1.jar:]
at
org.apache.activemq.artemis.core.protocol.openwire.OpenWireConnection$CommandProcessor.processMessage(OpenWireConnection.java:1366)
[artemis-openwire-protocol-2.0.0.amq-700013-redhat-1.jar:]
at
org.apache.activemq.command.ActiveMQMessage.visit(ActiveMQMessage.java:768)
[activemq-client-5.11.0.redhat-630283.jar:5.11.0.redhat-630283]
at
org.apache.activemq.artemis.core.protocol.openwire.OpenWireConnection.bufferReceived(OpenWireConnection.java:271)
[artemis-openwire-protocol-2.0.0.amq-700013-redhat-1.jar:]
at
org.apache.activemq.artemis.core.remoting.server.impl.RemotingServiceImpl$DelegatingBufferHandler.bufferReceived(RemotingServiceImpl.java:628)
[artemis-server-2.0.0.amq-700013-redhat-1.jar:2.0.0.amq-700013-redhat-1]
at
org.apache.activemq.artemis.core.remoting.impl.netty.ActiveMQChannelHandler.channelRead(ActiveMQChannelHandler.java:69)
[artemis-core-client-2.0.0.amq-700013-redhat-1.jar:2.0.0.amq-700013-redhat-1]
at
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
[netty-all-4.1.9.Final-redhat-2.jar:4.1.9.Final-redhat-2]
at
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
[netty-all-4.1.9.Final-redhat-2.jar:4.1.9.Final-redhat-2]
at
io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340)
[netty-all-4.1.9.Final-redhat-2.jar:4.1.9.Final-redhat-2]
at
io.netty.handler.codec.ByteToMessageDecoder.fireChannelRead(ByteToMessageDecoder.java:293)
[netty-all-4.1.9.Final-redhat-2.jar:4.1.9.Final-redhat-2]
at
io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:267)
[netty-all-4.1.9.Final-redhat-2.jar:4.1.9.Final-redhat-2]
at
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
[netty-all-4.1.9.Final-redhat-2.jar:4.1.9.Final-redhat-2]
at
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
[netty-all-4.1.9.Final-redhat-2.jar:4.1.9.Final-redhat-2]
at
io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340)
[netty-all-4.1.9.Final-redhat-2.jar:4.1.9.Final-redhat-2]
at
io.netty.channel.DefaultChannelPipeline$HeadContext.channelRead(DefaultChannelPipeline.java:1334)
[netty-all-4.1.9.Final-redhat-2.jar:4.1.9.Final-redhat-2]
at
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
[netty-all-4.1.9.Final-redhat-2.jar:4.1.9.Final-redhat-2]
at
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
[netty-all-4.1.9.Final-redhat-2.jar:4.1.9.Final-redhat-2]
at
io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:926)
[netty-all-4.1.9.Final-redhat-2.jar:4.1.9.Final-redhat-2]
at
io.netty.channel.epoll.AbstractEpollStreamChannel$EpollStreamUnsafe.epollInReady(AbstractEpollStreamChannel.java:1017)
[netty-all-4.1.9.Final-redhat-2.jar:4.1.9.Final-redhat-2]
at
io.netty.channel.epoll.EpollEventLoop.processReady(EpollEventLoop.java:394)
[netty-all-4.1.9.Final-redhat-2.jar:4.1.9.Final-redhat-2]
at io.netty.channel.epoll.EpollEventLoop.run(EpollEventLoop.java:299)
[netty-all-4.1.9.Final-redhat-2.jar:4.1.9.Final-redhat-2]
at
io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:858)
[netty-all-4.1.9.Final-redhat-2.jar:4.1.9.Final-redhat-2]
at java.lang.Thread.run(Thread.java:748) [rt.jar:1.8.0_141]
12:58:11,189 WARN [org.apache.activemq.artemis.core.server] AMQ222061: Client
connection failed, clearing up resources for session
e7c0cd3c-ada9-11e7-8016-525400061be7
12:58:11,190 WARN [org.apache.activemq.artemis.core.server] AMQ222107: Cleared
up resources for session e7c0cd3c-ada9-11e7-8016-525400061be7
12:58:11,190 WARN [org.apache.activemq.artemis.core.server] AMQ222061: Client
connection failed, clearing up resources for session
ID:dhcp-145-96.lab.eng.brq.redhat.com-33090-1507633090593-1:1:-1
12:58:11,191 WARN [org.apache.activemq.artemis.core.server] AMQ222107: Cleared
up resources for session
ID:dhcp-145-96.lab.eng.brq.redhat.com-33090-1507633090593-1:1:-1
12:58:11,214 WARN [org.apache.activemq.artemis.core.server] AMQ222061: Client
connection failed, clearing up resources for session
ID:dhcp-145-96.lab.eng.brq.redhat.com-33090-1507633090593-1:1:1
12:58:11,214 WARN [org.apache.activemq.artemis.core.server] AMQ222107: Cleared
up resources for session
ID:dhcp-145-96.lab.eng.brq.redhat.com-33090-1507633090593-1:1:1
{noformat}
Client error
{noformat}
$ java -jar /var/dtests/node_data/clients/aoc7.jar sender --log-msgs dict
--broker <broker>:61616 --conn-username admin --conn-password admin --address
testDivert --count 1
12:55:27,010 ERROR Error while sending a message!
javax.jms.InvalidDestinationException: Cannot publish to a non-existent
Destination: queue://testDivert
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:696)
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:1366)
at
org.apache.activemq.command.ActiveMQMessage.visit(ActiveMQMessage.java:768)
at
org.apache.activemq.artemis.core.protocol.openwire.OpenWireConnection.bufferReceived(OpenWireConnection.java:271)
at
org.apache.activemq.artemis.core.remoting.server.impl.RemotingServiceImpl$DelegatingBufferHandler.bufferReceived(RemotingServiceImpl.java:628)
at
org.apache.activemq.artemis.core.remoting.impl.netty.ActiveMQChannelHandler.channelRead(ActiveMQChannelHandler.java:69)
at
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
at
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
at
io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340)
at
io.netty.handler.codec.ByteToMessageDecoder.fireChannelRead(ByteToMessageDecoder.java:293)
at
io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:267)
at
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
at
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
at
io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340)
at
io.netty.channel.DefaultChannelPipeline$HeadContext.channelRead(DefaultChannelPipeline.java:1334)
at
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
at
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
at
io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:926)
at
io.netty.channel.epoll.AbstractEpollStreamChannel$EpollStreamUnsafe.epollInReady(AbstractEpollStreamChannel.java:1017)
at
io.netty.channel.epoll.EpollEventLoop.processReady(EpollEventLoop.java:394)
at io.netty.channel.epoll.EpollEventLoop.run(EpollEventLoop.java:299)
at
io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:858)
at java.lang.Thread.run(Thread.java:748)
{noformat}
--
This message was sent by Atlassian JIRA
(v6.4.14#64029)
