Skip to content

Commit 4e95e8d

Browse files
committed
Fixes
1 parent 7722d32 commit 4e95e8d

File tree

3 files changed

+9
-7
lines changed

3 files changed

+9
-7
lines changed

README.md

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -226,8 +226,8 @@ class UploadPictureConsumer implements ConsumerInterface
226226
- [ ] Dynamic consumer
227227
- [ ] Batch consumer
228228
- [ ] Anon consumer
229-
- [x] Rpc client (в разработке)
230-
- [x] Rpc server (в разработке)
229+
- [x] Rpc client
230+
- [x] Rpc server
231231
- [ ] Logged channel
232232

233233
## Credits

install/version.php

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -4,6 +4,6 @@
44
*/
55

66
$arModuleVersion = [
7-
'VERSION' => '1.1.0',
8-
'VERSION_DATE' => '2021-07-13 00:00:00',
7+
'VERSION' => '1.1.1',
8+
'VERSION_DATE' => '2021-07-13 15:00:00',
99
];

lib/Examples/RandomIntServer.php

Lines changed: 5 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -2,14 +2,16 @@
22

33
namespace Proklung\RabbitMq\Examples;
44

5+
use PhpAmqpLib\Message\AMQPMessage;
6+
57
/**
68
* Class RandomIntServer
79
* @package Proklung\RabbitMq\Examples
810
*/
911
class RandomIntServer
1012
{
11-
public function execute()
13+
public function execute(AMQPMessage $request)
1214
{
13-
14-
}
15+
return ['request_id' => mt_rand(1, 123)];
16+
}
1517
}

0 commit comments

Comments
 (0)