code cleanup
This commit is contained in:
parent
2ffa17b839
commit
4355f9f47f
1 changed files with 2 additions and 6 deletions
|
@ -71,15 +71,11 @@ public class SEBClientEventBatchService {
|
||||||
this.examSessionCacheService = examSessionCacheService;
|
this.examSessionCacheService = examSessionCacheService;
|
||||||
this.jsonMapper = jsonMapper;
|
this.jsonMapper = jsonMapper;
|
||||||
|
|
||||||
this.sqlSessionTemplate = new SqlSessionTemplate(
|
this.sqlSessionTemplate = new SqlSessionTemplate(this.sqlSessionFactory, ExecutorType.BATCH);
|
||||||
this.sqlSessionFactory,
|
this.clientEventMapper = this.sqlSessionTemplate.getMapper(ClientEventRecordMapper.class);
|
||||||
ExecutorType.BATCH);
|
|
||||||
this.clientEventMapper = this.sqlSessionTemplate.getMapper(
|
|
||||||
ClientEventRecordMapper.class);
|
|
||||||
}
|
}
|
||||||
|
|
||||||
private final BlockingDeque<EventData> eventDataQueue = new LinkedBlockingDeque<>();
|
private final BlockingDeque<EventData> eventDataQueue = new LinkedBlockingDeque<>();
|
||||||
//private final Collection<EventData> events = new ArrayList<>();
|
|
||||||
|
|
||||||
public void accept(final String connectionToken, final String jsonBody) {
|
public void accept(final String connectionToken, final String jsonBody) {
|
||||||
this.eventDataQueue.add(new EventData(
|
this.eventDataQueue.add(new EventData(
|
||||||
|
|
Loading…
Reference in a new issue