File tree Expand file tree Collapse file tree 2 files changed +3
-3
lines changed
Expand file tree Collapse file tree 2 files changed +3
-3
lines changed Original file line number Diff line number Diff line change @@ -22,7 +22,7 @@ public function __construct() {
2222 array ($ this , 'on_response ' ));
2323 }
2424 public function on_response ($ rep ) {
25- if ($ rep ->properties [ 'correlation_id ' ] == $ this ->corr_id ) {
25+ if ($ rep ->get ( 'correlation_id ' ) == $ this ->corr_id ) {
2626 $ this ->response = $ rep ->body ;
2727 }
2828 }
Original file line number Diff line number Diff line change @@ -24,11 +24,11 @@ function fib($n) {
2424
2525 $ msg = new AMQPMessage (
2626 (string ) fib ($ n ),
27- array ('correlation_id ' => $ req ->properties [ 'correlation_id ' ] )
27+ array ('correlation_id ' => $ req ->get ( 'correlation_id ' ) )
2828 );
2929
3030 $ req ->delivery_info ['channel ' ]->basic_publish (
31- $ msg , '' , $ req ->properties [ 'reply_to ' ] );
31+ $ msg , '' , $ req ->get ( 'reply_to ' ) );
3232 $ req ->delivery_info ['channel ' ]->basic_ack (
3333 $ req ->delivery_info ['delivery_tag ' ]);
3434};
You can’t perform that action at this time.
0 commit comments