summaryrefslogtreecommitdiff
path: root/java
diff options
context:
space:
mode:
authorRafael H. Schloming <rhs@apache.org>2007-01-16 18:25:55 +0000
committerRafael H. Schloming <rhs@apache.org>2007-01-16 18:25:55 +0000
commitc571a31eb5355649f8c539188a6ed64109ad161e (patch)
tree710b767ef373fefd7705e870f6e0bdcc6a80fdb0 /java
parent72808053545e0723bf6dbbc0e738097d5ea13e28 (diff)
downloadqpid-python-c571a31eb5355649f8c539188a6ed64109ad161e.tar.gz
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
Diffstat (limited to 'java')
-rw-r--r--java/broker/src/main/java/org/apache/qpid/server/handler/ConnectionStartOkMethodHandler.java4
1 files changed, 2 insertions, 2 deletions
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)