Skip to content

Commit 6b292ef

Browse files
committed
Fix(test): MongoDeleteOutboxWorker 스케줄 경합 제거로 배치 한도 테스트 안정화
1 parent 5b4392f commit 6b292ef

2 files changed

Lines changed: 10 additions & 1 deletion

File tree

src/main/java/io/ejangs/docsa/global/mongo/deletion/app/MongoDeleteOutboxWorker.java

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -22,7 +22,10 @@ public class MongoDeleteOutboxWorker {
2222
private final MongoDeleteService mongoDeleteService;
2323
private final MongoDeleteOutboxCompleteService mongoDeleteOutboxCompleteService;
2424

25-
@Scheduled(fixedDelayString = "PT1M")
25+
@Scheduled(
26+
fixedDelayString = "${mongo.delete.outbox.worker.fixed-delay:PT1M}",
27+
initialDelayString = "${mongo.delete.outbox.worker.initial-delay:PT0S}"
28+
)
2629
public void run() {
2730
int recovered = mongoDeleteOutboxCompleteService.recoverTimedOutProcessing(
2831
LocalDateTime.now().minus(PROCESSING_TIMEOUT)

src/test/resources/application-test.yml

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -53,3 +53,9 @@ app:
5353
cors:
5454
allowed-origin:
5555

56+
mongo:
57+
delete:
58+
outbox:
59+
worker:
60+
fixed-delay: PT1M
61+
initial-delay: PT24H

0 commit comments

Comments
 (0)