@@ -66,7 +66,7 @@ public class JSR356Endpoint extends Endpoint {
66
66
private AtmosphereRequest request ;
67
67
private final AtmosphereFramework framework ;
68
68
private WebSocket webSocket ;
69
- private final int webSocketWriteTimeout ;
69
+ private final int webSocketIdleTimeoutMs ;
70
70
private HttpSession handshakeSession ;
71
71
private Map <String , List <String >> handshakeHeaders ;
72
72
@@ -80,9 +80,9 @@ public JSR356Endpoint(AtmosphereFramework framework, WebSocketProcessor webSocke
80
80
81
81
String s = framework .getAtmosphereConfig ().getInitParameter (ApplicationConfig .WEBSOCKET_IDLETIME );
82
82
if (s != null ) {
83
- webSocketWriteTimeout = Integer .parseInt (s );
83
+ webSocketIdleTimeoutMs = Integer .parseInt (s );
84
84
} else {
85
- webSocketWriteTimeout = -1 ;
85
+ webSocketIdleTimeoutMs = -1 ;
86
86
}
87
87
88
88
s = framework .getAtmosphereConfig ().getInitParameter (ApplicationConfig .WEBSOCKET_MAXBINARYSIZE );
@@ -118,7 +118,7 @@ public void onOpen(Session session, final EndpointConfig endpointConfig) {
118
118
}
119
119
120
120
if (maxBinaryBufferSize != -1 ) session .setMaxBinaryMessageBufferSize (maxBinaryBufferSize );
121
- if (webSocketWriteTimeout != -1 ) session .setMaxIdleTimeout (webSocketWriteTimeout );
121
+ if (webSocketIdleTimeoutMs != -1 ) session .setMaxIdleTimeout (webSocketIdleTimeoutMs );
122
122
if (maxTextBufferSize != -1 ) session .setMaxTextMessageBufferSize (maxTextBufferSize );
123
123
124
124
webSocket = new JSR356WebSocket (session , framework .getAtmosphereConfig ());
0 commit comments