18 private $mergedMessageProcessor;
23 private $defaultMessageProcessor;
28 private $messageProcessorLoader;
37 $this->mergedMessageProcessor = $this
38 ->getMockBuilder(\
Magento\Framework\MessageQueue\MessageProcessorInterface::class)
39 ->disableOriginalConstructor()
40 ->getMockForAbstractClass();
41 $this->defaultMessageProcessor = $this
42 ->getMockBuilder(\
Magento\Framework\MessageQueue\MessageProcessorInterface::class)
43 ->disableOriginalConstructor()
44 ->getMockForAbstractClass();
46 $objectManagerHelper =
new ObjectManagerHelper($this);
47 $this->messageProcessorLoader = $objectManagerHelper->getObject(
48 \
Magento\Framework\MessageQueue\MessageProcessorLoader::class,
50 'mergedMessageProcessor' => $this->mergedMessageProcessor,
51 'defaultMessageProcessor' => $this->defaultMessageProcessor
64 $messageTopic =
'topic';
69 $this->assertInstanceOf(
70 \
Magento\Framework\MessageQueue\MessageProcessorInterface::class,
71 $this->messageProcessorLoader->load($messages)
82 $mergedMessage = $this->getMockBuilder(\
Magento\Framework\MessageQueue\MergedMessageInterface::class)
83 ->disableOriginalConstructor()
84 ->getMockForAbstractClass();
85 $message = $this->getMockBuilder(\
Magento\Framework\MessageQueue\EnvelopeInterface::class)
86 ->disableOriginalConstructor()
87 ->getMockForAbstractClass();