Consumer Client Trait

The ConsumerClientTrait is a helper to implement a consumer client. It implements the ConsumerClientInterface. You need to define the connector, the pipe name and the process function.

<?php
class MyConsumerClient implements ConsumerClientInterface
{
    use ConsumerClientTrait;

    public function __construct(ConnectorInterface $connector, Pipe $pipe)
    {
        $this->connector = $connector;
        $this->pipe = $pipe;
    }
    
    // From the Interface
    public function getPipe(): Pipe
    {
        return $this->pipe;
    }

    public function getConnector(): ConnectorInterface
    {
        return $this->connector;
    }

    public function getLogger(): LoggerInterface
    {
        return new NullLogger();
    }

    public function getLogOutputStart(Message $message): string
    {
        return "Start";
    }

    public function getLogOutputException(\Throwable $exception, Message $message): string
    {
        return "Exception: " . $exception->getMessage();
    }

    public function getLogOutputSuccess(Message $message): string
    {
        return "Success";
    }
    
    public function processMessage(Message $message)
    {
        echo "Process the message";
        echo $message()->getBody();
    }
}

Publish

<?php
$consumerClient = new MyConsumerClient($connector, $pipe);
$consumerClient->getConnector()->publish(new Envelope($consumerClient->getPipe()), new Message("Hello World"));

Consume

<?php
// Register the connector and associate with a scheme
ConnectorFactory::registerConnector(MockConnector::class);

// Create a connector
$connector = ConnectorFactory::create(new Uri("mock://local"));

// Create a queue
$pipe = new Pipe("test");

// Create a consumer client
$consumerClient = new MyConsumerClient($connector, $pipe);

// Connect to the queue and wait to consume the message
$consumerClient->consume();