[ https://issues.apache.org/jira/browse/ARTEMIS-2140?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Justin Bertram reopened ARTEMIS-2140: ------------------------------------- > AMQP Shared Subscriptions fail because of RaceCondition > ------------------------------------------------------- > > Key: ARTEMIS-2140 > URL: https://issues.apache.org/jira/browse/ARTEMIS-2140 > Project: ActiveMQ Artemis > Issue Type: Bug > Components: AMQP, Broker > Affects Versions: 2.6.3 > Reporter: Johan Stenberg > Assignee: Justin Bertram > Priority: Major > Fix For: 2.7.0, 2.6.4 > > Attachments: Artemis2140_AmqpSharedConsumerRaceConditionTest.java > > > When multiple clients concurrently try to subscribe to the same shared > subscription the following exception occurs: > {noformat} > Okt 19, 2018 4:25:21 PM > org.apache.activemq.artemis.protocol.amqp.proton.handler.ProtonHandler > dispatch > WARN: AMQ119018: Binding already exists LocalQueueBinding > [address=topics.cat, queue=QueueImpl[name=nonDurable.MY_SUB, > postOffice=PostOfficeImpl > [server=ActiveMQServerImpl::serverUUID=cf020fcf-d3aa-11e8-ac61-54524514640f], > temp=false]@6425eba3, filter=null, name=nonDurable.MY_SUB, > clusterName=nonDurable.MY_SUBcf020fcf-d3aa-11e8-ac61-54524514640f] > ActiveMQQueueExistsException[errorType=QUEUE_EXISTS message=AMQ119018: > Binding already exists LocalQueueBinding [address=topics.cat, > queue=QueueImpl[name=nonDurable.MY_SUB, postOffice=PostOfficeImpl > [server=ActiveMQServerImpl::serverUUID=cf020fcf-d3aa-11e8-ac61-54524514640f], > temp=false]@6425eba3, filter=null, name=nonDurable.MY_SUB, > clusterName=nonDurable.MY_SUBcf020fcf-d3aa-11e8-ac61-54524514640f]] > at > org.apache.activemq.artemis.core.postoffice.impl.SimpleAddressManager.addBinding(SimpleAddressManager.java:85) > at > org.apache.activemq.artemis.core.postoffice.impl.WildcardAddressManager.addBinding(WildcardAddressManager.java:90) > at > org.apache.activemq.artemis.core.postoffice.impl.PostOfficeImpl.addBinding(PostOfficeImpl.java:615) > at > org.apache.activemq.artemis.core.server.impl.ActiveMQServerImpl.createQueue(ActiveMQServerImpl.java:2818) > at > org.apache.activemq.artemis.core.server.impl.ActiveMQServerImpl.createQueue(ActiveMQServerImpl.java:1690) > at > org.apache.activemq.artemis.core.server.impl.ServerSessionImpl.createQueue(ServerSessionImpl.java:594) > at > org.apache.activemq.artemis.core.server.impl.ServerSessionImpl.createQueue(ServerSessionImpl.java:634) > at > org.apache.activemq.artemis.protocol.amqp.broker.AMQPSessionCallback.createSharedVolatileQueue(AMQPSessionCallback.java:283) > at > org.apache.activemq.artemis.protocol.amqp.proton.ProtonServerSenderContext.initialise(ProtonServerSenderContext.java:374) > at > org.apache.activemq.artemis.protocol.amqp.proton.AMQPSessionContext.addSender(AMQPSessionContext.java:168) > at > org.apache.activemq.artemis.protocol.amqp.proton.AMQPConnectionContext.remoteLinkOpened(AMQPConnectionContext.java:243) > at > org.apache.activemq.artemis.protocol.amqp.proton.AMQPConnectionContext.onRemoteOpen(AMQPConnectionContext.java:462) > at > org.apache.activemq.artemis.protocol.amqp.proton.handler.Events.dispatch(Events.java:68) > at > org.apache.activemq.artemis.protocol.amqp.proton.handler.ProtonHandler.dispatch(ProtonHandler.java:494) > at > org.apache.activemq.artemis.protocol.amqp.proton.handler.ProtonHandler.flush(ProtonHandler.java:307) > at > org.apache.activemq.artemis.protocol.amqp.proton.handler.ProtonHandler.inputBuffer(ProtonHandler.java:272) > at > org.apache.activemq.artemis.protocol.amqp.proton.AMQPConnectionContext.inputBuffer(AMQPConnectionContext.java:158) > at > org.apache.activemq.artemis.protocol.amqp.broker.ActiveMQProtonRemotingConnection.bufferReceived(ActiveMQProtonRemotingConnection.java:147) > at > org.apache.activemq.artemis.core.remoting.server.impl.RemotingServiceImpl$DelegatingBufferHandler.bufferReceived(RemotingServiceImpl.java:643) > at > org.apache.activemq.artemis.core.remoting.impl.netty.ActiveMQChannelHandler.channelRead(ActiveMQChannelHandler.java:73) > 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:1434) > 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:965) > at > io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:163) > at > io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:644) > at > io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:579) > at > io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:496) > at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:458) > at > io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:897) > at > org.apache.activemq.artemis.utils.ActiveMQThreadFactory$1.run(ActiveMQThreadFactory.java:118) > {noformat} -- This message was sent by Atlassian JIRA (v7.6.3#76005)