File tree 1 file changed +3
-3
lines changed
pkg/enqueue/Tests/Functional/Client
1 file changed +3
-3
lines changed Original file line number Diff line number Diff line change @@ -34,7 +34,7 @@ public function testProduceAndConsumeOneMessage()
34
34
$ actualMessage = null ;
35
35
36
36
$ client = new SimpleClient ($ this ->context );
37
- $ client ->bind ('foo_topic ' , function (Message $ message ) use (&$ actualMessage ) {
37
+ $ client ->bind ('foo_topic ' , ' foo_processor ' , function (Message $ message ) use (&$ actualMessage ) {
38
38
$ actualMessage = $ message ;
39
39
40
40
return Result::ACK ;
@@ -56,12 +56,12 @@ public function testProduceAndRouteToTwoConsumes()
56
56
$ received = 0 ;
57
57
58
58
$ client = new SimpleClient ($ this ->context );
59
- $ client ->bind ('foo_topic ' , function () use (&$ received ) {
59
+ $ client ->bind ('foo_topic ' , ' foo_processor1 ' , function () use (&$ received ) {
60
60
++$ received ;
61
61
62
62
return Result::ACK ;
63
63
});
64
- $ client ->bind ('foo_topic ' , function () use (&$ received ) {
64
+ $ client ->bind ('foo_topic ' , ' foo_processor2 ' , function () use (&$ received ) {
65
65
++$ received ;
66
66
67
67
return Result::ACK ;
You can’t perform that action at this time.
0 commit comments