diff --git a/application/src/main/java/org/thingsboard/server/service/queue/DefaultTbRuleEngineConsumerService.java b/application/src/main/java/org/thingsboard/server/service/queue/DefaultTbRuleEngineConsumerService.java index f8f6a7d25f..3d02a1f60e 100644 --- a/application/src/main/java/org/thingsboard/server/service/queue/DefaultTbRuleEngineConsumerService.java +++ b/application/src/main/java/org/thingsboard/server/service/queue/DefaultTbRuleEngineConsumerService.java @@ -266,7 +266,7 @@ public class DefaultTbRuleEngineConsumerService extends AbstractConsumerService< updateCurrentThreadName(threadSuffix); while (!stopped && !consumer.isStopped()) { try { - List> msgs = consumer.poll(pollDuration); + List> msgs = consumer.poll(configuration.getPollInterval()); if (msgs.isEmpty()) { continue; } diff --git a/ui-ngx/src/app/modules/home/components/profile/tenant-profile.component.ts b/ui-ngx/src/app/modules/home/components/profile/tenant-profile.component.ts index 2aafa97d99..e96a237033 100644 --- a/ui-ngx/src/app/modules/home/components/profile/tenant-profile.component.ts +++ b/ui-ngx/src/app/modules/home/components/profile/tenant-profile.component.ts @@ -56,10 +56,10 @@ export class TenantProfileComponent extends EntityComponent { const mainQueue = [ { id: guid(), - consumerPerPartition: true, + consumerPerPartition: false, name: 'Main', packProcessingTimeout: 2000, - partitions: 10, + partitions: 1, pollInterval: 25, processingStrategy: { failurePercentage: 0, @@ -82,8 +82,8 @@ export class TenantProfileComponent extends EntityComponent { name: 'HighPriority', topic: 'tb_rule_engine.hp', pollInterval: 25, - partitions: 10, - consumerPerPartition: true, + partitions: 1, + consumerPerPartition: false, packProcessingTimeout: 2000, submitStrategy: { type: 'BURST', @@ -105,8 +105,8 @@ export class TenantProfileComponent extends EntityComponent { name: 'SequentialByOriginator', topic: 'tb_rule_engine.sq', pollInterval: 25, - partitions: 10, - consumerPerPartition: true, + partitions: 1, + consumerPerPartition: false, packProcessingTimeout: 2000, submitStrategy: { type: 'SEQUENTIAL_BY_ORIGINATOR',