Fixed ClassCastExceptions.

This commit is contained in:
Simone Bordet 2012-02-28 09:35:09 +01:00
parent 268e8bdbd7
commit a07a7525ff
1 changed files with 2 additions and 2 deletions

View File

@ -128,7 +128,7 @@ public class SPDYServerConnector extends SelectChannelConnector
public void unsupported() public void unsupported()
{ {
AsyncConnectionFactory connectionFactory = getDefaultAsyncConnectionFactory(); AsyncConnectionFactory connectionFactory = getDefaultAsyncConnectionFactory();
AsyncConnection connection = connectionFactory.newAsyncConnection(channel, sslEndPoint, this); AsyncConnection connection = connectionFactory.newAsyncConnection(channel, sslEndPoint, SPDYServerConnector.this);
sslEndPoint.setConnection(connection); sslEndPoint.setConnection(connection);
} }
@ -142,7 +142,7 @@ public class SPDYServerConnector extends SelectChannelConnector
public void protocolSelected(String protocol) public void protocolSelected(String protocol)
{ {
AsyncConnectionFactory connectionFactory = getAsyncConnectionFactory(protocol); AsyncConnectionFactory connectionFactory = getAsyncConnectionFactory(protocol);
AsyncConnection connection = connectionFactory.newAsyncConnection(channel, sslEndPoint, this); AsyncConnection connection = connectionFactory.newAsyncConnection(channel, sslEndPoint, SPDYServerConnector.this);
sslEndPoint.setConnection(connection); sslEndPoint.setConnection(connection);
} }
}); });