Thanks! This should do the trick...
@Override
public void close() throws Exception {
CompletableFuture vertxClosed = new CompletableFuture<>();
if(jdbc != null)
jdbc.close();
if(vertx != null)
vertx.close(close -> {
if(close.failed())
> On May 16, 2019, at 9:38 AM, John Smith wrote:
>
> Hi, so Thread.Sleep(1000) seems to do the trick. Now is this a good thing or
> bad thing?
An arbitrary sleep duration has the potential to create random failures if the
close takes longer than expected.
For async close() calls, often you
Hi, so Thread.Sleep(1000) seems to do the trick. Now is this a good thing
or bad thing?
On Thu, 16 May 2019 at 11:46, John Smith wrote:
> Yes when I mean cancel the JOB, it's when you go inside the UI and hit the
> cancel button at the top right corner.
>
> The close is very simple...
>
>
Yes when I mean cancel the JOB, it's when you go inside the UI and hit the
cancel button at the top right corner.
The close is very simple...
@Override
public void close() throws Exception {
if(jdbc != null)
jdbc.close();
if(vertx != null)
vertx.close();
if(ignite != null)
Could you share the source code of your RichAsyncFunction?
Looks like netty threads of vertx are still being shutdown after user code
class loader has been shutdown.
It probably means that RichAsyncFunction was not closed properly or not all
resources have been fully freed there (logging your
So these are the two exceptions I see in the logs...
Exception in thread "vert.x-worker-thread-0" Exception in thread
"vert.x-internal-blocking-0" java.lang.NoClassDefFoundError:
io/netty/util/concurrent/FastThreadLocal
at
Hi John,
could you share the full stack trace or better logs?
It looks like something is trying to be executed in vertx.io code after the
local task has been stopped and the class loader for the user code has been
unloaded. Maybe from some daemon thread pool.
Best,
Andrey
On Wed, May 15, 2019
Hi,
I'm using vertx.io as an async JDBC client for a RichAsyncFunction it works
fine but when I stop the job I get...
java.lang.BootstrapMethodError: java.lang.NoClassDefFoundError:
io/vertx/core/impl/VertxImpl$SharedWorkerPool
Is there a way to avoid/fix this?
