Uploaded image for project: 'AMQ Broker'
  1. AMQ Broker
  2. ENTMQBR-468

Artemis doesn't return Error when amqp receiver use wrong selector

    XMLWordPrintable

Details

    • Bug
    • Resolution: Duplicate
    • Critical
    • None
    • A-MQ 7.0.0.ER13
    • None
    • None
      1. start broker
      2. run amqp receiver client with selector string foo/bar
      3. broker doesn't return error in detach

    Description

      When amqp receiver use wrong selector AMQ7-ER12 retunr in detach error with wrong selector:

      [1256929573:0] <- Open{ containerId='9dad2efb-7542-4821-98d4-0041feb7340e', hostname='10.34.75.113', maxFrameSize=4294967295, channelMax=32767, idleTimeOut=null, outgoingLocales=null, incomingLocales=null, offeredCapabilities=null, desiredCapabilities=null, properties=null}
      [1256929573:0] <- Begin{remoteChannel=null, nextOutgoingId=0, incomingWindow=2147483647, outgoingWindow=2147483647, handleMax=4294967295, offeredCapabilities=null, desiredCapabilities=null, properties=null}
      [1256929573:0] <- Attach{name='9dad2efb-7542-4821-98d4-0041feb7340e-jms.queue.test', handle=0, role=RECEIVER, sndSettleMode=MIXED, rcvSettleMode=FIRST, source=Source{address='jms.queue.test', durable=NONE, expiryPolicy=SESSION_END, timeout=0, dynamic=false, dynamicNodeProperties=null, distributionMode=null, filter={selector=org.apache.qpid.proton.codec.DecoderImpl$UnknownDescribedType@131efb92}, defaultOutcome=null, outcomes=null, capabilities=null}, target=Target{address='null', durable=NONE, expiryPolicy=SESSION_END, timeout=0, dynamic=false, dynamicNodeProperties=null, capabilities=null}, unsettled=null, incompleteUnsettled=false, initialDeliveryCount=0, maxMessageSize=null, offeredCapabilities=null, desiredCapabilities=null, properties=null}
      [1256929573:0] <- Flow{nextIncomingId=null, incomingWindow=2147483647, nextOutgoingId=0, outgoingWindow=2147483647, handle=0, deliveryCount=0, linkCredit=10, available=null, drain=false, echo=false, properties=null}
      [1256929573:0] -> Open{ containerId='0.0.0.0', hostname='', maxFrameSize=4294967295, channelMax=65535, idleTimeOut=30000, outgoingLocales=null, incomingLocales=null, offeredCapabilities=[sole-connection-for-container, DELAYED_DELIVERY], desiredCapabilities=null, properties={product=apache-activemq-artemis, version=1.3.0.amq-700005-redhat-1}}
      [1256929573:0] <- Empty Frame
      10:29:48,640 WARN  [org.proton.plug.handler.impl.ProtonHandlerImpl] null: java.lang.NullPointerException
      	at org.apache.activemq.artemis.core.protocol.proton.plug.ProtonSessionIntegrationCallback.onFlowConsumer(ProtonSessionIntegrationCallback.java:126) [artemis-amqp-protocol-1.3.0.amq-700005-redhat-1.jar:]
      	at org.proton.plug.context.server.ProtonServerSenderContext.onFlow(ProtonServerSenderContext.java:86) [artemis-proton-plug-1.3.0.amq-700005-redhat-1.jar:1.3.0.amq-700005-redhat-1]
      	at org.proton.plug.context.AbstractConnectionContext$LocalListener.onFlow(AbstractConnectionContext.java:316) [artemis-proton-plug-1.3.0.amq-700005-redhat-1.jar:1.3.0.amq-700005-redhat-1]
      	at org.proton.plug.handler.Events.dispatch(Events.java:85) [artemis-proton-plug-1.3.0.amq-700005-redhat-1.jar:1.3.0.amq-700005-redhat-1]
      	at org.proton.plug.handler.impl.ProtonHandlerImpl.dispatch(ProtonHandlerImpl.java:369) [artemis-proton-plug-1.3.0.amq-700005-redhat-1.jar:1.3.0.amq-700005-redhat-1]
      	at org.proton.plug.handler.impl.ProtonHandlerImpl.access$000(ProtonHandlerImpl.java:49) [artemis-proton-plug-1.3.0.amq-700005-redhat-1.jar:1.3.0.amq-700005-redhat-1]
      	at org.proton.plug.handler.impl.ProtonHandlerImpl$1.run(ProtonHandlerImpl.java:68) [artemis-proton-plug-1.3.0.amq-700005-redhat-1.jar:1.3.0.amq-700005-redhat-1]
      	at org.apache.activemq.artemis.utils.OrderedExecutorFactory$OrderedExecutor$ExecutorTask.run(OrderedExecutorFactory.java:103) [artemis-core-client-1.3.0.amq-700005-redhat-1.jar:1.3.0.amq-700005-redhat-1]
      	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142) [rt.jar:1.8.0_111]
      	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617) [rt.jar:1.8.0_111]
      	at java.lang.Thread.run(Thread.java:745) [rt.jar:1.8.0_111]
      
      [1256929573:0] -> Begin{remoteChannel=0, nextOutgoingId=1, incomingWindow=2147483647, outgoingWindow=2147483647, handleMax=65535, offeredCapabilities=null, desiredCapabilities=null, properties=null}
      [1256929573:0] -> Attach{name='9dad2efb-7542-4821-98d4-0041feb7340e-jms.queue.test', handle=0, role=SENDER, sndSettleMode=MIXED, rcvSettleMode=FIRST, source=Source{address='jms.queue.test', durable=NONE, expiryPolicy=SESSION_END, timeout=0, dynamic=false, dynamicNodeProperties=null, distributionMode=null, filter={selector=org.apache.qpid.proton.codec.DecoderImpl$UnknownDescribedType@131efb92}, defaultOutcome=null, outcomes=null, capabilities=null}, target=Target{address='null', durable=NONE, expiryPolicy=SESSION_END, timeout=0, dynamic=false, dynamicNodeProperties=null, capabilities=null}, unsettled=null, incompleteUnsettled=false, initialDeliveryCount=0, maxMessageSize=null, offeredCapabilities=null, desiredCapabilities=null, properties=null}
      [1256929573:0] <- Detach{handle=0, closed=true, error=null}
      [1256929573:0] <- Close{error=null}
      [1256929573:0] -> Detach{handle=0, closed=true, error=Error{condition=amqp:invalid-field, description='foo/bar', info=null}}
      [1256929573:0] -> Close{error=null}
      10:30:00,682 WARN  [org.apache.activemq.artemis.core.client] AMQ212037: Connection failure has been detected: null [code=REMOTE_DISCONNECT]
      

      but with ER13 no

      [1857313193:0] <- Open{ containerId='23643712-8604-48ce-bad4-b8f7b7093ad4', hostname='10.34.75.113', maxFrameSize=4294967295, channelMax=32767, idleTimeOut=null, outgoingLocales=null, incomingLocales=null, offeredCapabilities=null, desiredCapabilities=null, properties=null}
      [1857313193:0] <- Begin{remoteChannel=null, nextOutgoingId=0, incomingWindow=2147483647, outgoingWindow=2147483647, handleMax=4294967295, offeredCapabilities=null, desiredCapabilities=null, properties=null}
      [1857313193:0] <- Attach{name='23643712-8604-48ce-bad4-b8f7b7093ad4-jms.queue.test', handle=0, role=RECEIVER, sndSettleMode=MIXED, rcvSettleMode=FIRST, source=Source{address='jms.queue.test', durable=NONE, expiryPolicy=SESSION_END, timeout=0, dynamic=false, dynamicNodeProperties=null, distributionMode=null, filter={selector=org.apache.qpid.proton.codec.DecoderImpl$UnknownDescribedType@1143432f}, defaultOutcome=null, outcomes=null, capabilities=null}, target=Target{address='null', durable=NONE, expiryPolicy=SESSION_END, timeout=0, dynamic=false, dynamicNodeProperties=null, capabilities=null}, unsettled=null, incompleteUnsettled=false, initialDeliveryCount=0, maxMessageSize=null, offeredCapabilities=null, desiredCapabilities=null, properties=null}
      [1857313193:0] <- Flow{nextIncomingId=null, incomingWindow=2147483647, nextOutgoingId=0, outgoingWindow=2147483647, handle=0, deliveryCount=0, linkCredit=10, available=null, drain=false, echo=false, properties=null}
      [1857313193:0] -> Open{ containerId='0.0.0.0', hostname='null', maxFrameSize=4294967295, channelMax=65535, idleTimeOut=30000, outgoingLocales=null, incomingLocales=null, offeredCapabilities=[sole-connection-for-container, DELAYED_DELIVERY], desiredCapabilities=null, properties={product=apache-activemq-artemis, version=1.5.0.amq-700002-redhat-1}}
      10:31:30,588 WARN  [org.apache.activemq.artemis.protocol.amqp.proton.handler.ProtonHandler] null: java.lang.NullPointerException
      	at org.apache.activemq.artemis.protocol.amqp.broker.AMQPSessionCallback.onFlowConsumer(AMQPSessionCallback.java:130) [artemis-amqp-protocol-1.5.0.amq-700002-redhat-1.jar:]
      	at org.apache.activemq.artemis.protocol.amqp.proton.ProtonServerSenderContext.onFlow(ProtonServerSenderContext.java:93) [artemis-amqp-protocol-1.5.0.amq-700002-redhat-1.jar:]
      	at org.apache.activemq.artemis.protocol.amqp.proton.AMQPConnectionContext$LocalListener.onFlow(AMQPConnectionContext.java:388) [artemis-amqp-protocol-1.5.0.amq-700002-redhat-1.jar:]
      	at org.apache.activemq.artemis.protocol.amqp.proton.handler.Events.dispatch(Events.java:82) [artemis-amqp-protocol-1.5.0.amq-700002-redhat-1.jar:]
      	at org.apache.activemq.artemis.protocol.amqp.proton.handler.ProtonHandler.dispatch(ProtonHandler.java:342) [artemis-amqp-protocol-1.5.0.amq-700002-redhat-1.jar:]
      	at org.apache.activemq.artemis.protocol.amqp.proton.handler.ProtonHandler.access$000(ProtonHandler.java:42) [artemis-amqp-protocol-1.5.0.amq-700002-redhat-1.jar:]
      	at org.apache.activemq.artemis.protocol.amqp.proton.handler.ProtonHandler$1.run(ProtonHandler.java:61) [artemis-amqp-protocol-1.5.0.amq-700002-redhat-1.jar:]
      	at org.apache.activemq.artemis.utils.OrderedExecutorFactory$OrderedExecutor$ExecutorTask.run(OrderedExecutorFactory.java:101) [artemis-commons-1.5.0.amq-700002-redhat-1.jar:1.5.0.amq-700002-redhat-1]
      	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142) [rt.jar:1.8.0_111]
      	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617) [rt.jar:1.8.0_111]
      	at java.lang.Thread.run(Thread.java:745) [rt.jar:1.8.0_111]
      
      [1857313193:0] -> Begin{remoteChannel=0, nextOutgoingId=1, incomingWindow=2147483647, outgoingWindow=2147483647, handleMax=65535, offeredCapabilities=null, desiredCapabilities=null, properties=null}
      [1857313193:0] -> Attach{name='23643712-8604-48ce-bad4-b8f7b7093ad4-jms.queue.test', handle=0, role=SENDER, sndSettleMode=MIXED, rcvSettleMode=FIRST, source=Source{address='jms.queue.test', durable=NONE, expiryPolicy=SESSION_END, timeout=0, dynamic=false, dynamicNodeProperties=null, distributionMode=null, filter={selector=org.apache.qpid.proton.codec.DecoderImpl$UnknownDescribedType@1143432f}, defaultOutcome=null, outcomes=null, capabilities=null}, target=Target{address='null', durable=NONE, expiryPolicy=SESSION_END, timeout=0, dynamic=false, dynamicNodeProperties=null, capabilities=null}, unsettled=null, incompleteUnsettled=false, initialDeliveryCount=0, maxMessageSize=null, offeredCapabilities=null, desiredCapabilities=null, properties=null}
      [1857313193:0] <- Detach{handle=0, closed=true, error=null}
      [1857313193:0] <- Close{error=null}
      [1857313193:0] -> Detach{handle=0, closed=true, error=null}
      [1857313193:0] -> Close{error=null}
      10:31:52,630 WARN  [org.apache.activemq.artemis.core.client] AMQ212037: Connection failure has been detected: null [code=REMOTE_DISCONNECT]
      

      Attachments

        Issue Links

          Activity

            People

              rh-ee-ataylor Andy Taylor
              dkornel@redhat.com David Kornel
              Votes:
              0 Vote for this issue
              Watchers:
              2 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: