This repository was archived by the owner on Jul 21, 2023. It is now read-only.
File tree 1 file changed +4
-3
lines changed
providers/grizzly/src/main/java/com/ning/http/client/providers/grizzly 1 file changed +4
-3
lines changed Original file line number Diff line number Diff line change 17
17
import com .ning .http .client .ConnectionsPool ;
18
18
19
19
import org .glassfish .grizzly .CloseListener ;
20
+ import org .glassfish .grizzly .CloseType ;
20
21
import org .glassfish .grizzly .Connection ;
21
22
import org .glassfish .grizzly .Grizzly ;
22
23
import org .glassfish .grizzly .attributes .Attribute ;
@@ -73,10 +74,10 @@ public GrizzlyConnectionsPool(final AsyncHttpClientConfig config) {
73
74
unlimitedConnections = (maxConnections == -1 );
74
75
delayedExecutor = new DelayedExecutor (Executors .newSingleThreadExecutor ());
75
76
delayedExecutor .start ();
76
- listener = new Connection . CloseListener () {
77
+ listener = new CloseListener < Connection , CloseType > () {
77
78
@ Override
78
- public void onClosed (Connection connection , Connection . CloseType closeType ) throws IOException {
79
- if (closeType == Connection . CloseType .REMOTELY ) {
79
+ public void onClosed (Connection connection , CloseType closeType ) throws IOException {
80
+ if (closeType == CloseType .REMOTELY ) {
80
81
if (LOG .isInfoEnabled ()) {
81
82
LOG .info ("Remote closed connection ({}). Removing from cache" , connection .toString ());
82
83
}
You can’t perform that action at this time.
0 commit comments