File tree 1 file changed +26
-1
lines changed
1 file changed +26
-1
lines changed Original file line number Diff line number Diff line change @@ -290,12 +290,37 @@ public function testShouldThrowExceptionIfProcessorQueueNameParameterIsNotSet()
290
290
291
291
public function testShouldSetupBroker ()
292
292
{
293
+ $ routerTopic = new RdKafkaTopic ('' );
294
+ $ routerQueue = new RdKafkaTopic ('' );
295
+
296
+ $ processorTopic = new RdKafkaTopic ('' );
297
+
293
298
$ context = $ this ->createPsrContextMock ();
294
299
300
+ $ context
301
+ ->expects ($ this ->at (0 ))
302
+ ->method ('createQueue ' )
303
+ ->willReturn ($ routerTopic )
304
+ ;
305
+ $ context
306
+ ->expects ($ this ->at (1 ))
307
+ ->method ('createQueue ' )
308
+ ->willReturn ($ routerQueue )
309
+ ;
310
+ $ context
311
+ ->expects ($ this ->at (2 ))
312
+ ->method ('createQueue ' )
313
+ ->willReturn ($ processorTopic )
314
+ ;
315
+
316
+ $ meta = new QueueMetaRegistry ($ this ->createDummyConfig (), [
317
+ 'default ' => [],
318
+ ]);
319
+
295
320
$ driver = new RdKafkaDriver (
296
321
$ context ,
297
322
$ this ->createDummyConfig (),
298
- $ this -> createDummyQueueMetaRegistry ()
323
+ $ meta
299
324
);
300
325
301
326
$ driver ->setupBroker ();
You can’t perform that action at this time.
0 commit comments