File tree Expand file tree Collapse file tree 28 files changed +51
-50
lines changed Expand file tree Collapse file tree 28 files changed +51
-50
lines changed Original file line number Diff line number Diff line change 25
25
"require" : {
26
26
"php" : " ^7.4" ,
27
27
"psr/event-dispatcher" : " ^1.0" ,
28
- "psr/log" : " ^1.1" ,
28
+ "psr/log" : " ^1.1" ,
29
29
"yiisoft/friendly-exception" : " ^1.0" ,
30
30
"yiisoft/yii-console" : " ^3.0@dev"
31
31
},
34
34
"pda/pheanstalk" : " *" ,
35
35
"phpunit/phpunit" : " ^9.0" ,
36
36
"yiisoft/di" : " ^3.0@dev" ,
37
- "yiisoft/log" : " ^3.0@dev"
37
+ "yiisoft/log" : " ^3.0@dev" ,
38
+ "yiisoft/event-dispatcher" : " ^3.0@dev"
38
39
},
39
40
"suggest" : {
40
41
"ext-pcntl" : " Need for process signals."
Original file line number Diff line number Diff line change 4
4
use Psr \EventDispatcher \ListenerProviderInterface ;
5
5
use Yiisoft \EventDispatcher \Dispatcher \Dispatcher ;
6
6
use Yiisoft \EventDispatcher \Provider \Provider ;
7
- use Yiisoft \Yii \Queue \Workers \Worker as QueueWorker ;
8
- use Yiisoft \Yii \Queue \Workers \WorkerInterface ;
7
+ use Yiisoft \Yii \Queue \Worker \Worker as QueueWorker ;
8
+ use Yiisoft \Yii \Queue \Worker \WorkerInterface ;
9
9
10
10
return [
11
11
EventDispatcherInterface::class => Dispatcher::class,
Original file line number Diff line number Diff line change 2
2
3
3
declare (strict_types=1 );
4
4
5
- use Yiisoft \Yii \Queue \Commands \ListenCommand ;
6
- use Yiisoft \Yii \Queue \Commands \RunCommand ;
5
+ use Yiisoft \Yii \Queue \Command \ListenCommand ;
6
+ use Yiisoft \Yii \Queue \Command \RunCommand ;
7
7
8
8
return [
9
9
'console ' => [
Original file line number Diff line number Diff line change 5
5
// '@runtime' => dirname(__DIR__) . '/tests/runtime',
6
6
// ],
7
7
// 'syncQueue' => [
8
- // '__class' => \Yiisoft\Yii\Queue\Drivers \Sync\Queue::class,
8
+ // '__class' => \Yiisoft\Yii\Queue\Driver \Sync\Queue::class,
9
9
// ],
10
10
];
Original file line number Diff line number Diff line change 2
2
3
3
declare (strict_types=1 );
4
4
5
- namespace Yiisoft \Yii \Queue \Commands ;
5
+ namespace Yiisoft \Yii \Queue \Command ;
6
6
7
7
use Symfony \Component \Console \Command \Command ;
8
8
use Symfony \Component \Console \Input \InputInterface ;
Original file line number Diff line number Diff line change 2
2
3
3
declare (strict_types=1 );
4
4
5
- namespace Yiisoft \Yii \Queue \Commands ;
5
+ namespace Yiisoft \Yii \Queue \Command ;
6
6
7
7
use Symfony \Component \Console \Command \Command ;
8
8
use Symfony \Component \Console \Input \InputInterface ;
Original file line number Diff line number Diff line change 6
6
7
7
use InvalidArgumentException ;
8
8
use Yiisoft \Yii \Queue \Enum \JobStatus ;
9
- use Yiisoft \Yii \Queue \Jobs \DelayableJobInterface ;
10
- use Yiisoft \Yii \Queue \Jobs \JobInterface ;
11
- use Yiisoft \Yii \Queue \Jobs \PrioritisedJobInterface ;
12
- use Yiisoft \Yii \Queue \Jobs \RetryableJobInterface ;
9
+ use Yiisoft \Yii \Queue \Job \DelayableJobInterface ;
10
+ use Yiisoft \Yii \Queue \Job \JobInterface ;
11
+ use Yiisoft \Yii \Queue \Job \PrioritisedJobInterface ;
12
+ use Yiisoft \Yii \Queue \Job \RetryableJobInterface ;
13
13
14
14
interface DriverInterface
15
15
{
Original file line number Diff line number Diff line change 4
4
5
5
namespace Yiisoft \Yii \Queue \Enum ;
6
6
7
- use Yiisoft \Yii \Queue \Exceptions \InvalidStatusException ;
7
+ use Yiisoft \Yii \Queue \Exception \InvalidStatusException ;
8
8
9
9
class JobStatus
10
10
{
Original file line number Diff line number Diff line change 2
2
3
3
declare (strict_types=1 );
4
4
5
- namespace Yiisoft \Yii \Queue \Events ;
5
+ namespace Yiisoft \Yii \Queue \Event ;
6
6
7
7
use Yiisoft \Yii \Queue \MessageInterface ;
8
8
use Yiisoft \Yii \Queue \Queue ;
Original file line number Diff line number Diff line change 2
2
3
3
declare (strict_types=1 );
4
4
5
- namespace Yiisoft \Yii \Queue \Events ;
5
+ namespace Yiisoft \Yii \Queue \Event ;
6
6
7
7
use Yiisoft \Yii \Queue \MessageInterface ;
8
8
use Yiisoft \Yii \Queue \Queue ;
Original file line number Diff line number Diff line change 2
2
3
3
declare (strict_types=1 );
4
4
5
- namespace Yiisoft \Yii \Queue \Events ;
5
+ namespace Yiisoft \Yii \Queue \Event ;
6
6
7
7
use Yiisoft \Yii \Queue \MessageInterface ;
8
8
use Yiisoft \Yii \Queue \Queue ;
Original file line number Diff line number Diff line change 2
2
3
3
declare (strict_types=1 );
4
4
5
- namespace Yiisoft \Yii \Queue \Events ;
5
+ namespace Yiisoft \Yii \Queue \Event ;
6
6
7
- use Yiisoft \Yii \Queue \Jobs \JobInterface ;
7
+ use Yiisoft \Yii \Queue \Job \JobInterface ;
8
8
use Yiisoft \Yii \Queue \Queue ;
9
9
10
10
final class BeforePush
Original file line number Diff line number Diff line change 2
2
3
3
declare (strict_types=1 );
4
4
5
- namespace Yiisoft \Yii \Queue \Events ;
5
+ namespace Yiisoft \Yii \Queue \Event ;
6
6
7
7
use Throwable ;
8
8
use Yiisoft \Yii \Queue \MessageInterface ;
Original file line number Diff line number Diff line change 2
2
3
3
declare (strict_types=1 );
4
4
5
- namespace Yiisoft \Yii \Queue \Exceptions ;
5
+ namespace Yiisoft \Yii \Queue \Exception ;
6
6
7
7
use InvalidArgumentException ;
8
8
use Throwable ;
Original file line number Diff line number Diff line change 2
2
3
3
declare (strict_types=1 );
4
4
5
- namespace Yiisoft \Yii \Queue \Exceptions ;
5
+ namespace Yiisoft \Yii \Queue \Exception ;
6
6
7
7
use Throwable ;
8
8
use UnexpectedValueException ;
9
9
use Yiisoft \FriendlyException \FriendlyExceptionInterface ;
10
10
use Yiisoft \Yii \Queue \DriverInterface ;
11
- use Yiisoft \Yii \Queue \Jobs \DelayableJobInterface ;
12
- use Yiisoft \Yii \Queue \Jobs \JobInterface ;
13
- use Yiisoft \Yii \Queue \Jobs \PrioritisedJobInterface ;
14
- use Yiisoft \Yii \Queue \Jobs \RetryableJobInterface ;
11
+ use Yiisoft \Yii \Queue \Job \DelayableJobInterface ;
12
+ use Yiisoft \Yii \Queue \Job \JobInterface ;
13
+ use Yiisoft \Yii \Queue \Job \PrioritisedJobInterface ;
14
+ use Yiisoft \Yii \Queue \Job \RetryableJobInterface ;
15
15
16
16
class JobNotSupportedException extends UnexpectedValueException implements FriendlyExceptionInterface
17
17
{
Original file line number Diff line number Diff line change 2
2
3
3
declare (strict_types=1 );
4
4
5
- namespace Yiisoft \Yii \Queue \Jobs ;
5
+ namespace Yiisoft \Yii \Queue \Job ;
6
6
7
7
use Throwable ;
8
8
Original file line number Diff line number Diff line change 2
2
3
3
declare (strict_types=1 );
4
4
5
- namespace Yiisoft \Yii \Queue \Jobs ;
5
+ namespace Yiisoft \Yii \Queue \Job ;
6
6
7
7
use Yiisoft \Serializer \SerializerInterface ;
8
8
Original file line number Diff line number Diff line change 2
2
3
3
declare (strict_types=1 );
4
4
5
- namespace Yiisoft \Yii \Queue \Jobs ;
5
+ namespace Yiisoft \Yii \Queue \Job ;
6
6
7
7
interface DelayableJobInterface extends JobInterface
8
8
{
Original file line number Diff line number Diff line change 6
6
* @license http://www.yiiframework.com/license/
7
7
*/
8
8
9
- namespace Yiisoft \Yii \Queue \Jobs ;
9
+ namespace Yiisoft \Yii \Queue \Job ;
10
10
11
11
/**
12
12
* Job Interface.
Original file line number Diff line number Diff line change 2
2
3
3
declare (strict_types=1 );
4
4
5
- namespace Yiisoft \Yii \Queue \Jobs ;
5
+ namespace Yiisoft \Yii \Queue \Job ;
6
6
7
7
interface PrioritisedJobInterface extends JobInterface
8
8
{
Original file line number Diff line number Diff line change 6
6
* @license http://www.yiiframework.com/license/
7
7
*/
8
8
9
- namespace Yiisoft \Yii \Queue \Jobs ;
9
+ namespace Yiisoft \Yii \Queue \Job ;
10
10
11
11
use Throwable ;
12
12
Original file line number Diff line number Diff line change 4
4
5
5
namespace Yiisoft \Yii \Queue ;
6
6
7
- use Yiisoft \Yii \Queue \Jobs \JobInterface ;
7
+ use Yiisoft \Yii \Queue \Job \JobInterface ;
8
8
9
9
class Message implements MessageInterface
10
10
{
Original file line number Diff line number Diff line change 4
4
5
5
namespace Yiisoft \Yii \Queue ;
6
6
7
- use Yiisoft \Yii \Queue \Jobs \JobInterface ;
7
+ use Yiisoft \Yii \Queue \Job \JobInterface ;
8
8
9
9
interface MessageInterface
10
10
{
Original file line number Diff line number Diff line change 8
8
use Yiisoft \EventDispatcher \Provider \Provider ;
9
9
use Yiisoft \Yii \Queue \Cli \LoopInterface ;
10
10
use Yiisoft \Yii \Queue \Enum \JobStatus ;
11
- use Yiisoft \Yii \Queue \Events \AfterPush ;
12
- use Yiisoft \Yii \Queue \Events \BeforePush ;
13
- use Yiisoft \Yii \Queue \Events \JobFailure ;
14
- use Yiisoft \Yii \Queue \Exceptions \InvalidJobException ;
15
- use Yiisoft \Yii \Queue \Exceptions \JobNotSupportedException ;
16
- use Yiisoft \Yii \Queue \Jobs \JobInterface ;
17
- use Yiisoft \Yii \Queue \Workers \WorkerInterface ;
11
+ use Yiisoft \Yii \Queue \Event \AfterPush ;
12
+ use Yiisoft \Yii \Queue \Event \BeforePush ;
13
+ use Yiisoft \Yii \Queue \Event \JobFailure ;
14
+ use Yiisoft \Yii \Queue \Exception \InvalidJobException ;
15
+ use Yiisoft \Yii \Queue \Exception \JobNotSupportedException ;
16
+ use Yiisoft \Yii \Queue \Job \JobInterface ;
17
+ use Yiisoft \Yii \Queue \Worker \WorkerInterface ;
18
18
19
19
/**
20
20
* Base Queue.
Original file line number Diff line number Diff line change 2
2
3
3
declare (strict_types=1 );
4
4
5
- namespace Yiisoft \Yii \Queue \Workers ;
5
+ namespace Yiisoft \Yii \Queue \Worker ;
6
6
7
7
use Psr \EventDispatcher \EventDispatcherInterface ;
8
8
use Psr \Log \LoggerInterface ;
9
9
use Throwable ;
10
- use Yiisoft \Yii \Queue \Events \AfterExecution ;
11
- use Yiisoft \Yii \Queue \Events \BeforeExecution ;
12
- use Yiisoft \Yii \Queue \Events \JobFailure ;
10
+ use Yiisoft \Yii \Queue \Event \AfterExecution ;
11
+ use Yiisoft \Yii \Queue \Event \BeforeExecution ;
12
+ use Yiisoft \Yii \Queue \Event \JobFailure ;
13
13
use Yiisoft \Yii \Queue \MessageInterface ;
14
14
use Yiisoft \Yii \Queue \Queue ;
15
15
Original file line number Diff line number Diff line change 2
2
3
3
declare (strict_types=1 );
4
4
5
- namespace Yiisoft \Yii \Queue \Workers ;
5
+ namespace Yiisoft \Yii \Queue \Worker ;
6
6
7
7
use Yiisoft \Yii \Queue \MessageInterface ;
8
8
use Yiisoft \Yii \Queue \Queue ;
Original file line number Diff line number Diff line change 8
8
9
9
namespace Yiisoft \Yii \Queue \Tests \App ;
10
10
11
- use Yiisoft \Yii \Queue \Jobs \JobInterface ;
11
+ use Yiisoft \Yii \Queue \Job \JobInterface ;
12
12
13
13
/**
14
14
* Simple Job.
Original file line number Diff line number Diff line change 7
7
use Psr \EventDispatcher \ListenerProviderInterface ;
8
8
use RuntimeException ;
9
9
use Yiisoft \EventDispatcher \Provider \Provider ;
10
- use Yiisoft \Yii \Queue \Events \BeforeExecution ;
11
- use Yiisoft \Yii \Queue \Events \JobFailure ;
10
+ use Yiisoft \Yii \Queue \Event \BeforeExecution ;
11
+ use Yiisoft \Yii \Queue \Event \JobFailure ;
12
12
use Yiisoft \Yii \Queue \Message ;
13
13
use Yiisoft \Yii \Queue \Queue ;
14
14
use Yiisoft \Yii \Queue \Tests \App \ExceptionalSimpleJob ;
15
15
use Yiisoft \Yii \Queue \Tests \App \SimpleJob ;
16
16
use Yiisoft \Yii \Queue \Tests \TestCase ;
17
- use Yiisoft \Yii \Queue \Workers \Worker ;
17
+ use Yiisoft \Yii \Queue \Worker \Worker ;
18
18
19
19
class WorkerTest extends TestCase
20
20
{
You can’t perform that action at this time.
0 commit comments