MessageProcessorInterface.php 791 B

123456789101112131415161718192021222324252627282930
  1. <?php
  2. /**
  3. * Copyright © Magento, Inc. All rights reserved.
  4. * See COPYING.txt for license details.
  5. */
  6. namespace Magento\Framework\MessageQueue;
  7. /**
  8. * Interface for processing queue messages.
  9. */
  10. interface MessageProcessorInterface
  11. {
  12. /**
  13. * Processing decoded messages, invoking callbacks, changing statuses for messages.
  14. *
  15. * @param QueueInterface $queue
  16. * @param ConsumerConfigurationInterface $configuration
  17. * @param array $messages
  18. * @param array $messagesToAcknowledge
  19. * @param array $mergedMessages
  20. * @return void
  21. */
  22. public function process(
  23. QueueInterface $queue,
  24. ConsumerConfigurationInterface $configuration,
  25. array $messages,
  26. array $messagesToAcknowledge,
  27. array $mergedMessages
  28. );
  29. }