[QPID-5673] [Java Broker] NPE when attempting to connect to an unknown Virtual Host using AMQP 1.0

• Type: Bug
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 0.27
• Fix Version/s: 0.28
• Component/s: Broker-J
• Assignee: Robbie Gemmell
• Reporter: Justin Ross
• Created: 09/Apr/14 14:20
• Updated: 03/Jun/14 15:34
• Resolved: 01/May/14 13:19

Description

When I try to authenticate with an existing user (admin:admin), I get the exception. When I try to authenticate with a made-up user (test:test), I get a "(null)" error response.

Exception:

java.lang.NullPointerException
	at org.apache.qpid.server.protocol.v1_0.Connection_1_0.closeReceived(Connection_1_0.java:220)
	at org.apache.qpid.amqp_1_0.transport.ConnectionEndpoint.receiveClose(ConnectionEndpoint.java:369)
	at org.apache.qpid.amqp_1_0.type.transport.Close.invoke(Close.java:75)
	at org.apache.qpid.amqp_1_0.transport.ConnectionEndpoint.receive(ConnectionEndpoint.java:731)
	at org.apache.qpid.amqp_1_0.framing.FrameHandler.parse(FrameHandler.java:242)
	at org.apache.qpid.server.protocol.v1_0.ProtocolEngine_1_0_0_SASL$3.run(ProtocolEngine_1_0_0_SASL.java:367)
	at org.apache.qpid.server.protocol.v1_0.ProtocolEngine_1_0_0_SASL$3.run(ProtocolEngine_1_0_0_SASL.java:363)
	at java.security.AccessController.doPrivileged(Native Method)
	at javax.security.auth.Subject.doAs(Subject.java:356)
	at org.apache.qpid.server.protocol.v1_0.ProtocolEngine_1_0_0_SASL.received(ProtocolEngine_1_0_0_SASL.java:362)
	at org.apache.qpid.server.protocol.v1_0.ProtocolEngine_1_0_0_SASL.received(ProtocolEngine_1_0_0_SASL.java:64)
	at org.apache.qpid.server.protocol.MultiVersionProtocolEngine.received(MultiVersionProtocolEngine.java:132)
	at org.apache.qpid.server.protocol.MultiVersionProtocolEngine.received(MultiVersionProtocolEngine.java:48)
	at org.apache.qpid.transport.network.io.IoReceiver.run(IoReceiver.java:161)
	at java.lang.Thread.run(Thread.java:744)

Test code:

from proton import Message, Messenger

msgr = Messenger()
msgr.start()

try:
    msg = Message()
    msg.address = "amqp://admin:admin@0.0.0.0:5672/test"
    msg.body = "test"

    msgr.put(msg)
    msgr.send()
finally:
    msgr.stop()