Skip to content

Commit 778fb94

Browse files
committed
Change default polling to 30 seconds
1 parent 53d5b3c commit 778fb94

File tree

4 files changed

+4
-3
lines changed

4 files changed

+4
-3
lines changed

README.md

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -116,5 +116,5 @@ The following properties are for advanced usage. Only change these if you unders
116116
* `flowable.external.worker.lock-duration` : The amount of time an external job will be locked when acquired. If this time limit is reached, other external workers will be able to acquire the same job. By default 5 minutes.
117117
* `flowable.external.worker.number-of-retries` : The number of times to retry acquiring new jobs on the Flowable server-side before giving up. By default, 5.
118118
* `flowable.external.worker.number-of-tasks` : The amount of external worker tasks to acquire and lock in one go. The default is `1`.
119-
* `flowable.external.worker.polling-interval` : The amount of time between polling for new external worker jobs. By default, 10 seconds.
119+
* `flowable.external.worker.polling-interval` : The amount of time between polling for new external worker jobs. By default, 30 seconds.
120120

workers/spring/autoconfigure/src/test/java/org/flowable/external/worker/spring/boot/ExternalWorkerAutoConfigurationTest.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -76,7 +76,7 @@ void defaultConfiguration() {
7676
assertThat(container.getLockDuration()).isEqualTo(Duration.ofMinutes(5));
7777
assertThat(container.getNumberOfRetries()).isEqualTo(5);
7878
assertThat(container.getNumberOfTasks()).isEqualTo(1);
79-
assertThat(container.getPollingInterval()).isEqualTo(Duration.ofSeconds(10));
79+
assertThat(container.getPollingInterval()).isEqualTo(Duration.ofSeconds(30));
8080
});
8181
}
8282

workers/spring/worker/src/main/java/org/flowable/external/worker/listener/WorkerJobListenerContainer.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -78,7 +78,7 @@ public class WorkerJobListenerContainer implements FlowableWorkerContainer, Bean
7878
protected int numberOfRetries = 5;
7979
protected int numberOfTasks = 1;
8080

81-
protected Duration pollingInterval = Duration.ofSeconds(10);
81+
protected Duration pollingInterval = Duration.ofSeconds(30);
8282

8383
protected FlowableWorkerJobListener workerJobListener;
8484

workers/spring/worker/src/test/java/org/flowable/external/worker/annotation/FlowableWorkerTest.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -844,6 +844,7 @@ static class DefaultContainerFactoryConfiguration {
844844
public FlowableWorkerContainerFactory<?> flowableWorkerContainerFactory(ExternalWorkerClient client) {
845845
DefaultFlowableWorkerContainerFactory factory = new DefaultFlowableWorkerContainerFactory();
846846
factory.setExternalWorkerClient(client);
847+
factory.setPollingInterval(Duration.ofSeconds(10));
847848
return factory;
848849
}
849850
}

0 commit comments

Comments
 (0)