Subversion-Projekte lars-tiefland.laravel_shop

Revision

Revision 148 | Ganze Datei anzeigen | Leerzeichen ignorieren | Details | Blame | Letzte Änderung | Log anzeigen | RSS feed

Revision 148 Revision 621
Zeile 149... Zeile 149...
149
        return strtolower($routingKey);
149
        return strtolower($routingKey);
150
    }
150
    }
Zeile 151... Zeile 151...
151
 
151
 
152
    private function createAmqpMessage(string $data): AMQPMessage
152
    private function createAmqpMessage(string $data): AMQPMessage
153
    {
-
 
154
        return new AMQPMessage(
-
 
155
            $data,
153
    {
156
            [
154
        $attributes = [
157
                'delivery_mode' => 2,
155
            'delivery_mode' => 2,
158
                'content_type' => 'application/json',
156
            'content_type' => 'application/json',
-
 
157
        ];
-
 
158
        if ($this->extraAttributes) {
159
            ]
159
            $attributes = array_merge($attributes, $this->extraAttributes);
-
 
160
        }
160
        );
161
        return new AMQPMessage($data, $attributes);
Zeile 161... Zeile 162...
161
    }
162
    }
162
 
163
 
163
    /**
164
    /**