[
https://issues.apache.org/jira/browse/QPID-6056?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Keith Wall resolved QPID-6056.
------------------------------
Resolution: Invalid
> [JMS Client 0.8/0.9.x] JMS client can send null as an exchange name in
> ExchangeBound command
> --------------------------------------------------------------------------------------------
>
> Key: QPID-6056
> URL: https://issues.apache.org/jira/browse/QPID-6056
> Project: Qpid
> Issue Type: Bug
> Components: Java Client
> Affects Versions: 0.30
> Reporter: Alex Rudyy
> Priority: Critical
>
> JMS client can send null as an exchange name in ExchangeBound command
> Client log:
> {noformat}
> main 2014-08-29 11:42:44,985 DEBUG [qpid.protocol] SEND:
> [org.apache.qpid.client.protocol.AMQProtocolHandler@62725296] Frame
> channelId: 2, bodyFrame: [ExchangeBoundBodyImpl: exchange=amq.direct,
> routingKey=selectors, queue=selectors]
> IoReceiver - /127.0.0.1:56724 2014-08-29 11:42:44,985 INFO [qpid.protocol]
> RECV: [org.apache.qpid.client.protocol.AMQProtocolHandler@62725296] Frame
> channelId: 2, bodyFrame: [ExchangeBoundOkBodyImpl: replyCode=0,
> replyText=null]
> IoReceiver - /127.0.0.1:56724 2014-08-29 11:42:44,985 DEBUG
> [qpid.client.protocol.AMQProtocolHandler] (1651659414)Method frame received:
> [ExchangeBoundOkBodyImpl: replyCode=0, replyText=null]
> IoReceiver - /127.0.0.1:56724 2014-08-29 11:42:44,985 DEBUG
> [qpid.client.handler.ExchangeBoundOkMethodHandler] Received Exchange.Bound-Ok
> message, response code: 0 text: null
> main 2014-08-29 11:42:44,985 DEBUG [apache.qpid.client.AMQSession] Setting
> channel flow : suspended
> main 2014-08-29 11:42:44,985 DEBUG [qpid.protocol] SEND:
> [org.apache.qpid.client.protocol.AMQProtocolHandler@62725296] Frame
> channelId: 2, bodyFrame: [ChannelFlowBodyImpl: active=false]
> IoReceiver - /127.0.0.1:56724 2014-08-29 11:42:44,986 INFO [qpid.protocol]
> RECV: [org.apache.qpid.client.protocol.AMQProtocolHandler@62725296] Frame
> channelId: 2, bodyFrame: [ChannelFlowOkBodyImpl: active=false]
> IoReceiver - /127.0.0.1:56724 2014-08-29 11:42:44,986 DEBUG
> [qpid.client.protocol.AMQProtocolHandler] (1651659414)Method frame received:
> [ChannelFlowOkBodyImpl: active=false]
> IoReceiver - /127.0.0.1:56724 2014-08-29 11:42:44,986 DEBUG
> [qpid.client.handler.ChannelFlowOkMethodHandler] Received Channel.Flow-Ok
> message, active = false
> main 2014-08-29 11:42:44,986 DEBUG [apache.qpid.client.AMQSession]
> Prefetching delayed existing messages will not flow until requested via
> receive*() or setML().
> main 2014-08-29 11:42:44,987 DEBUG [apache.qpid.framing.FieldTable]
> FieldTable::writeToBuffer: Writing encoded length of 27...
> main 2014-08-29 11:42:44,987 DEBUG [apache.qpid.framing.FieldTable]
> {x-filter-jms-selector=[LONG_STRING: ]}
> main 2014-08-29 11:42:44,987 DEBUG [qpid.protocol] SEND:
> [org.apache.qpid.client.protocol.AMQProtocolHandler@62725296] Frame
> channelId: 2, bodyFrame: [BasicConsumeBodyImpl: ticket=0, queue=selectors,
> consumerTag=1, noLocal=false, noAck=true, exclusive=false, nowait=false,
> arguments={x-filter-jms-selector=[LONG_STRING: ]}]
> IoReceiver - /127.0.0.1:56724 2014-08-29 11:42:44,994 INFO [qpid.protocol]
> RECV: [org.apache.qpid.client.protocol.AMQProtocolHandler@62725296] Frame
> channelId: 2, bodyFrame: [BasicConsumeOkBodyImpl: consumerTag=1]
> IoReceiver - /127.0.0.1:56724 2014-08-29 11:42:44,994 DEBUG
> [qpid.client.protocol.AMQProtocolHandler] (1651659414)Method frame received:
> [BasicConsumeOkBodyImpl: consumerTag=1]
> main 2014-08-29 11:42:44,995 DEBUG
> [apache.qpid.client.AMQConnectionDelegate_8_0] supportsIsBound: true
> main 2014-08-29 11:42:44,996 DEBUG [qpid.protocol] SEND:
> [org.apache.qpid.client.protocol.AMQProtocolHandler@62725296] Frame
> channelId: 2, bodyFrame: [ExchangeBoundBodyImpl: exchange=null,
> routingKey=null, queue=selectors]
> IoReceiver - /127.0.0.1:56724 2014-08-29 11:42:45,004 DEBUG
> [qpid.client.protocol.AMQProtocolHandler] Session closed called with failover
> state FailoverState: NOT STARTED
> IoReceiver - /127.0.0.1:56724 2014-08-29 11:42:45,005 DEBUG
> [apache.qpid.jms.FailoverPolicy] All failover methods exhausted
> IoReceiver - /127.0.0.1:56724 2014-08-29 11:42:45,005 DEBUG
> [apache.qpid.jms.FailoverPolicy] All failover methods exhausted
> IoReceiver - /127.0.0.1:56724 2014-08-29 11:42:45,005 DEBUG
> [qpid.client.protocol.AMQProtocolHandler] Failover not allowed by
> policy:Failover Policy:
> Failover not allowed
> Failover policy methods
> >Single Server:
> Max Retries:0
> Current Retry:0
> tcp://127.0.0.1:56724
> IoReceiver - /127.0.0.1:56724 2014-08-29 11:42:45,006 DEBUG
> [apache.qpid.client.AMQConnection] exceptionReceived done by:IoReceiver -
> /127.0.0.1:56724
> org.apache.qpid.AMQDisconnectedException: Server closed connection and
> reconnection not permitted.
> at
> org.apache.qpid.client.protocol.AMQProtocolHandler.closed(AMQProtocolHandler.java:275)
> at
> org.apache.qpid.transport.network.io.IoReceiver.run(IoReceiver.java:222)
> at java.lang.Thread.run(Thread.java:745)
> IoReceiver - /127.0.0.1:56724 2014-08-29 11:42:45,009 DEBUG
> [qpid.client.state.AMQStateManager] State changing to AMQState: id = 6 name:
> CONNECTION_CLOSED from old state AMQState: id = 4 name: CONNECTION_OPEN
> IoReceiver - /127.0.0.1:56724 2014-08-29 11:42:45,009 DEBUG
> [qpid.client.state.AMQStateManager] Notififying State change to 0 : []
> IoReceiver - /127.0.0.1:56724 2014-08-29 11:42:45,009 INFO
> [qpid.client.state.AMQStateManager] No Waiters for error. Saving as last
> error:Exception thrown against AMQConnection:
> Host: 127.0.0.1
> Port: 56724
> Virtual Host:
> Client ID: clientid
> Active session count: 2: org.apache.qpid.AMQDisconnectedException: Server
> closed connection and reconnection not permitted.
> main 2014-08-29 11:42:45,009 DEBUG [apache.qpid.client.AMQSession] Closing
> session: org.apache.qpid.client.AMQSession_0_8@65babc5c
> main 2014-08-29 11:42:45,010 DEBUG [apache.qpid.client.BasicMessageConsumer]
> Closing consumer:1[1400948206]
> main 2014-08-29 11:42:45,011 ERROR [qpid.disttest.controller.TestRunner]
> Couldn't run test
> org.apache.qpid.disttest.DistributedTestException: Failed to drain
> queue:direct://amq.direct/selectors/selectors?routingkey='selectors'
> at
> org.apache.qpid.disttest.jms.QpidQueueCreator.drainQueue(QpidQueueCreator.java:122)
> at
> org.apache.qpid.disttest.jms.QpidQueueCreator.deleteQueues(QpidQueueCreator.java:64)
> at
> org.apache.qpid.disttest.jms.ControllerJmsDelegate.deleteQueues(ControllerJmsDelegate.java:233)
> at
> org.apache.qpid.disttest.controller.TestRunner.deleteQueues(TestRunner.java:237)
> at
> org.apache.qpid.disttest.controller.TestRunner.runParts(TestRunner.java:145)
> at
> org.apache.qpid.disttest.controller.TestRunner.run(TestRunner.java:104)
> at
> org.apache.qpid.disttest.controller.Controller.runAllTests(Controller.java:171)
> at
> org.apache.qpid.disttest.ControllerRunner.runTest(ControllerRunner.java:157)
> at
> org.apache.qpid.disttest.ControllerRunner.runTests(ControllerRunner.java:136)
> at
> org.apache.qpid.disttest.ControllerRunner.runController(ControllerRunner.java:90)
> at
> org.apache.qpid.disttest.ControllerRunner.main(ControllerRunner.java:77)
> Caused by: org.apache.qpid.disttest.DistributedTestException: Failed to query
> queue depth:direct://amq.direct/selectors/selectors?routingkey='selectors'
> at
> org.apache.qpid.disttest.jms.QpidQueueCreator.getQueueDepth(QpidQueueCreator.java:91)
> at
> org.apache.qpid.disttest.jms.QpidQueueCreator.drainQueue(QpidQueueCreator.java:104)
> ... 10 more
> Caused by: org.apache.qpid.AMQException: Woken up due to class
> javax.jms.JMSException
> at
> org.apache.qpid.client.util.BlockingWaiter.block(BlockingWaiter.java:195)
> at
> org.apache.qpid.client.protocol.BlockingMethodFrameListener.blockForFrame(BlockingMethodFrameListener.java:115)
> at
> org.apache.qpid.client.protocol.AMQProtocolHandler.writeCommandFrameAndWaitForReply(AMQProtocolHandler.java:709)
> at
> org.apache.qpid.client.protocol.AMQProtocolHandler.syncWrite(AMQProtocolHandler.java:730)
> at
> org.apache.qpid.client.protocol.AMQProtocolHandler.syncWrite(AMQProtocolHandler.java:724)
> at
> org.apache.qpid.client.AMQSession_0_8.sendExchangeBound(AMQSession_0_8.java:506)
> at
> org.apache.qpid.client.AMQSession_0_8.access$100(AMQSession_0_8.java:70)
> at
> org.apache.qpid.client.AMQSession_0_8$2.execute(AMQSession_0_8.java:462)
> at
> org.apache.qpid.client.AMQSession_0_8$2.execute(AMQSession_0_8.java:459)
> at
> org.apache.qpid.client.failover.FailoverNoopSupport.execute(FailoverNoopSupport.java:67)
> at
> org.apache.qpid.client.AMQSession_0_8.isBound(AMQSession_0_8.java:457)
> at
> org.apache.qpid.client.AMQSession_0_8.requestQueueDepth(AMQSession_0_8.java:881)
> at org.apache.qpid.client.AMQSession$8.execute(AMQSession.java:2851)
> at org.apache.qpid.client.AMQSession$8.execute(AMQSession.java:2846)
> at
> org.apache.qpid.client.failover.FailoverNoopSupport.execute(FailoverNoopSupport.java:67)
> at org.apache.qpid.client.AMQSession.getQueueDepth(AMQSession.java:2845)
> at org.apache.qpid.client.AMQSession.getQueueDepth(AMQSession.java:2830)
> at
> org.apache.qpid.disttest.jms.QpidQueueCreator.getQueueDepth(QpidQueueCreator.java:86)
> ... 11 more
> Caused by: javax.jms.JMSException: Exception thrown against AMQConnection:
> Host: 127.0.0.1
> Port: 56724
> Virtual Host:
> Client ID: clientid
> Active session count: 2: org.apache.qpid.AMQDisconnectedException: Server
> closed connection and reconnection not permitted.
> at
> org.apache.qpid.client.AMQConnection.exceptionReceived(AMQConnection.java:1313)
> at
> org.apache.qpid.client.protocol.AMQProtocolHandler.closed(AMQProtocolHandler.java:275)
> at
> org.apache.qpid.transport.network.io.IoReceiver.run(IoReceiver.java:222)
> at java.lang.Thread.run(Thread.java:745)
> Caused by: org.apache.qpid.AMQDisconnectedException: Server closed connection
> and reconnection not permitted.
> ... 3 more
> main 2014-08-29 11:42:45,014 ERROR [apache.qpid.disttest.ControllerRunner]
> Problem running test
> org.apache.qpid.disttest.DistributedTestException: Failed to drain
> queue:direct://amq.direct/selectors/selectors?routingkey='selectors'
> at
> org.apache.qpid.disttest.jms.QpidQueueCreator.drainQueue(QpidQueueCreator.java:122)
> at
> org.apache.qpid.disttest.jms.QpidQueueCreator.deleteQueues(QpidQueueCreator.java:64)
> at
> org.apache.qpid.disttest.jms.ControllerJmsDelegate.deleteQueues(ControllerJmsDelegate.java:233)
> at
> org.apache.qpid.disttest.controller.TestRunner.deleteQueues(TestRunner.java:237)
> at
> org.apache.qpid.disttest.controller.TestRunner.runParts(TestRunner.java:145)
> at
> org.apache.qpid.disttest.controller.TestRunner.run(TestRunner.java:104)
> at
> org.apache.qpid.disttest.controller.Controller.runAllTests(Controller.java:171)
> at
> org.apache.qpid.disttest.ControllerRunner.runTest(ControllerRunner.java:157)
> at
> org.apache.qpid.disttest.ControllerRunner.runTests(ControllerRunner.java:136)
> at
> org.apache.qpid.disttest.ControllerRunner.runController(ControllerRunner.java:90)
> at
> org.apache.qpid.disttest.ControllerRunner.main(ControllerRunner.java:77)
> Caused by: org.apache.qpid.disttest.DistributedTestException: Failed to query
> queue depth:direct://amq.direct/selectors/selectors?routingkey='selectors'
> at
> org.apache.qpid.disttest.jms.QpidQueueCreator.getQueueDepth(QpidQueueCreator.java:91)
> at
> org.apache.qpid.disttest.jms.QpidQueueCreator.drainQueue(QpidQueueCreator.java:104)
> ... 10 more
> Caused by: org.apache.qpid.AMQException: Woken up due to class
> javax.jms.JMSException
> at
> org.apache.qpid.client.util.BlockingWaiter.block(BlockingWaiter.java:195)
> at
> org.apache.qpid.client.protocol.BlockingMethodFrameListener.blockForFrame(BlockingMethodFrameListener.java:115)
> at
> org.apache.qpid.client.protocol.AMQProtocolHandler.writeCommandFrameAndWaitForReply(AMQProtocolHandler.java:709)
> at
> org.apache.qpid.client.protocol.AMQProtocolHandler.syncWrite(AMQProtocolHandler.java:730)
> at
> org.apache.qpid.client.protocol.AMQProtocolHandler.syncWrite(AMQProtocolHandler.java:724)
> at
> org.apache.qpid.client.AMQSession_0_8.sendExchangeBound(AMQSession_0_8.java:506)
> at
> org.apache.qpid.client.AMQSession_0_8.access$100(AMQSession_0_8.java:70)
> at
> org.apache.qpid.client.AMQSession_0_8$2.execute(AMQSession_0_8.java:462)
> at
> org.apache.qpid.client.AMQSession_0_8$2.execute(AMQSession_0_8.java:459)
> at
> org.apache.qpid.client.failover.FailoverNoopSupport.execute(FailoverNoopSupport.java:67)
> at
> org.apache.qpid.client.AMQSession_0_8.isBound(AMQSession_0_8.java:457)
> at
> org.apache.qpid.client.AMQSession_0_8.requestQueueDepth(AMQSession_0_8.java:881)
> at org.apache.qpid.client.AMQSession$8.execute(AMQSession.java:2851)
> at org.apache.qpid.client.AMQSession$8.execute(AMQSession.java:2846)
> at
> org.apache.qpid.client.failover.FailoverNoopSupport.execute(FailoverNoopSupport.java:67)
> at org.apache.qpid.client.AMQSession.getQueueDepth(AMQSession.java:2845)
> at org.apache.qpid.client.AMQSession.getQueueDepth(AMQSession.java:2830)
> at
> org.apache.qpid.disttest.jms.QpidQueueCreator.getQueueDepth(QpidQueueCreator.java:86)
> ... 11 more
> Caused by: javax.jms.JMSException: Exception thrown against AMQConnection:
> Host: 127.0.0.1
> Port: 56724
> Virtual Host:
> Client ID: clientid
> Active session count: 2: org.apache.qpid.AMQDisconnectedException: Server
> closed connection and reconnection not permitted.
> at
> org.apache.qpid.client.AMQConnection.exceptionReceived(AMQConnection.java:1313)
> at
> org.apache.qpid.client.protocol.AMQProtocolHandler.closed(AMQProtocolHandler.java:275)
> at
> org.apache.qpid.transport.network.io.IoReceiver.run(IoReceiver.java:222)
> at java.lang.Thread.run(Thread.java:745)
> Caused by: org.apache.qpid.AMQDisconnectedException: Server closed connection
> and reconnection not permitted.
> ... 3 more
> main 2014-08-29 11:42:45,016 INFO [qpid.disttest.controller.Controller]
> Stopping all clients
> {noformat}
> Broker log:
> {noformat}
> 2014-08-29 11:42:44,997 ERROR [IoReceiver - /127.0.0.1:34522]
> (protocol.AMQProtocolEngine) - Unexpected exception while processing frame.
> Closing connection.
> org.apache.qpid.AMQException: Exchange exchange must not be null
> at
> org.apache.qpid.server.handler.ExchangeBoundHandler.methodReceived(ExchangeBoundHandler.java:89)
> at
> org.apache.qpid.server.handler.ServerMethodDispatcherImpl.dispatchExchangeBound(ServerMethodDispatcherImpl.java:458)
> at
> org.apache.qpid.framing.amqp_0_9.ExchangeBoundBodyImpl.execute(ExchangeBoundBodyImpl.java:130)
> at
> org.apache.qpid.server.state.AMQStateManager.methodReceived(AMQStateManager.java:120)
> at
> org.apache.qpid.server.protocol.AMQProtocolEngine.methodFrameReceived(AMQProtocolEngine.java:569)
> at
> org.apache.qpid.framing.AMQMethodBodyImpl.handle(AMQMethodBodyImpl.java:97)
> at
> org.apache.qpid.server.protocol.AMQProtocolEngine.frameReceived(AMQProtocolEngine.java:433)
> at
> org.apache.qpid.server.protocol.AMQProtocolEngine.dataBlockReceived(AMQProtocolEngine.java:356)
> at
> org.apache.qpid.server.protocol.AMQProtocolEngine.received(AMQProtocolEngine.java:277)
> at
> org.apache.qpid.server.protocol.AMQProtocolEngine.received(AMQProtocolEngine.java:103)
> at
> org.apache.qpid.server.protocol.MultiVersionProtocolEngine.received(MultiVersionProtocolEngine.java:118)
> at
> org.apache.qpid.server.protocol.MultiVersionProtocolEngine.received(MultiVersionProtocolEngine.java:37)
> at
> org.apache.qpid.transport.network.io.IoReceiver.run(IoReceiver.java:161)
> at java.lang.Thread.run(Thread.java:745)
> {noformat}
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
