Skip to content

Commit cf0c17f

Browse files
Corrected testDrainTaskParameters
1 parent c994671 commit cf0c17f

File tree

2 files changed

+3
-10
lines changed

2 files changed

+3
-10
lines changed

src/main/java/com/exactpro/th2/estore/CradleErrorCollector.java

Lines changed: 0 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -71,11 +71,6 @@ private CradleErrorCollector(@NotNull ScheduledExecutorService executor,
7171
.scheduleAtFixedRate(this::drain, period, period, unit);
7272
}
7373

74-
private CradleErrorCollector(@NotNull ScheduledExecutorService executor,
75-
@NotNull CradleEntitiesFactory entitiesFactory) {
76-
this(executor, entitiesFactory, 1, TimeUnit.MINUTES);
77-
}
78-
7974
public static ErrorCollector create(@NotNull ScheduledExecutorService executor,
8075
@NotNull CradleEntitiesFactory entitiesFactory,
8176
long period,

src/test/java/com/exactpro/th2/estore/TestErrorCollector.java

Lines changed: 3 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -98,12 +98,10 @@ void afterEach() {
9898
"60,SECONDS",
9999
"1,MINUTES",
100100
})
101-
void testDrainTaskParameters(String period, String timeUnit) throws Exception {
102-
long periodValue = Long.parseLong(period);
103-
TimeUnit timeUnitValue = TimeUnit.valueOf(timeUnit);
104-
try(ErrorCollector collector = CradleErrorCollector.create(executor, entitiesFactory, periodValue, timeUnitValue)) {
101+
void testDrainTaskParameters(long period, TimeUnit timeUnit) throws Exception {
102+
try(ErrorCollector collector = CradleErrorCollector.create(executor, entitiesFactory, period, timeUnit)) {
105103
collector.init(persistor, rootEvent);
106-
verify(executor).scheduleAtFixedRate(taskCaptor.capture(), eq(periodValue), eq(periodValue), eq(timeUnitValue));
104+
verify(executor).scheduleAtFixedRate(taskCaptor.capture(), eq(period), eq(period), eq(timeUnit));
107105
}
108106
verify(future).cancel(eq(true));
109107
}

0 commit comments

Comments
 (0)