Details
-
Bug
-
Resolution: Done
-
Blocker
-
A-MQ 7.0.0.ER16
-
None
Description
I realize that when I was sorting out the CMS failures I omit to report this issue, sorry for the inconvenience. This tests was not yet investigated and may imply a broker issue. This tests is also marked as 'needs investigation' in the Andy's CMS Openwire failures [1] document.
This looks as a race condition issue and is not 100% reproducible. However, the reproducibility for me is more than 90%. In some cases (~20%) the CMS test suite is stuck on this test and needs to be killed (in this case Broker is in working state and responsive, so it's more like CMS client issue).
Note: ENTMQBR-36 looks related
N8activemq4test8openwire23OpenwireCmsTemplateTestE::testBasics.AMQ119018: Binding already exists LocalQueueBinding [address=testBasics1, queue=QueueImpl[name=testBasics1, postOffice=PostOfficeImpl [server=ActiveMQServerImpl::serverUUID=6ad1a259-f39c-11e6-bb9d-52540033cf85], temp=false]@43988f76, filter=null, name=testBasics1, clusterName=testBasics16ad1a259-f39c-11e6-bb9d-52540033cf85] FILE: org.apache.activemq.artemis.core.postoffice.impl.SimpleAddressManager.addBinding(SimpleAddressManager.java), LINE: 76 FILE: org.apache.activemq.artemis.core.postoffice.impl.WildcardAddressManager.addBinding(WildcardAddressManager.java), LINE: 95 FILE: org.apache.activemq.artemis.core.postoffice.impl.PostOfficeImpl.addBinding(PostOfficeImpl.java), LINE: 532 FILE: org.apache.activemq.artemis.core.server.impl.ActiveMQServerImpl.createQueue(ActiveMQServerImpl.java), LINE: 2486 FILE: org.apache.activemq.artemis.core.server.impl.ActiveMQServerImpl.createQueue(ActiveMQServerImpl.java), LINE: 1537 FILE: org.apache.activemq.artemis.core.server.impl.ActiveMQServerImpl.createQueue(ActiveMQServerImpl.java), LINE: 1522 FILE: org.apache.activemq.artemis.core.server.impl.ActiveMQServerImpl.createQueue(ActiveMQServerImpl.java), LINE: 1509 FILE: org.apache.activemq.artemis.core.protocol.openwire.OpenWireConnection.addDestination(OpenWireConnection.java), LINE: 726 FILE: org.apache.activemq.artemis.core.protocol.openwire.OpenWireConnection$CommandProcessor.processAddProducer(OpenWireConnection.java), LINE: 992 FILE: org.apache.activemq.command.ProducerInfo.visit(ProducerInfo.java), LINE: 108 FILE: org.apache.activemq.artemis.core.protocol.openwire.OpenWireConnection.bufferReceived(OpenWireConnection.java), LINE: 268 FILE: org.apache.activemq.artemis.core.remoting.server.impl.RemotingServiceImpl$DelegatingBufferHandler.bufferReceived(RemotingServiceImpl.java), LINE: 621 FILE: org.apache.activemq.artemis.core.remoting.impl.netty.ActiveMQChannelHandler.channelRead(ActiveMQChannelHandler.java), LINE: 68 FILE: io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java), LINE: 372 FILE: io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java), LINE: 358 FILE: io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java), LINE: 350 FILE: io.netty.handler.codec.ByteToMessageDecoder.fireChannelRead(ByteToMessageDecoder.java), LINE: 293 FILE: io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java), LINE: 267 FILE: io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java), LINE: 372 FILE: io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java), LINE: 358 FILE: io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java), LINE: 350 FILE: io.netty.channel.DefaultChannelPipeline$HeadContext.channelRead(DefaultChannelPipeline.java), LINE: 1334 FILE: io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java), LINE: 372 FILE: io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java), LINE: 358 FILE: io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java), LINE: 926 FILE: io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java), LINE: 129 FILE: io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java), LINE: 610 FILE: io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java), LINE: 551 FILE: io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java), LINE: 465 FILE: io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java), LINE: 437 FILE: io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java), LINE: 873 FILE: java.lang.Thread.run(Thread.java), LINE: 785 FILE: activemq/core/ActiveMQSession.cpp, LINE: 129 DataInputStream::readLong - Reached EOF FILE: activemq/core/kernels/ActiveMQConsumerKernel.cpp, LINE: 1067 FILE: activemq/core/kernels/ActiveMQConsumerKernel.cpp, LINE: 1094 FILE: activemq/core/ActiveMQConsumer.cpp, LINE: 131 FILE: activemq/cmsutil/CmsTemplate.cpp, LINE: 644 : assertionFDataInputStream::readLong - Reached EOF FILE: activemq/core/ActiveMQConnection.cpp, LINE: 1262 FILE: activemq/core/ActiveMQConnection.cpp, LINE: 804
1) test: N8activemq4test8openwire23OpenwireCmsTemplateTestE::testBasics (F) line: 177 activemq/test/CmsTemplateTest.cpp assertion failed - Expression: numReceived == NUM_MESSAGES
[1] https://docs.google.com/spreadsheets/d/1-LAnzVmtjtOODrQ-BANVQNGVZxzxh1m1UY_TTKVBNcE/edit#gid=0
Attachments
Issue Links
- relates to
-
-
- Closed
-
