src/Queues/SqsQueue.php
/**
     * Higher order function that parses and consumes the message received.
     *
     * @return callable
     */
Higher order function that parses and consumes the message received.
@return callable
Higher order function that parses and consumes the message received . @return callable
private function parseAndConsumeMessage(): callable
    {
        return function ($message) {
            $parser = $this->getPayloadParser($message);
            $headers = $parser->getHeaders($message);
            $body = $parser->getBody($message);
            $this->events->triggerActions($headers, $body);
            $this->deleteMessage($message['ReceiptHandle']);
        };
    }
private function parseAndConsumeMessage ( ) : callable { return function ( $ message ) { $ parser = $ this -> getPayloadParser ( $ message ) ; $ headers = $ parser -> getHeaders ( $ message ) ; $ body = $ parser -> getBody ( $ message ) ; $ this -> events -> triggerActions ( $ headers , $ body ) ; $ this -> deleteMessage ( $ message [ 'ReceiptHandle' ] ) ; } ; }
Higher order function that parses and consumes the message received.
Higher order function that parses and consumes the message received .