svn commit: r496810 - /incubator/qpid/branches/qpid.0-9/java/broker/src/main/java/org/apache/qpid/server/handler/ConnectionStartOkMethodHandler.java

[rhs]

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)