zervo/seb-server
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

code cleanup

Browse source
This commit is contained in:
anhefti 2021-03-04 13:50:40 +01:00
parent 53a9710ec8
commit d4c79e06d8
1 changed files with 9 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

11
src/main/java/ch/ethz/seb/sebserver/webservice/servicelayer/session/impl/AsyncBatchEventSaveStrategy.java
View file

@ -138,13 +138,14 @@ public class AsyncBatchEventSaveStrategy implements EventHandlingStrategy {
SEBServerInit.INIT_LOGGER.info("> Worker Thread {} running", Thread.currentThread()); SEBServerInit.INIT_LOGGER.info("> Worker Thread {} running", Thread.currentThread());
final Collection<ClientEventRecord> events = new ArrayList<>(); final Collection<ClientEventRecord> events = new ArrayList<>();
@SuppressWarnings("resource")
final SqlSessionTemplate sqlSessionTemplate = new SqlSessionTemplate( final SqlSessionTemplate sqlSessionTemplate = new SqlSessionTemplate(
this.sqlSessionFactory, this.sqlSessionFactory,
ExecutorType.BATCH); ExecutorType.BATCH);
final ClientEventRecordMapper clientEventMapper = sqlSessionTemplate.getMapper( final ClientEventRecordMapper clientEventMapper = sqlSessionTemplate.getMapper(
ClientEventRecordMapper.class); ClientEventRecordMapper.class);
long sleepTime = 100; long sleepTime = MIN_SLEEP_TIME;
try { try {
while (this.workersRunning) { while (this.workersRunning) {
@ -175,7 +176,13 @@ public class AsyncBatchEventSaveStrategy implements EventHandlingStrategy {
} }
} }
} finally { } finally {
sqlSessionTemplate.close(); try {
sqlSessionTemplate.destroy();
} catch (final Exception e) {
log.error("Failed to close and destroy the SqlSessionTemplate for this thread: {}",
Thread.currentThread(),
e);
}
log.debug("Worker Thread {} stopped", Thread.currentThread()); log.debug("Worker Thread {} stopped", Thread.currentThread());
} }
}; };