Skip to content
This repository was archived by the owner on Nov 9, 2025. It is now read-only.

Commit e8b319f

Browse files
committed
updat deps, fix test.
1 parent 8ec625e commit e8b319f

File tree

8 files changed

+58
-73
lines changed

8 files changed

+58
-73
lines changed

DI/QuartzExtension.php

Lines changed: 5 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,7 @@
11
<?php
22
namespace Quartz\Bridge\DI;
33

4+
use Enqueue\Client\ProducerInterface;
45
use Quartz\Bridge\Enqueue\EnqueueRemoteTransportProcessor;
56
use Quartz\Bridge\Enqueue\EnqueueResponseJob;
67
use Quartz\Bridge\Scheduler\EnqueueJobRunShell;
@@ -56,7 +57,7 @@ public function load(array $configs, ContainerBuilder $container)
5657
;
5758

5859
$container->register($this->format('enqueue_job_run_shell'), EnqueueJobRunShell::class)
59-
->setArguments([new Reference('enqueue.producer')])
60+
->setArguments([new Reference(ProducerInterface::class)])
6061
;
6162

6263
$container->register($this->format('job_run_shell_factory'), StdJobRunShellFactory::class)
@@ -69,7 +70,7 @@ public function load(array $configs, ContainerBuilder $container)
6970

7071
// TODO: add config option where can enable/disable this job
7172
$container->register($this->format('job.enqueue_response'), EnqueueResponseJob::class)
72-
->setArguments([new Reference('enqueue.producer')])
73+
->setArguments([new Reference(ProducerInterface::class)])
7374
->addTag($this->format('job'), ['alias' => 'enqueue_response'])
7475
->addTag($this->format('job'), ['alias' => EnqueueResponseJob::class])
7576
;
@@ -93,7 +94,7 @@ public function load(array $configs, ContainerBuilder $container)
9394
new Reference($this->format('store')),
9495
new Reference($this->format('std_job_run_shell'))
9596
])
96-
->addTag('enqueue.client.processor')
97+
->addTag('enqueue.command_subscriber')
9798
;
9899

99100
$container->register($this->format('rpc_protocol'), RpcProtocol::class)
@@ -106,7 +107,7 @@ public function load(array $configs, ContainerBuilder $container)
106107
new Reference($this->format('scheduler')),
107108
new Reference($this->format('rpc_protocol'))
108109
])
109-
->addTag('enqueue.client.processor')
110+
->addTag('enqueue.command_subscriber')
110111
;
111112
}
112113

DI/RemoteSchedulerExtension.php

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,7 @@
11
<?php
22
namespace Quartz\Bridge\DI;
33

4+
use Enqueue\Client\ProducerInterface;
45
use Quartz\Bridge\Enqueue\EnqueueRemoteTransport;
56
use Quartz\Bridge\Scheduler\RemoteScheduler;
67
use Quartz\Bridge\Scheduler\RpcProtocol;
@@ -37,7 +38,7 @@ public function getAlias()
3738
public function load(array $configs, ContainerBuilder $container)
3839
{
3940
$container->register($this->format('remote.transport'), EnqueueRemoteTransport::class)
40-
->setArguments([new Reference('enqueue.client.producer_v2')])
41+
->setArguments([new Reference(ProducerInterface::class)])
4142
;
4243

4344
$container->register($this->format('remote.rpc_protocol'), RpcProtocol::class)

Enqueue/EnqueueRemoteTransportProcessor.php

Lines changed: 10 additions & 19 deletions
Original file line numberDiff line numberDiff line change
@@ -5,13 +5,13 @@
55
use Enqueue\Consumption\QueueSubscriberInterface;
66
use Enqueue\Consumption\Result;
77
use Enqueue\Util\JSON;
8-
use Interop\Queue\PsrContext;
9-
use Interop\Queue\PsrMessage;
10-
use Interop\Queue\PsrProcessor;
8+
use Interop\Queue\Context;
9+
use Interop\Queue\Message;
10+
use Interop\Queue\Processor;
1111
use Quartz\Bridge\Scheduler\RpcProtocol;
1212
use Quartz\Core\Scheduler;
1313

14-
class EnqueueRemoteTransportProcessor implements PsrProcessor, CommandSubscriberInterface, QueueSubscriberInterface
14+
class EnqueueRemoteTransportProcessor implements Processor, CommandSubscriberInterface, QueueSubscriberInterface
1515
{
1616
/**
1717
* @var Scheduler
@@ -33,10 +33,7 @@ public function __construct(Scheduler $scheduler, RpcProtocol $rpcProtocol)
3333
$this->rpcProtocol = $rpcProtocol;
3434
}
3535

36-
/**
37-
* {@inheritdoc}
38-
*/
39-
public function process(PsrMessage $message, PsrContext $context)
36+
public function process(Message $message, Context $context): Result
4037
{
4138
try {
4239
$request = $this->rpcProtocol->decodeRequest(JSON::decode($message->getBody()));
@@ -50,23 +47,17 @@ public function process(PsrMessage $message, PsrContext $context)
5047
return Result::reply($context->createMessage(JSON::encode($result)));
5148
}
5249

53-
/**
54-
* {@inheritdoc}
55-
*/
56-
public static function getSubscribedCommand()
50+
public static function getSubscribedCommand(): array
5751
{
5852
return [
59-
'processorName' => EnqueueRemoteTransport::COMMAND,
60-
'queueName' => EnqueueRemoteTransport::COMMAND,
61-
'queueNameHardcoded' => true,
53+
'command' => EnqueueRemoteTransport::COMMAND,
54+
'queue' => EnqueueRemoteTransport::COMMAND,
55+
'prefix_queue' => false,
6256
'exclusive' => true,
6357
];
6458
}
6559

66-
/**
67-
* {@inheritdoc}
68-
*/
69-
public static function getSubscribedQueues()
60+
public static function getSubscribedQueues(): array
7061
{
7162
return [EnqueueRemoteTransport::COMMAND];
7263
}

Scheduler/JobRunShellProcessor.php

Lines changed: 11 additions & 20 deletions
Original file line numberDiff line numberDiff line change
@@ -5,13 +5,13 @@
55
use Enqueue\Consumption\QueueSubscriberInterface;
66
use Enqueue\Consumption\Result;
77
use Enqueue\Util\JSON;
8-
use Interop\Queue\PsrContext;
9-
use Interop\Queue\PsrMessage;
10-
use Interop\Queue\PsrProcessor;
8+
use Interop\Queue\Context;
9+
use Interop\Queue\Message;
10+
use Interop\Queue\Processor;
1111
use Quartz\Scheduler\JobStore;
1212
use Quartz\Scheduler\StdJobRunShell;
1313

14-
class JobRunShellProcessor implements PsrProcessor, CommandSubscriberInterface, QueueSubscriberInterface
14+
class JobRunShellProcessor implements Processor, CommandSubscriberInterface, QueueSubscriberInterface
1515
{
1616
/**
1717
* @var JobStore
@@ -33,10 +33,7 @@ public function __construct(JobStore $store, StdJobRunShell $runShell)
3333
$this->runShell = $runShell;
3434
}
3535

36-
/**
37-
* {@inheritdoc}
38-
*/
39-
public function process(PsrMessage $message, PsrContext $context)
36+
public function process(Message $message, Context $context): Result
4037
{
4138
$data = JSON::decode($message->getBody());
4239

@@ -50,26 +47,20 @@ public function process(PsrMessage $message, PsrContext $context)
5047

5148
$this->runShell->execute($trigger);
5249

53-
return Result::ACK;
50+
return Result::ack();
5451
}
5552

56-
/**
57-
* {@inheritdoc}
58-
*/
59-
public static function getSubscribedCommand()
53+
public static function getSubscribedCommand(): array
6054
{
6155
return [
62-
'processorName' => EnqueueJobRunShell::COMMAND,
63-
'queueName' => EnqueueJobRunShell::COMMAND,
64-
'queueNameHardcoded' => true,
56+
'command' => EnqueueJobRunShell::COMMAND,
57+
'queue' => EnqueueJobRunShell::COMMAND,
58+
'prefix_queue' => false,
6559
'exclusive' => true,
6660
];
6761
}
6862

69-
/**
70-
* {@inheritdoc}
71-
*/
72-
public static function getSubscribedQueues()
63+
public static function getSubscribedQueues(): array
7364
{
7465
return [EnqueueJobRunShell::COMMAND];
7566
}

Tests/DI/QuartzConfigurationTest.php

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -26,7 +26,7 @@ public function testShouldReturnDefaultConfig()
2626
'uriOptions' => [],
2727
'driverOptions' => [],
2828
'sessionId' => 'quartz',
29-
'dbName' => 'quartz',
29+
'dbName' => null,
3030
'managementLockCol' => 'managementLock',
3131
'calendarCol' => 'calendar',
3232
'triggerCol' => 'trigger',
@@ -42,7 +42,7 @@ public function testShouldReturnDefaultConfig()
4242

4343
public function testCouldSetConfigurationOptions()
4444
{
45-
$configuration = new QuartzConfiguration([]);
45+
$configuration = new QuartzConfiguration();
4646

4747
$processor = new Processor();
4848
$config = $processor->processConfiguration($configuration, [[
@@ -58,7 +58,7 @@ public function testCouldSetConfigurationOptions()
5858
'uriOptions' => [],
5959
'driverOptions' => [],
6060
'sessionId' => 'quartz',
61-
'dbName' => 'quartz',
61+
'dbName' => null,
6262
'managementLockCol' => 'managementLock',
6363
'calendarCol' => 'calendar',
6464
'triggerCol' => 'trigger',

Tests/Enqueue/EnqueueRemoteTransportProcessorTest.php

Lines changed: 12 additions & 12 deletions
Original file line numberDiff line numberDiff line change
@@ -5,8 +5,8 @@
55
use Enqueue\Consumption\QueueSubscriberInterface;
66
use Enqueue\Consumption\Result;
77
use Enqueue\Null\NullMessage;
8-
use Interop\Queue\PsrContext;
9-
use Interop\Queue\PsrProcessor;
8+
use Interop\Queue\Context;
9+
use Interop\Queue\Processor;
1010
use PHPUnit\Framework\TestCase;
1111
use Quartz\Bridge\Enqueue\EnqueueRemoteTransportProcessor;
1212
use Quartz\Bridge\Scheduler\RpcProtocol;
@@ -16,11 +16,11 @@
1616

1717
class EnqueueRemoteTransportProcessorTest extends TestCase
1818
{
19-
public function testShouldImpleentPsrProcessorInterface()
19+
public function testShouldImpleentProcessorInterface()
2020
{
2121
$processor = new EnqueueRemoteTransportProcessor($this->createSchedulerMock(), $this->createRpcProtocolMock());
2222

23-
$this->assertInstanceOf(PsrProcessor::class, $processor);
23+
$this->assertInstanceOf(Processor::class, $processor);
2424
}
2525

2626
public function testShouldImplementCommandSubscriberInterfaceAndReturnExpectectedSubscribedCommand()
@@ -30,9 +30,9 @@ public function testShouldImplementCommandSubscriberInterfaceAndReturnExpectecte
3030
$this->assertInstanceOf(CommandSubscriberInterface::class, $processor);
3131

3232
$expectedConfig = [
33-
'processorName' => 'quartz_rpc',
34-
'queueName' => 'quartz_rpc',
35-
'queueNameHardcoded' => true,
33+
'command' => 'quartz_rpc',
34+
'queue' => 'quartz_rpc',
35+
'prefix_queue' => false,
3636
'exclusive' => true,
3737
];
3838

@@ -78,7 +78,7 @@ public function testShouldInvokeSchedulerMethodAndReturnResponse()
7878
->willReturn('scheduler-result')
7979
;
8080

81-
$context = $this->createPsrContextMock();
81+
$context = $this->createContextMock();
8282
$context
8383
->expects($this->once())
8484
->method('createMessage')
@@ -125,7 +125,7 @@ public function testOnExceptionShouldEncodeExceptionAndReturn()
125125
->willThrowException($ex)
126126
;
127127

128-
$context = $this->createPsrContextMock();
128+
$context = $this->createContextMock();
129129
$context
130130
->expects($this->once())
131131
->method('createMessage')
@@ -141,11 +141,11 @@ public function testOnExceptionShouldEncodeExceptionAndReturn()
141141
}
142142

143143
/**
144-
* @return \PHPUnit_Framework_MockObject_MockObject|PsrContext
144+
* @return \PHPUnit_Framework_MockObject_MockObject|Context
145145
*/
146-
private function createPsrContextMock()
146+
private function createContextMock()
147147
{
148-
return $this->createMock(PsrContext::class);
148+
return $this->createMock(Context::class);
149149
}
150150

151151
/**

Tests/Scheduler/JobRunShellProcessorTest.php

Lines changed: 12 additions & 11 deletions
Original file line numberDiff line numberDiff line change
@@ -6,8 +6,8 @@
66
use Enqueue\Consumption\Result;
77
use Enqueue\Null\NullMessage;
88
use Enqueue\Util\JSON;
9-
use Interop\Queue\PsrContext;
10-
use Interop\Queue\PsrProcessor;
9+
use Interop\Queue\Context;
10+
use Interop\Queue\Processor;
1111
use PHPUnit\Framework\TestCase;
1212
use Quartz\Bridge\Scheduler\JobRunShellProcessor;
1313
use Quartz\Scheduler\StdJobRunShell;
@@ -16,11 +16,11 @@
1616

1717
class JobRunShellProcessorTest extends TestCase
1818
{
19-
public function testShouldImplementPsrProcessorInterface()
19+
public function testShouldImplementProcessorInterface()
2020
{
2121
$processor = new JobRunShellProcessor($this->createJobStore(), $this->createJobRunShell());
2222

23-
$this->assertInstanceOf(PsrProcessor::class, $processor);
23+
$this->assertInstanceOf(Processor::class, $processor);
2424
}
2525

2626
public function testShouldImplementCommandSubscriberInterfaceAndReturnExpectectedSubscribedCommand()
@@ -30,9 +30,9 @@ public function testShouldImplementCommandSubscriberInterfaceAndReturnExpectecte
3030
$this->assertInstanceOf(CommandSubscriberInterface::class, $processor);
3131

3232
$expectedConfig = [
33-
'processorName' => 'quartz_job_run_shell',
34-
'queueName' => 'quartz_job_run_shell',
35-
'queueNameHardcoded' => true,
33+
'command' => 'quartz_job_run_shell',
34+
'queue' => 'quartz_job_run_shell',
35+
'prefix_queue' => false,
3636
'exclusive' => true,
3737
];
3838

@@ -64,7 +64,7 @@ public function testShouldRejectMessageIfJobInstanceIdIsNotSet()
6464

6565
$processor = new JobRunShellProcessor($store, $shell);
6666

67-
$result = $processor->process(new NullMessage(), $this->createMock(PsrContext::class));
67+
$result = $processor->process(new NullMessage(), $this->createMock(Context::class));
6868

6969
$this->assertInstanceOf(Result::class, $result);
7070
$this->assertSame('fire instance id is empty', $result->getReason());
@@ -91,7 +91,7 @@ public function testShouldRejectMessageIfJobInstanceWasNotFound()
9191
'fireInstanceId' => '1234',
9292
]));
9393

94-
$result = $processor->process($message, $this->createMock(PsrContext::class));
94+
$result = $processor->process($message, $this->createMock(Context::class));
9595

9696
$this->assertInstanceOf(Result::class, $result);
9797
$this->assertSame('There is not trigger with fire instance id: "1234"', $result->getReason());
@@ -122,9 +122,10 @@ public function testShouldPassTriggerToJobRunShell()
122122
'fireInstanceId' => '1234',
123123
]));
124124

125-
$result = $processor->process($message, $this->createMock(PsrContext::class));
125+
$result = $processor->process($message, $this->createMock(Context::class));
126126

127-
$this->assertSame(Result::ACK, $result);
127+
$this->assertInstanceOf(Result::class, $result);
128+
$this->assertSame(Result::ACK, $result->getStatus());
128129
}
129130

130131
/**

composer.json

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -6,10 +6,10 @@
66
"keywords": ["job", "time", "task", "time scheduler", "quartz", "chrono"],
77
"license": "MIT",
88
"require": {
9-
"php": ">=5.6",
9+
"php": "^7.1",
1010
"symfony/framework-bundle": "^3|^4",
11-
"enqueue/enqueue": "^0.8",
12-
"queue-interop/queue-interop": "^0.6",
11+
"enqueue/enqueue": "^0.9",
12+
"queue-interop/queue-interop": "^0.7|^0.8",
1313
"php-quartz/quartz": "^0.1.1"
1414
},
1515
"require-dev": {

0 commit comments

Comments
 (0)