moved user object destruction to queue itself

So far, the consumer was responsible for destroying objects. However, this
does not work well with ultra-reliable queues. This is the first move to
support them.

1 files changed, 0 insertions, 1 deletions

diff --git a/action.c b/action.c
index 0253e1b6..424cb00b 100644
--- a/action.c
+++ b/action.c
@@ -905,7 +905,6 @@ processAction(action_t *pAction, batch_t *pBatch)
 	/* this must be moved away - up into the dequeue part of the queue, I guess, but that's for another day */
 	for(i = 0 ; i < pBatch->nElem ; i++) {
 		pMsg = (msg_t*) pBatch->pElem[i].pUsrp;
-		msgDestruct(&pMsg); /* TODO: change: we are now finished with the message */
 	}
 	iRet = finishBatch(pAction);