idle bugfix #405
viktorproggerAnnotations
7 warnings
|
PHP 8.4-ubuntu-latest:
src/ExistingMessagesConsumer.php#L46
Escaped Mutant for Mutator "FalseValue":
@@ @@
if ($this->messageConsumed = $callback($message)) {
$channel->basic_ack($amqpMessage->getDeliveryTag());
} else {
- $channel->basic_nack($amqpMessage->getDeliveryTag(), false, true);
+ $channel->basic_nack($amqpMessage->getDeliveryTag(), true, true);
}
} catch (Throwable $exception) {
$this->messageConsumed = false;
|
|
PHP 8.4-ubuntu-latest:
src/ExistingMessagesConsumer.php#L38
Escaped Mutant for Mutator "FalseValue":
@@ @@
$channel = $this->queueProvider->getChannel();
$consumerTag = uniqid(more_entropy: true);
try {
- $channel->basic_consume($this->queueProvider->getQueueSettings()->getName(), $consumerTag, false, false, false, false, function (AMQPMessage $amqpMessage) use ($callback, $channel): void {
+ $channel->basic_consume($this->queueProvider->getQueueSettings()->getName(), $consumerTag, false, false, true, false, function (AMQPMessage $amqpMessage) use ($callback, $channel): void {
try {
$message = $this->serializer->unserialize($amqpMessage->getBody());
if ($this->messageConsumed = $callback($message)) {
|
|
PHP 8.4-ubuntu-latest:
src/ExistingMessagesConsumer.php#L36
Escaped Mutant for Mutator "FalseValue":
@@ @@
$channel = $this->queueProvider->getChannel();
$consumerTag = uniqid(more_entropy: true);
try {
- $channel->basic_consume($this->queueProvider->getQueueSettings()->getName(), $consumerTag, false, false, false, false, function (AMQPMessage $amqpMessage) use ($callback, $channel): void {
+ $channel->basic_consume($this->queueProvider->getQueueSettings()->getName(), $consumerTag, true, false, false, false, function (AMQPMessage $amqpMessage) use ($callback, $channel): void {
try {
$message = $this->serializer->unserialize($amqpMessage->getBody());
if ($this->messageConsumed = $callback($message)) {
|
|
PHP 8.4-ubuntu-latest:
src/Adapter.php#L101
Escaped Mutant for Mutator "MethodCallRemoval":
@@ @@
} catch (Throwable $exception) {
$consumerTag = $amqpMessage->getConsumerTag();
if ($consumerTag !== null) {
- $channel->basic_cancel($consumerTag);
+
}
throw $exception;
}
|
|
PHP 8.4-ubuntu-latest:
src/Adapter.php#L93
Escaped Mutant for Mutator "TrueValue":
@@ @@
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, false, false, function (AMQPMessage $amqpMessage) use ($handlerCallback, $channel): void {
try {
$handlerCallback($this->serializer->unserialize($amqpMessage->getBody()));
$channel->basic_ack($amqpMessage->getDeliveryTag());
|
|
PHP 8.4-ubuntu-latest:
src/Adapter.php#L92
Escaped Mutant for Mutator "FalseValue":
@@ @@
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());
|
|
PHP 8.4-ubuntu-latest:
src/Adapter.php#L90
Escaped Mutant for Mutator "FalseValue":
@@ @@
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());
|