18 private $messageStatusProcessor;
27 $objectManagerHelper =
new ObjectManagerHelper($this);
28 $this->messageStatusProcessor = $objectManagerHelper->getObject(
29 \
Magento\Framework\MessageQueue\MessageStatusProcessor::class
40 $queue = $this->getMockBuilder(\
Magento\Framework\MessageQueue\QueueInterface::class)
41 ->disableOriginalConstructor()
42 ->getMockForAbstractClass();
43 $queue->expects($this->atLeastOnce())->method(
'acknowledge');
44 $message = $this->getMockBuilder(\
Magento\Framework\MessageQueue\EnvelopeInterface::class)
45 ->disableOriginalConstructor()
46 ->getMockForAbstractClass();
48 $this->messageStatusProcessor->acknowledgeMessages(
$queue, [
$message]);
58 $queue = $this->getMockBuilder(\
Magento\Framework\MessageQueue\QueueInterface::class)
59 ->disableOriginalConstructor()
60 ->getMockForAbstractClass();
61 $queue->expects($this->atLeastOnce())->method(
'reject');
62 $message = $this->getMockBuilder(\
Magento\Framework\MessageQueue\EnvelopeInterface::class)
63 ->disableOriginalConstructor()
64 ->getMockForAbstractClass();
testAcknowledgeMessages()