One Hat Cyber Team

Your IP: 216.73.216.1
Server IP: 185.238.29.86
Server: Linux server2 6.8.12-6-pve #1 SMP PREEMPT_DYNAMIC PMX 6.8.12-6 (2024-12-19T19:05Z) x86_64
Server Software: nginx/1.18.0
PHP Version: 8.1.31
Buat File | Buat Folder

Dir : ~/var/www/shopware/vendor/enqueue/null/

View File Name : NullContext.php

<?php

declare(strict_types=1);

namespace Enqueue\Null;

use Interop\Queue\Consumer;
use Interop\Queue\Context;
use Interop\Queue\Destination;
use Interop\Queue\Message;
use Interop\Queue\Producer;
use Interop\Queue\Queue;
use Interop\Queue\SubscriptionConsumer;
use Interop\Queue\Topic;

class NullContext implements Context
{
    /**
     * @return NullMessage
     */
    public function createMessage(string $body = '', array $properties = [], array $headers = []): Message
    {
        $message = new NullMessage();
        $message->setBody($body);
        $message->setProperties($properties);
        $message->setHeaders($headers);

        return $message;
    }

    /**
     * @return NullQueue
     */
    public function createQueue(string $name): Queue
    {
        return new NullQueue($name);
    }

    /**
     * @return NullQueue
     */
    public function createTemporaryQueue(): Queue
    {
        return $this->createQueue(uniqid('', true));
    }

    /**
     * @return NullTopic
     */
    public function createTopic(string $name): Topic
    {
        return new NullTopic($name);
    }

    /**
     * @return NullConsumer
     */
    public function createConsumer(Destination $destination): Consumer
    {
        return new NullConsumer($destination);
    }

    /**
     * @return NullProducer
     */
    public function createProducer(): Producer
    {
        return new NullProducer();
    }

    /**
     * @return NullSubscriptionConsumer
     */
    public function createSubscriptionConsumer(): SubscriptionConsumer
    {
        return new NullSubscriptionConsumer();
    }

    public function purgeQueue(Queue $queue): void
    {
    }

    public function close(): void
    {
    }
}