Update due to yiisoft/queue changes (#111) #357
Annotations
8 warnings
|
ubuntu-latest pipelines will use ubuntu-24.04 soon. For more details, see https://github.com/actions/runner-images/issues/10636
|
|
Run infection:
src/Adapter.php#L89
Escaped Mutant for Mutator "FalseValue":
--- Original
+++ New
@@ @@
public function subscribe(callable $handlerCallback) : void
{
$channel = $this->queueProvider->getChannel();
- $channel->basic_consume($this->queueProvider->getQueueSettings()->getName(), $this->queueProvider->getQueueSettings()->getName(), false, false, false, true, function (AMQPMessage $amqpMessage) use($handlerCallback, $channel) : void {
+ $channel->basic_consume($this->queueProvider->getQueueSettings()->getName(), $this->queueProvider->getQueueSettings()->getName(), true, false, false, true, function (AMQPMessage $amqpMessage) use($handlerCallback, $channel) : void {
try {
$handlerCallback($this->serializer->unserialize($amqpMessage->getBody()));
$channel->basic_ack($amqpMessage->getDeliveryTag());
|
|
Run infection:
src/Adapter.php#L91
Escaped Mutant for Mutator "FalseValue":
--- Original
+++ New
@@ @@
public function subscribe(callable $handlerCallback) : void
{
$channel = $this->queueProvider->getChannel();
- $channel->basic_consume($this->queueProvider->getQueueSettings()->getName(), $this->queueProvider->getQueueSettings()->getName(), false, false, false, true, function (AMQPMessage $amqpMessage) use($handlerCallback, $channel) : void {
+ $channel->basic_consume($this->queueProvider->getQueueSettings()->getName(), $this->queueProvider->getQueueSettings()->getName(), false, false, true, true, function (AMQPMessage $amqpMessage) use($handlerCallback, $channel) : void {
try {
$handlerCallback($this->serializer->unserialize($amqpMessage->getBody()));
$channel->basic_ack($amqpMessage->getDeliveryTag());
|
|
Run infection:
src/Adapter.php#L100
Escaped Mutant for Mutator "MethodCallRemoval":
--- Original
+++ New
@@ @@
} catch (Throwable $exception) {
$consumerTag = $amqpMessage->getConsumerTag();
if ($consumerTag !== null) {
- $channel->basic_cancel($consumerTag);
+
}
throw $exception;
}
|
|
Run infection:
src/ExistingMessagesConsumer.php#L35
Escaped Mutant for Mutator "FalseValue":
--- Original
+++ New
@@ @@
*/
public function consume(callable $callback) : void
{
- $this->channel->basic_consume($this->queueName, '', false, false, false, false, function (AMQPMessage $amqpMessage) use($callback) : void {
+ $this->channel->basic_consume($this->queueName, '', true, false, false, false, function (AMQPMessage $amqpMessage) use($callback) : void {
try {
$message = $this->serializer->unserialize($amqpMessage->getBody());
if ($this->messageConsumed = $callback($message)) {
|
|
Run infection:
src/ExistingMessagesConsumer.php#L37
Escaped Mutant for Mutator "FalseValue":
--- Original
+++ New
@@ @@
*/
public function consume(callable $callback) : void
{
- $this->channel->basic_consume($this->queueName, '', false, false, false, false, function (AMQPMessage $amqpMessage) use($callback) : void {
+ $this->channel->basic_consume($this->queueName, '', false, false, true, false, function (AMQPMessage $amqpMessage) use($callback) : void {
try {
$message = $this->serializer->unserialize($amqpMessage->getBody());
if ($this->messageConsumed = $callback($message)) {
|
|
Run infection:
src/ExistingMessagesConsumer.php#L43
Escaped Mutant for Mutator "MethodCallRemoval":
--- Original
+++ New
@@ @@
try {
$message = $this->serializer->unserialize($amqpMessage->getBody());
if ($this->messageConsumed = $callback($message)) {
- $this->channel->basic_ack($amqpMessage->getDeliveryTag());
+
}
} catch (Throwable $exception) {
$this->messageConsumed = false;
|
|
Run infection:
src/ExistingMessagesConsumer.php#L57
Escaped Mutant for Mutator "DoWhile":
--- Original
+++ New
@@ @@
do {
$this->messageConsumed = false;
$this->channel->wait(null, true);
- } while ($this->messageConsumed === true);
+ } while (false);
}
}
|
Loading