You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by rh...@apache.org on 2007/01/16 19:25:55 UTC
svn commit: r496810 -
/incubator/qpid/branches/qpid.0-9/java/broker/src/main/java/org/apache/qpid/server/handler/ConnectionStartOkMethodHandler.java
Author: rhs
Date: Tue Jan 16 10:25:55 2007
New Revision: 496810
URL: http://svn.apache.org/viewvc?view=rev&rev=496810
Log:
fixed a braino in ConnectionStartOk
Modified:
incubator/qpid/branches/qpid.0-9/java/broker/src/main/java/org/apache/qpid/server/handler/ConnectionStartOkMethodHandler.java
Modified: incubator/qpid/branches/qpid.0-9/java/broker/src/main/java/org/apache/qpid/server/handler/ConnectionStartOkMethodHandler.java
URL: http://svn.apache.org/viewvc/incubator/qpid/branches/qpid.0-9/java/broker/src/main/java/org/apache/qpid/server/handler/ConnectionStartOkMethodHandler.java?view=diff&rev=496810&r1=496809&r2=496810
==============================================================================
--- incubator/qpid/branches/qpid.0-9/java/broker/src/main/java/org/apache/qpid/server/handler/ConnectionStartOkMethodHandler.java (original)
+++ incubator/qpid/branches/qpid.0-9/java/broker/src/main/java/org/apache/qpid/server/handler/ConnectionStartOkMethodHandler.java Tue Jan 16 10:25:55 2007
@@ -100,7 +100,7 @@
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 @@
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)