Skip to content

Commit a4661d5

Browse files
committed
Fixed thread warnings for long running default threads
1 parent 469d2c9 commit a4661d5

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

src/main/java/org/computate/frFR/java/RegarderRepertoire.java

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -673,8 +673,8 @@ private void regarderClasseEvenement(Message<Object> message) {
673673
protected void traiterEvenements(JsonObject classeLangueConfig) {
674674
VertxBuilder vertxBuilder = Vertx.builder();
675675
VertxOptions vertxOptions = new VertxOptions();
676-
Long vertxWarningExceptionSeconds = configuration.getLong(ComputateConfigKeys.VERTX_WARNING_EXCEPTION_SECONDS);
677-
Long vertxMaxEventLoopExecuteTime = configuration.getLong(ComputateConfigKeys.VERTX_MAX_EVENT_LOOP_EXECUTE_TIME);
676+
Long vertxWarningExceptionSeconds = Long.MAX_VALUE;
677+
Long vertxMaxEventLoopExecuteTime = Long.MAX_VALUE;
678678
Long vertxMaxWorkerExecuteTime = Long.MAX_VALUE;
679679
vertxOptions.setWarningExceptionTime(vertxWarningExceptionSeconds);
680680
vertxOptions.setWarningExceptionTimeUnit(TimeUnit.SECONDS);
@@ -820,7 +820,7 @@ public void start(Promise<Void> startPromise) throws Exception {
820820
vertx.eventBus().consumer(REGARDER_CLASSE_ADDRESSE, message -> {
821821
regarderClasseEvenement(message);
822822
});
823-
Long vertxMaxWorkerExecuteTime = configuration.getLong(ComputateConfigKeys.VERTX_MAX_WORKER_EXECUTE_TIME);
823+
Long vertxMaxWorkerExecuteTime = Long.MAX_VALUE;
824824
Integer workerPoolSize = 1;
825825
workerExecutor = vertx.createSharedWorkerExecutor(String.format("%s-worker", Thread.currentThread().getName()), workerPoolSize, vertxMaxWorkerExecuteTime, TimeUnit.SECONDS);
826826
startPromise.complete();

0 commit comments

Comments
 (0)