Skip to content

Commit 9550d3b

Browse files
CAMEL-23267: Fill test assertion gap and set maximum cache size field
1 parent 49c32f9 commit 9550d3b

File tree

2 files changed

+6
-2
lines changed

2 files changed

+6
-2
lines changed

core/camel-support/src/main/java/org/apache/camel/support/processor/idempotent/MemoryIdempotentRepository.java

Lines changed: 5 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -91,7 +91,11 @@ protected boolean removeEldestEntry(Entry<String, Object> eldest) {
9191
return size() > cacheSize;
9292
}
9393
};
94-
return memoryIdempotentRepository(map);
94+
MemoryIdempotentRepository answer = new MemoryIdempotentRepository(map);
95+
answer.setCacheSize(cacheSize);
96+
ServiceHelper.startService(answer);
97+
98+
return answer;
9599
}
96100

97101
/**

core/camel-support/src/test/java/org/apache/camel/support/MemoryIdempotentRepositoryTest.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -41,7 +41,7 @@ void repositoryEvictsOldestEntryWhenRepositoryIsFull() throws IOException {
4141
for (int i = entriesNotFittingInRepository; i < cacheSize + entriesNotFittingInRepository; i++) {
4242
assertTrue(repository.contains(String.valueOf(i)), "Repository should contain entry " + i);
4343
}
44-
for (int i = 0; i < cacheSize - entriesNotFittingInRepository; i++) {
44+
for (int i = 0; i < entriesNotFittingInRepository; i++) {
4545
assertFalse(repository.contains(String.valueOf(i)), "Repository should not contain entry " + i);
4646
}
4747
}

0 commit comments

Comments
 (0)