diff --git a/core/AmSessionProcessor.cpp b/core/AmSessionProcessor.cpp index ebcecb13..4c758d2e 100644 --- a/core/AmSessionProcessor.cpp +++ b/core/AmSessionProcessor.cpp @@ -171,6 +171,9 @@ void AmSessionProcessorThread::startSession(AmSession* s) { // add this to be scheduled events.postEvent(new AmSessionProcessorThreadAddEvent(s)); + // trigger processing of events already in queue at startup + notify(s); + // wakeup the thread runcond.set(true); }