diff options
Diffstat (limited to 'runtime/ruleset.c')
| -rw-r--r-- | runtime/ruleset.c | 3 |
1 files changed, 3 insertions, 0 deletions
diff --git a/runtime/ruleset.c b/runtime/ruleset.c index 6013baf7..822150d9 100644 --- a/runtime/ruleset.c +++ b/runtime/ruleset.c @@ -412,6 +412,7 @@ done: return; /* Process (consume) a batch of messages. Calls the actions configured. + * This is called by MAIN queues. */ static rsRetVal processBatch(batch_t *pBatch, wti_t *pWti) @@ -423,6 +424,8 @@ processBatch(batch_t *pBatch, wti_t *pWti) DBGPRINTF("processBATCH: batch of %d elements must be processed\n", pBatch->nElem); + wtiResetExecState(pWti, pBatch); + /* execution phase */ for(i = 0 ; i < batchNumMsgs(pBatch) && !*(pWti->pbShutdownImmediate) ; ++i) { pMsg = pBatch->pElem[i].pMsg; |