public function consume($message, array $headers = [])
    {
        return $this->serializer->serialize(
            $this->consumer->consume(
                $this->serializer->deserialize($message),
                $headers
            )
        );
    }
public function consume($message, array $headers = [])
    {
        return $this->serializer->serialize(
            $this->consumer->consume(
                $this->serializer->deserialize($message),
                $headers
            )
        );
    }
public function consume ( $ message , array $ headers = [ ] ) { return $ this -> serializer -> serialize ( $ this -> consumer -> consume ( $ this -> serializer -> deserialize ( $ message ) , $ headers ) ) ; }
Consumes a message.

@param mixed    $message
@param string[] $headers

@return string
Consumes a message .