WARNING: Can't invoke task later as EventLoop rejected it

[Simon Gemmell]

Hiya, 

This code:

CompletableFuture<Void> fut = new CompletableFuture<>();
vertx.undeploy(deploymentId, (asyncResult) -> {
   if (asyncResult.succeeded()) {
      System.out.println(verticleName + " undeployed");
      httpClient.close();
      vertx.close((as) -> {
         if (as.succeeded()) {
            fut.complete(null);
         } else {
            fut.completeExceptionally(asyncResult.cause());
         }
      });

   } else {
      fut.completeExceptionally(asyncResult.cause());
   }
});

Produces this exception:

io.netty.channel.AbstractChannel$AbstractUnsafe invokeLater
WARNING: Can't invoke task later as EventLoop rejected it
java.util.concurrent.RejectedExecutionException: event executor terminated
	at io.netty.util.concurrent.SingleThreadEventExecutor.reject(SingleThreadEventExecutor.java:745)
	at io.netty.util.concurrent.SingleThreadEventExecutor.addTask(SingleThreadEventExecutor.java:322)
	at io.netty.util.concurrent.SingleThreadEventExecutor.execute(SingleThreadEventExecutor.java:725)
	at io.netty.channel.AbstractChannel$AbstractUnsafe.invokeLater(AbstractChannel.java:779)
	at io.netty.channel.AbstractChannel$AbstractUnsafe.close(AbstractChannel.java:573)
	at io.netty.channel.nio.NioEventLoop.closeAll(NioEventLoop.java:576)
	at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:361)
	at io.netty.util.concurrent.SingleThreadEventExecutor$2.run(SingleThreadEventExecutor.java:116)
	at java.lang.Thread.run(Thread.java:745)



Which I can see was raised before (https://github.com/vert-x3/issues/issues/9) was there a solution? Am I not supposed to vertx.close()?

[Julien Viet]

vertx.close will take care of undeploying everything for you.

-- 
Julien Viet
www.julienviet.com

--
You received this message because you are subscribed to the Google Groups "vert.x" group.
To unsubscribe from this group and stop receiving emails from it, send an email to vertx+un...@googlegroups.com.
For more options, visit https://groups.google.com/d/optout.

[Simon Gemmell]

Just doing:

CompletableFuture<Void> fut = new CompletableFuture<>();

vertx.close((asyncResult) -> {
   if (asyncResult.succeeded()) {
      fut.complete(null);
   } else {
      fut.completeExceptionally(asyncResult.cause());
   }
});

Gives me the same exception:

io.netty.channel.AbstractChannel$AbstractUnsafe invokeLater

WARNING: Can't invoke task later as EventLoop rejected it

java.util.concurrent.RejectedExecutionException: event executor terminated

at io.netty.util.concurrent.SingleThreadEventExecutor.reject(SingleThreadEventExecutor.java:745)

at io.netty.util.concurrent.SingleThreadEventExecutor.addTask(SingleThreadEventExecutor.java:322)

at io.netty.util.concurrent.SingleThreadEventExecutor.execute(SingleThreadEventExecutor.java:725)

at io.netty.channel.AbstractChannel$AbstractUnsafe.invokeLater(AbstractChannel.java:779)

at io.netty.channel.AbstractChannel$AbstractUnsafe.close(AbstractChannel.java:573)

at io.netty.channel.nio.NioEventLoop.closeAll(NioEventLoop.java:576)

at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:361)

at io.netty.util.concurrent.SingleThreadEventExecutor$2.run(SingleThreadEventExecutor.java:116)

at java.lang.Thread.run(Thread.java:745)

I actually get that a bunch of times.

[Julien Viet]

what version are you using ?

-- 
Julien Viet
www.julienviet.com

[Simon Gemmell]

M6

[Julien Viet]

can you provide a reproducer please ?

-- 
Julien Viet
www.julienviet.com

[Scott Rutherford]

I see the same running the tests (still narrowing down which exact ones) in vertx-redis-client (3.0.0-SNAPSHOT) using local redis install

** Using standalone redis
Running io.vertx.test.redis.RedisClientTestBase
Starting test: RedisClientTestBase#testMulti 

Can't invoke task later as EventLoop rejected it
java.util.concurrent.RejectedExecutionException: event executor terminated
at io.netty.util.concurrent.SingleThreadEventExecutor.reject(SingleThreadEventExecutor.java:745)
at io.netty.util.concurrent.SingleThreadEventExecutor.addTask(SingleThreadEventExecutor.java:322)
at io.netty.util.concurrent.SingleThreadEventExecutor.execute(SingleThreadEventExecutor.java:725)
at io.netty.channel.AbstractChannel$AbstractUnsafe.invokeLater(AbstractChannel.java:779)
at io.netty.channel.AbstractChannel$AbstractUnsafe.close(AbstractChannel.java:573)
at io.netty.channel.nio.NioEventLoop.closeAll(NioEventLoop.java:576)
at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:361)
at io.netty.util.concurrent.SingleThreadEventExecutor$2.run(SingleThreadEventExecutor.java:116)
at java.lang.Thread.run(Thread.java:745)