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

only one worker again

Browse source
This commit is contained in:
anhefti 2023-06-06 08:54:47 +02:00
parent 456b6094f7
commit f29aa52dd0
1 changed files with 22 additions and 22 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

44
src/main/java/ch/ethz/seb/sebserver/webservice/servicelayer/session/impl/SEBClientEventBatchService.java
View file

@ -93,32 +93,32 @@ public class SEBClientEventBatchService {
} }
@Scheduled( @Scheduled(
fixedDelayString = "${sebserver.webservice.api.exam.session.event.batch.interval:1000}", fixedDelayString = "${sebserver.webservice.api.exam.session.event.batch.interval:500}",
initialDelay = 100) initialDelay = 100)
public void worker1() { public void worker1() {
processEvents("worker1"); processEvents("worker1");
} }
@Scheduled( // @Scheduled(
fixedDelayString = "${sebserver.webservice.api.exam.session.event.batch.interval:1000}", // fixedDelayString = "${sebserver.webservice.api.exam.session.event.batch.interval:1000}",
initialDelay = 300) // initialDelay = 300)
public void worker2() { // public void worker2() {
processEvents("worker2"); // processEvents("worker2");
} // }
//
@Scheduled( // @Scheduled(
fixedDelayString = "${sebserver.webservice.api.exam.session.event.batch.interval:1000}", // fixedDelayString = "${sebserver.webservice.api.exam.session.event.batch.interval:1000}",
initialDelay = 600) // initialDelay = 600)
public void worker3() { // public void worker3() {
processEvents("worker3"); // processEvents("worker3");
} // }
//
@Scheduled( // @Scheduled(
fixedDelayString = "${sebserver.webservice.api.exam.session.event.batch.interval:1000}", // fixedDelayString = "${sebserver.webservice.api.exam.session.event.batch.interval:1000}",
initialDelay = 900) // initialDelay = 900)
public void worker4() { // public void worker4() {
processEvents("worker4"); // processEvents("worker4");
} // }
public void processOneTime() { public void processOneTime() {
processEvents("One Time Call"); processEvents("One Time Call");
@ -243,7 +243,7 @@ public class SEBClientEventBatchService {
return null; return null;
} catch (final Exception e) { } catch (final Exception e) {
log.error("Failed to verify and process notification for SEB event: {}", eventData); log.error("Failed to verify and process notification for SEB event: {}", eventData, e);
return eventData; return eventData;
} }
} }