diff --git a/httpcore5/src/main/java/org/apache/hc/core5/reactor/SingleCoreIOReactor.java b/httpcore5/src/main/java/org/apache/hc/core5/reactor/SingleCoreIOReactor.java index 248ce1049..a9c936554 100644 --- a/httpcore5/src/main/java/org/apache/hc/core5/reactor/SingleCoreIOReactor.java +++ b/httpcore5/src/main/java/org/apache/hc/core5/reactor/SingleCoreIOReactor.java @@ -214,8 +214,8 @@ private void processPendingChannels() throws IOException { ioSessionDecorator, sessionListener, closedSessions); - dataChannel.upgrade(this.eventHandlerFactory.createHandler(dataChannel, attachment)); dataChannel.setSocketTimeout(this.reactorConfig.getSoTimeout()); + dataChannel.upgrade(this.eventHandlerFactory.createHandler(dataChannel, attachment)); key.attach(dataChannel); dataChannel.handleIOEvent(SelectionKey.OP_CONNECT); }