@@ -96,7 +96,7 @@ protected void onProtocolMessage(List<Header> headers, byte[] payload, MessageTy
9696 clientBootstrap .close ();
9797 clientBootstrap .getShutdownCompleteFuture ().get (1 , TimeUnit .SECONDS );
9898 elGroup .close ();
99- elGroup .getShutdownCompleteFuture ().get (1 , TimeUnit .SECONDS );
99+ elGroup .getShutdownCompleteFuture ().get (5 , TimeUnit .SECONDS );
100100 socketOptions .close ();
101101 }
102102
@@ -204,7 +204,7 @@ protected void onProtocolMessage(List<Header> headers, byte[] payload, MessageTy
204204 clientBootstrap .close ();
205205 clientBootstrap .getShutdownCompleteFuture ().get (1 , TimeUnit .SECONDS );
206206 elGroup .close ();
207- elGroup .getShutdownCompleteFuture ().get (1 , TimeUnit .SECONDS );
207+ elGroup .getShutdownCompleteFuture ().get (5 , TimeUnit .SECONDS );
208208 socketOptions .close ();
209209 }
210210
@@ -339,7 +339,7 @@ protected void onProtocolMessage(List<Header> headers, byte[] payload, MessageTy
339339 clientBootstrap .close ();
340340 clientBootstrap .getShutdownCompleteFuture ().get (1 , TimeUnit .SECONDS );
341341 elGroup .close ();
342- elGroup .getShutdownCompleteFuture ().get (1 , TimeUnit .SECONDS );
342+ elGroup .getShutdownCompleteFuture ().get (5 , TimeUnit .SECONDS );
343343 socketOptions .close ();
344344 }
345345
@@ -486,7 +486,7 @@ protected void onContinuationClosed() {
486486 clientBootstrap .close ();
487487 clientBootstrap .getShutdownCompleteFuture ().get (1 , TimeUnit .SECONDS );
488488 elGroup .close ();
489- elGroup .getShutdownCompleteFuture ().get (1 , TimeUnit .SECONDS );
489+ elGroup .getShutdownCompleteFuture ().get (5 , TimeUnit .SECONDS );
490490 socketOptions .close ();
491491 }
492492
@@ -655,7 +655,7 @@ protected void onContinuationClosed() {
655655 clientBootstrap .close ();
656656 clientBootstrap .getShutdownCompleteFuture ().get (1 , TimeUnit .SECONDS );
657657 elGroup .close ();
658- elGroup .getShutdownCompleteFuture ().get (1 , TimeUnit .SECONDS );
658+ elGroup .getShutdownCompleteFuture ().get (5 , TimeUnit .SECONDS );
659659 socketOptions .close ();
660660 }
661661}
0 commit comments