Детали задачи
-
Ошибка
-
Решение: Готово
-
High
-
Community 4.0
-
Не заполнено
-
Не заполнено
-
ecos-notifications 2.9.0
community.core 4.9.14
enterprise 4.9.4
-
Major
Описание
В мкс нотификации выполняется команда
val result = commandsService.execute { targetApp = config.targetApp body = CmdFitNotification(notification) type = config.commandType }.get()
Если одновременно выполняется 3 и более команды, то возникает TimeoutException.
java.util.concurrent.TimeoutException at java.util.concurrent.CompletableFuture.timedGet(CompletableFuture.java:1771) at java.util.concurrent.CompletableFuture.get(CompletableFuture.java:1915) at ru.citeck.ecos.commands.utils.FutureWithTimeout.get(FutureWithTimeout.kt:12) at ru.citeck.ecos.commands.utils.FutureWithTimeout.get(FutureWithTimeout.kt:29) at ru.citeck.ecos.notifications.domain.sender.command.CommandNotificationSender.sendNotification(CommandNotificationSender.kt:47) at ru.citeck.ecos.notifications.domain.sender.command.CommandNotificationSender.sendNotification(CommandNotificationSender.kt:16) at ru.citeck.ecos.notifications.domain.notification.service.NotificationSenderServiceImpl.sendNotification(NotificationSenderServiceImpl.kt:140) at ru.citeck.ecos.notifications.domain.notification.api.commands.UnsafeSendNotificationCommandExecutor.execute(UnsafeSendNotificationCommandExecutor.kt:72) at ru.citeck.ecos.notifications.domain.notification.api.commands.SendNotificationCommandExecutor.executeImpl(SendNotification.kt:45) at ru.citeck.ecos.notifications.domain.notification.api.commands.SendNotificationCommandExecutor.access$executeImpl(SendNotification.kt:18) at ru.citeck.ecos.notifications.domain.notification.api.commands.SendNotificationCommandExecutor$execute$1.invoke(SendNotification.kt:36) at ru.citeck.ecos.context.lib.spring.config.SpringAuthComponent.runAs(SpringAuthComponent.kt:46) at ru.citeck.ecos.context.lib.auth.AuthContext.runAs(AuthContext.kt:109) at ru.citeck.ecos.context.lib.auth.AuthContext.runAs(AuthContext.kt:94) at ru.citeck.ecos.context.lib.auth.AuthContext.runAs(AuthContext.kt:89) at ru.citeck.ecos.notifications.domain.notification.api.commands.SendNotificationCommandExecutor.execute(SendNotification.kt:35) at ru.citeck.ecos.notifications.domain.notification.api.commands.SendNotificationCommandExecutor.execute(SendNotification.kt:18) at ru.citeck.ecos.commands.CommandsService.executeLocal$lambda-1$lambda-0(CommandsService.kt:168) at ru.citeck.ecos.commands.transaction.SimpleTxnManager.doInTransaction(SimpleTxnManager.kt:7) at ru.citeck.ecos.commands.CommandsService.executeLocal$lambda-1(CommandsService.kt:167) at ru.citeck.ecos.commands.context.SimpleCommandCtxManager.runWith(SimpleCommandCtxManager.kt:60) at ru.citeck.ecos.commands.CommandsService.executeLocal(CommandsService.kt:161) at ru.citeck.ecos.commands.rabbit.RabbitCommandsService.onCommandReceived(RabbitCommandsService.kt:108) at ru.citeck.ecos.commands.rabbit.RabbitCommandsService.access$onCommandReceived(RabbitCommandsService.kt:18) at ru.citeck.ecos.commands.rabbit.RabbitCommandsService$addNewContext$1$context$1.invoke(RabbitCommandsService.kt:79) at ru.citeck.ecos.commands.rabbit.RabbitCommandsService$addNewContext$1$context$1.invoke(RabbitCommandsService.kt:79) at ru.citeck.ecos.commands.rabbit.RabbitContext.handleCommandMqMessage(RabbitContext.kt:79) at ru.citeck.ecos.commands.rabbit.RabbitContext.access$handleCommandMqMessage(RabbitContext.kt:14) at ru.citeck.ecos.commands.rabbit.RabbitContext$1.invoke(RabbitContext.kt:56) at ru.citeck.ecos.commands.rabbit.RabbitContext$1.invoke(RabbitContext.kt:53) at ru.citeck.ecos.commands.rabbit.RabbitContext$addConsumer$1.invoke(RabbitContext.kt:71) at ru.citeck.ecos.commands.rabbit.RabbitContext$addConsumer$1.invoke(RabbitContext.kt:69) at ru.citeck.ecos.rabbitmq.RabbitMqChannel$addAckedConsumer$1.accept(RabbitMqChannel.kt:54) at ru.citeck.ecos.rabbitmq.RabbitMqChannel$addAckedConsumer$1.accept(RabbitMqChannel.kt:52) at ru.citeck.ecos.rabbitmq.RabbitMqChannel$addAckedConsumer$$inlined$basicConsumeImpl$1.handle(RabbitMqChannel.kt:207) at com.rabbitmq.client.impl.recovery.AutorecoveringChannel$2.handleDelivery(AutorecoveringChannel.java:585) at com.rabbitmq.client.impl.ConsumerDispatcher$5.run(ConsumerDispatcher.java:149) at com.rabbitmq.client.impl.ConsumerWorkService$WorkPoolRunnable.run(ConsumerWorkService.java:104) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) at java.lang.Thread.run(Thread.java:748)
Вложенные файлы
Вложенные файлы
Связи запроса
- mentioned on
(18 mentioned on)