moved message destruction back to consumer - the consume should decide what

    to do with the object. It may pass it on to someone else. So this would
    have creatd some headache in the future (maybe...).

1 files changed, 0 insertions, 5 deletions

diff --git a/queue.c b/queue.c
index 19e92e9c..8ef20371 100644
--- a/queue.c
+++ b/queue.c
@@ -343,11 +343,6 @@ queueWorker(void *arg)
 				if(iRetLocal != RS_RET_OK)
 					dbgprintf("Queue 0x%lx: Consumer returned iRet %d\n",
 					          (unsigned long) pThis, iRetLocal);
-dbgprintf("QUEUE: consumer done\n");
-				iRetLocal = objDestruct(pUsr);
-				if(iRetLocal != RS_RET_OK)
-					dbgprintf("Queue 0x%lx: Destructor returned iRet %d\n",
-					          (unsigned long) pThis, iRetLocal);
 			} else {
 				dbgprintf("Queue 0x%lx: error %d dequeueing element - ignoring, but strange things "
 				          "may happen\n", (unsigned long) pThis, iRet);