Index: apps/app_queue.c
===================================================================
--- apps/app_queue.c	(revision 83637)
+++ apps/app_queue.c	(working copy)
@@ -884,10 +884,13 @@
 			ao2_ref(mem, -1);
 			ao2_unlock(q);
 			queue_unref(q);
+			ret = 1;
 			break;
 		}
 		ao2_unlock(q);
 		queue_unref(q);
+		if(ret) 
+			return ret;
 	}
 
 	return ret;