Skip to content
Advertisement

OkHttp WebSocket RejectedExecutionException when try to restart

I have this client:

OkHttpClient okHttpClient = new OkHttpClient.Builder()
            .pingInterval(Duration.ofMinutes(3))
            .readTimeout(Duration.ofMillis(0))
            .build();

And this methods for start and stop:

private WebSocket webSocket = null;
private MyListener wsListener = null;

private void start(){

    if(webSocket != null){ return; }

    wsListener = new MyListener();

    Request request = new Request.Builder()
        .url("wss://stream.binance.com:9443/ws")
        .build();

    webSocketBinance = okHttpClient.newWebSocket(request, wsListener); //here triggers error

}

private void stop(){

    if(webSocket == null){ return; }

    webSocket.close(1000, "{"reason": "With love"}");
    webSocket= null;

    okHttpClient.dispatcher().executorService().shutdown();
    okHttpClient.connectionPool().evictAll();

    wsListener = null;

}

Sometimes I want to restart the connection like this:

start();

Thread.sleep(10_000);

//restart connection
stop();
start(); //here triggers the error

But at start() I get this error:

java.io.InterruptedIOException: executor rejected
    at okhttp3.internal.connection.RealCall$AsyncCall.executeOn(RealCall.kt:501)
    at okhttp3.Dispatcher.promoteAndExecute(Dispatcher.kt:184)
    at okhttp3.Dispatcher.enqueue$okhttp(Dispatcher.kt:125)
    at okhttp3.internal.connection.RealCall.enqueue(RealCall.kt:164)
    at okhttp3.internal.ws.RealWebSocket.connect(RealWebSocket.kt:165)
    at okhttp3.OkHttpClient.newWebSocket(OkHttpClient.kt:281)
    at foo.Foo.start(...)

Caused by: 
java.util.concurrent.RejectedExecutionException: 
    Task okhttp3.internal.connection.RealCall$AsyncCall@2aceadd4 rejected from 
    java.util.concurrent.ThreadPoolExecutor@24aed80c
    [Shutting down, pool size = 1, active threads = 1, queued tasks = 0, completed tasks = 0]
    
at java.base/java.util.concurrent.ThreadPoolExecutor$AbortPolicy.rejectedExecution(ThreadPoolExecutor.java:2080)
    
at java.base/java.util.concurrent.ThreadPoolExecutor.reject(ThreadPoolExecutor.java:832)
    
at java.base/java.util.concurrent.ThreadPoolExecutor.execute(ThreadPoolExecutor.java:1365)
    
at okhttp3.internal.connection.RealCall$AsyncCall.executeOn(RealCall.kt:498)
    
... 8 more

Advertisement

Answer

The solution in my case was to create a new OkHttpClient and WebSocket every time when I want to restart.

User contributions licensed under: CC BY-SA
2 People found this is helpful
Advertisement