123456789101112131415161718192021222324252627282930 |
- <?php
- /**
- * Copyright © Magento, Inc. All rights reserved.
- * See COPYING.txt for license details.
- */
- namespace Magento\Framework\MessageQueue;
- /**
- * Interface for processing queue messages.
- */
- interface MessageProcessorInterface
- {
- /**
- * Processing decoded messages, invoking callbacks, changing statuses for messages.
- *
- * @param QueueInterface $queue
- * @param ConsumerConfigurationInterface $configuration
- * @param array $messages
- * @param array $messagesToAcknowledge
- * @param array $mergedMessages
- * @return void
- */
- public function process(
- QueueInterface $queue,
- ConsumerConfigurationInterface $configuration,
- array $messages,
- array $messagesToAcknowledge,
- array $mergedMessages
- );
- }
|