Skip to content

Commit a2fd4e5

Browse files
committed
Removed the single writer callback executor from unit tests
1 parent 63522fe commit a2fd4e5

File tree

2 files changed

+0
-8
lines changed

2 files changed

+0
-8
lines changed

src/test/java/com/hivemq/persistence/SingleWriterServiceImplTest.java

Lines changed: 0 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -101,10 +101,6 @@ public void stop_shutdownAllThreads() {
101101
singleWriterServiceImpl.stop();
102102
assertTrue(singleWriterServiceImpl.checkScheduler.isShutdown());
103103
assertTrue(singleWriterServiceImpl.singleWriterExecutor.isShutdown());
104-
105-
for (final ExecutorService callbackExecutor : singleWriterServiceImpl.callbackExecutors) {
106-
assertTrue(callbackExecutor.isShutdown());
107-
}
108104
}
109105

110106
private static class NoOpExecutor implements ExecutorService {

src/test/java/util/TestSingleWriterFactory.java

Lines changed: 0 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -15,7 +15,6 @@
1515
*/
1616
package util;
1717

18-
import com.google.common.util.concurrent.MoreExecutors;
1918
import com.hivemq.configuration.service.InternalConfigurations;
2019
import com.hivemq.persistence.SingleWriterService;
2120
import com.hivemq.persistence.SingleWriterServiceImpl;
@@ -34,9 +33,6 @@ public static SingleWriterService defaultSingleWriter() {
3433
InternalConfigurations.SINGLE_WRITER_INTERVAL_TO_CHECK_PENDING_TASKS_AND_SCHEDULE_MSEC.set(100);
3534

3635
final SingleWriterServiceImpl singleWriterServiceImpl = new SingleWriterServiceImpl();
37-
for (int i = 0; i < singleWriterServiceImpl.callbackExecutors.length; i++) {
38-
singleWriterServiceImpl.callbackExecutors[i] = MoreExecutors.newDirectExecutorService();
39-
}
4036

4137
singleWriterServiceImpl.postConstruct();
4238

0 commit comments

Comments
 (0)