X-Git-Url: https://git.mxchange.org/?a=blobdiff_plain;f=lib%2Fqueuehandler.php;h=23f295c45296fb480e233e4add9e7bb3fcc15782;hb=2abe10b8ea4b5d69fc7f6513bf465541454ca2cf;hp=d673f7f947b9ec94879573521082c4680beb0887;hpb=aed0fff4ea668de83405a4457fe238cf36c78d8f;p=quix0rs-gnu-social.git

diff --git a/lib/queuehandler.php b/lib/queuehandler.php
index d673f7f947..23f295c452 100644
--- a/lib/queuehandler.php
+++ b/lib/queuehandler.php
@@ -22,6 +22,8 @@ define('CLAIM_TIMEOUT', 1200);
 if (!defined('LACONICA')) { exit(1); }
 
 require_once(INSTALLDIR.'/lib/daemon.php');
+require_once(INSTALLDIR.'/classes/Queue_item.php');
+require_once(INSTALLDIR.'/classes/Notice.php');
 
 class QueueHandler extends Daemon {
 
@@ -87,11 +89,15 @@ class QueueHandler extends Daemon {
 						continue;
 					}
 					$this->log(LOG_INFO, 'finished broadcasting notice ID = ' . $notice->id);
+					$notice->free();
+					unset($notice);
 					$notice = NULL;
 				} else {
 					$this->log(LOG_WARNING, 'queue item for notice that does not exist');
 				}
 				$qi->delete();
+				$qi->free();
+				unset($qi);
 				$this->idle(0);
 			} else {
 				$this->clear_old_claims();
@@ -115,6 +121,8 @@ class QueueHandler extends Daemon {
 		$qi->transport = $this->transport();
 		$qi->whereAdd('now() - claimed > '.CLAIM_TIMEOUT);
 		$qi->update(DB_DATAOBJECT_WHEREADD_ONLY);
+		$qi->free();
+		unset($qi);
 	}
 	
 	function log($level, $msg) {