Skip to content

Commit e4c6bce

Browse files
authored
Develop (#12)
* Make connection configuration mergable * Change worker to use same logic as laravel queue * Some refactoring.
1 parent acf2276 commit e4c6bce

File tree

3 files changed

+285
-198
lines changed

3 files changed

+285
-198
lines changed

src/Type/BeanstalkdQueue.php

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -55,7 +55,7 @@ public function size($queue = null)
5555
{
5656
$queue = $this->getQueue($queue);
5757

58-
return (int)$this->pheanstalk->statsTube($queue)->total_jobs;
58+
return (int)$this->pheanstalk->statsTube($queue)->current_jobs_ready;
5959
}
6060

6161
/**

src/Type/RedisQueue.php

Lines changed: 2 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -121,9 +121,7 @@ public function later($delay, $job, $data = '', $queue = null)
121121
*/
122122
protected function laterRaw($delay, $payload, $queue = null)
123123
{
124-
$this->redis->zadd(
125-
$this->getQueue($queue) . ':delayed', $this->availableAt($delay), $payload
126-
);
124+
$this->redis->zadd($this->getQueue($queue) . ':delayed', $this->availableAt($delay), $payload);
127125

128126
return ArrayHelper::get(json_decode($payload, true), 'id');
129127
}
@@ -134,7 +132,7 @@ protected function laterRaw($delay, $payload, $queue = null)
134132
* @param string $job
135133
* @param mixed $data
136134
*
137-
* @return string
135+
* @return array
138136
*/
139137
protected function createPayloadArray($job, $data = '')
140138
{

0 commit comments

Comments
 (0)