Skip to content

Commit

Permalink
not sending getQueueSize when getJobs is 0:
Browse files Browse the repository at this point in the history
  • Loading branch information
david-winder-kaltura committed Jan 12, 2017
1 parent 5162715 commit 9fd9b66
Show file tree
Hide file tree
Showing 4 changed files with 4 additions and 4 deletions.
2 changes: 1 addition & 1 deletion batch/batches/KJobCloserWorker.class.php
Original file line number Diff line number Diff line change
Expand Up @@ -19,7 +19,7 @@ public function run($jobs = null)
if(! count($jobs) > 0)
{
KalturaLog::info("Queue size: 0 sent to scheduler");
$this->saveSchedulerQueue(static::getType());
$this->saveSchedulerQueue(static::getType(), 0);
return null;
}

Expand Down
2 changes: 1 addition & 1 deletion batch/batches/KJobHandlerWorker.class.php
Original file line number Diff line number Diff line change
Expand Up @@ -90,7 +90,7 @@ public function run($jobs = null)
if(! count($jobs) > 0)
{
KalturaLog::info("Queue size: 0 sent to scheduler");
$this->saveSchedulerQueue(static::getType());
$this->saveSchedulerQueue(static::getType(), 0);
return null;
}

Expand Down
2 changes: 1 addition & 1 deletion batch/batches/Mailer/KAsyncMailer.class.php
Original file line number Diff line number Diff line change
Expand Up @@ -62,7 +62,7 @@ public function run($jobs = null)
if(!count($jobs) > 0)
{
KalturaLog::info("Queue size: 0 sent to scheduler");
$this->saveSchedulerQueue(self::getType());
$this->saveSchedulerQueue(self::getType(), 0);
return;
}

Expand Down
2 changes: 1 addition & 1 deletion batch/batches/Notifier/KAsyncNotifier.class.php
Original file line number Diff line number Diff line change
Expand Up @@ -52,7 +52,7 @@ public function run($jobs = null)
if(! count($jobs))
{
KalturaLog::info("Queue size: 0 sent to scheduler");
$this->saveSchedulerQueue(self::getType());
$this->saveSchedulerQueue(self::getType(), 0);
return;
}

Expand Down

0 comments on commit 9fd9b66

Please sign in to comment.