From c571a31eb5355649f8c539188a6ed64109ad161e Mon Sep 17 00:00:00 2001 From: "Rafael H. Schloming" Date: Tue, 16 Jan 2007 18:25:55 +0000 Subject: fixed a braino in ConnectionStartOk git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@496810 13f79535-47bb-0310-9956-ffa450edef68 --- .../apache/qpid/server/handler/ConnectionStartOkMethodHandler.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) (limited to 'java') diff --git a/java/broker/src/main/java/org/apache/qpid/server/handler/ConnectionStartOkMethodHandler.java b/java/broker/src/main/java/org/apache/qpid/server/handler/ConnectionStartOkMethodHandler.java index 1745fd03f6..efe6dce884 100644 --- a/java/broker/src/main/java/org/apache/qpid/server/handler/ConnectionStartOkMethodHandler.java +++ b/java/broker/src/main/java/org/apache/qpid/server/handler/ConnectionStartOkMethodHandler.java @@ -100,7 +100,7 @@ public class ConnectionStartOkMethodHandler implements StateAwareMethodListener< Integer.MAX_VALUE, // channelMax getConfiguredFrameSize(), // frameMax HeartbeatConfig.getInstance().getDelay()); // heartbeat - protocolSession.writeResponse(evt, tune); + protocolSession.writeRequest(evt.getChannelId(), tune, stateManager); break; case CONTINUE: stateManager.changeState(AMQState.CONNECTION_NOT_AUTH); @@ -110,7 +110,7 @@ public class ConnectionStartOkMethodHandler implements StateAwareMethodListener< AMQMethodBody challenge = ConnectionSecureBody.createMethodBody ((byte)0, (byte)9, // AMQP version (major, minor) authResult.challenge); // challenge - protocolSession.writeResponse(evt, challenge); + protocolSession.writeRequest(evt.getChannelId(), challenge, stateManager); } } catch (SaslException e) -- cgit v1.2.1