File tree Expand file tree Collapse file tree 2 files changed +22
-1
lines changed Expand file tree Collapse file tree 2 files changed +22
-1
lines changed Original file line number Diff line number Diff line change @@ -140,12 +140,14 @@ return [
140140 'connection' => 'default',
141141 'unserializer' => 'json_decode',
142142 'lazy' => true,
143- 'direct_reply_to' => false
143+ 'direct_reply_to' => false,
144+ 'expect_serialized_response' => false
144145 ],
145146 ],
146147 'rpc_servers' => [
147148 'random_int' => [
148149 'connection' => 'default',
150+ // Автоматом регистрируется сервисом. Без обработки зависимостей.
149151 'callback' => 'Proklung\RabbitMq\Examples\RandomIntServer',
150152 'qos_options' => [
151153 'prefetch_size' => 0,
@@ -187,6 +189,23 @@ class UploadPictureConsumer implements ConsumerInterface
187189}
188190```
189191
192+ Пример серверной части RPC сообщений (при опции клиента ` expect_serialized_response ` равной ` false ` ):
193+
194+ ``` php
195+
196+ use PhpAmqpLib\Message\AMQPMessage;
197+
198+ class RandomIntServer
199+ {
200+ public function execute(AMQPMessage $request)
201+ {
202+ $params = json_decode($request->getBody(), true);
203+
204+ return ['request_id' => mt_rand(1, 123)];
205+ }
206+ }
207+ ```
208+
190209## Интеграция с CLI
191210
192211Доступны некоторые команды, которые упрощают работу:
Original file line number Diff line number Diff line change @@ -12,6 +12,8 @@ class RandomIntServer
1212{
1313 public function execute (AMQPMessage $ request )
1414 {
15+ $ params = json_decode ($ request ->getBody (), true );
16+
1517 return ['request_id ' => mt_rand (1 , 123 )];
1618 }
1719}
You can’t perform that action at this time.
0 commit comments