From d0a65ec42e689dcb4afec22eb8f6d64584b888e0 Mon Sep 17 00:00:00 2001 From: Robert Godfrey Date: Mon, 26 Nov 2012 14:07:59 +0000 Subject: QPID-4472 : [Java Broker] NPE with non-SASL AMQP 1.0 Connection git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1413627 13f79535-47bb-0310-9956-ffa450edef68 --- .../org/apache/qpid/server/protocol/MultiVersionProtocolEngine.java | 2 +- .../java/org/apache/qpid/server/protocol/ProtocolEngine_1_0_0.java | 6 +++++- 2 files changed, 6 insertions(+), 2 deletions(-) (limited to 'qpid/java') diff --git a/qpid/java/broker/src/main/java/org/apache/qpid/server/protocol/MultiVersionProtocolEngine.java b/qpid/java/broker/src/main/java/org/apache/qpid/server/protocol/MultiVersionProtocolEngine.java index 707f02d4a5..c8126b3677 100755 --- a/qpid/java/broker/src/main/java/org/apache/qpid/server/protocol/MultiVersionProtocolEngine.java +++ b/qpid/java/broker/src/main/java/org/apache/qpid/server/protocol/MultiVersionProtocolEngine.java @@ -341,7 +341,7 @@ public class MultiVersionProtocolEngine implements ServerProtocolEngine public ServerProtocolEngine getProtocolEngine() { - return new ProtocolEngine_1_0_0(_appRegistry,_id); + return new ProtocolEngine_1_0_0(_network, _appRegistry,_id); } }; diff --git a/qpid/java/broker/src/main/java/org/apache/qpid/server/protocol/ProtocolEngine_1_0_0.java b/qpid/java/broker/src/main/java/org/apache/qpid/server/protocol/ProtocolEngine_1_0_0.java index 274f206c85..715a512b47 100755 --- a/qpid/java/broker/src/main/java/org/apache/qpid/server/protocol/ProtocolEngine_1_0_0.java +++ b/qpid/java/broker/src/main/java/org/apache/qpid/server/protocol/ProtocolEngine_1_0_0.java @@ -99,10 +99,14 @@ public class ProtocolEngine_1_0_0 implements ServerProtocolEngine, FrameOutputHa - public ProtocolEngine_1_0_0(final IApplicationRegistry appRegistry, long id) + public ProtocolEngine_1_0_0(final NetworkConnection networkDriver, final IApplicationRegistry appRegistry, long id) { _appRegistry = appRegistry; _connectionId = id; + if(networkDriver != null) + { + setNetworkConnection(networkDriver, networkDriver.getSender()); + } } -- cgit v1.2.1