[MessengerBundle] only allow to list ListableReceiverInterface

src/CoreShop/Bundle/MessengerBundle/Controller/ListMessagesController.php

@@ -42,6 +42,19 @@ public function listReceiverMessageCountAction(ReceiversRepositoryInterface $rec
         return $this->json(['data' => $receivers, 'success' => true]);
     }
 
+    public function listListableReceiversAction(ReceiversRepositoryInterface $receiverLocator): Response
+    {
+        $receivers = [];
+        foreach ($receiverLocator->getListableReceiversMapping() as $name => $receiver) {
+            $receivers[] = [
+                'receiver' => $name,
+                'count' => $receiver instanceof MessageCountAwareInterface ? $receiver->getMessageCount() : null,
+            ];
+        }
+
+        return $this->json(['data' => $receivers, 'success' => true]);
+    }
+
     public function listFailureReceiversAction(FailureReceiversRepositoryInterface $failureReceivers): Response
     {
         $receivers = [];

src/CoreShop/Bundle/MessengerBundle/Exception/FailureReceiverNotListableException.php → src/CoreShop/Bundle/MessengerBundle/Exception/ReceiverNotListableException.php

@@ -20,10 +20,10 @@
 
 use Symfony\Component\Messenger\Exception\RuntimeException;
 
-final class FailureReceiverNotListableException extends RuntimeException
+final class ReceiverNotListableException extends RuntimeException
 {
-    public function __construct(
-        ) {
-        parent::__construct('The failure receiver does not support listing or showing specific messages.');
+    public function __construct()
+    {
+        parent::__construct('The receiver does not support listing or showing specific messages.');
     }
 }

src/CoreShop/Bundle/MessengerBundle/Messenger/FailedMessageRejecter.php

@@ -18,7 +18,7 @@
 
 namespace CoreShop\Bundle\MessengerBundle\Messenger;
 
-use CoreShop\Bundle\MessengerBundle\Exception\FailureReceiverNotListableException;
+use CoreShop\Bundle\MessengerBundle\Exception\ReceiverNotListableException;
 use Symfony\Component\Messenger\Transport\Receiver\ListableReceiverInterface;
 
 final class FailedMessageRejecter implements FailedMessageRejecterInterface
@@ -33,7 +33,7 @@ public function rejectStoredMessage(string $receiverName, int $id): void
         $failureReceiver = $this->failureReceivers->getFailureReceiver($receiverName);
 
         if (!$failureReceiver instanceof ListableReceiverInterface) {
-            throw new FailureReceiverNotListableException();
+            throw new ReceiverNotListableException();
         }
 
         $envelope = $failureReceiver->find($id);

src/CoreShop/Bundle/MessengerBundle/Messenger/FailedMessageRepository.php

@@ -18,7 +18,7 @@
 
 namespace CoreShop\Bundle\MessengerBundle\Messenger;
 
-use CoreShop\Bundle\MessengerBundle\Exception\FailureReceiverNotListableException;
+use CoreShop\Bundle\MessengerBundle\Exception\ReceiverNotListableException;
 use Symfony\Component\Messenger\Envelope;
 use Symfony\Component\Messenger\Stamp\ErrorDetailsStamp;
 use Symfony\Component\Messenger\Stamp\RedeliveryStamp;
@@ -37,7 +37,7 @@ public function listFailedMessages(string $receiverName, int $limit = 10): array
         $receiver = $this->failureReceivers->getFailureReceiver($receiverName);
 
         if (!$receiver instanceof ListableReceiverInterface) {
-            throw new FailureReceiverNotListableException();
+            throw new ReceiverNotListableException();
         }
 
         $envelopes = $receiver->all($limit);

src/CoreShop/Bundle/MessengerBundle/Messenger/FailedMessageRetryer.php

@@ -18,7 +18,7 @@
 
 namespace CoreShop\Bundle\MessengerBundle\Messenger;
 
-use CoreShop\Bundle\MessengerBundle\Exception\FailureReceiverNotListableException;
+use CoreShop\Bundle\MessengerBundle\Exception\ReceiverNotListableException;
 use CoreShop\Bundle\MessengerBundle\Stamp\RetriedByUserStamp;
 use Symfony\Component\Messenger\Envelope;
 use Symfony\Component\Messenger\MessageBusInterface;
@@ -38,7 +38,7 @@ public function retryFailedMessage(string $receiver, int $id): void
         $failureReceiver = $this->failureReceivers->getFailureReceiver($receiver);
 
         if (!$failureReceiver instanceof ListableReceiverInterface) {
-            throw new FailureReceiverNotListableException();
+            throw new ReceiverNotListableException();
         }
 
         $envelope = $failureReceiver->find($id);

src/CoreShop/Bundle/MessengerBundle/Messenger/MessageRepository.php

@@ -18,7 +18,7 @@
 
 namespace CoreShop\Bundle\MessengerBundle\Messenger;
 
-use CoreShop\Bundle\MessengerBundle\Exception\FailureReceiverNotListableException;
+use CoreShop\Bundle\MessengerBundle\Exception\ReceiverNotListableException;
 use Symfony\Component\Messenger\Envelope;
 use Symfony\Component\Messenger\Stamp\TransportMessageIdStamp;
 use Symfony\Component\Messenger\Transport\Receiver\ListableReceiverInterface;
@@ -35,7 +35,7 @@ public function listMessages(string $receiverName, int $limit = 10): array
         $receiver = $this->receivers->getReceiver($receiverName);
 
         if (!$receiver instanceof ListableReceiverInterface) {
-            throw new FailureReceiverNotListableException();
+            throw new ReceiverNotListableException();
         }
 
         $envelopes = $receiver->all($limit);

src/CoreShop/Bundle/MessengerBundle/Messenger/ReceiversRepository.php

@@ -19,6 +19,7 @@
 namespace CoreShop\Bundle\MessengerBundle\Messenger;
 
 use CoreShop\Bundle\MessengerBundle\Exception\ReceiverDoesNotExistException;
+use Symfony\Component\Messenger\Transport\Receiver\ListableReceiverInterface;
 use Symfony\Component\Messenger\Transport\Receiver\ReceiverInterface;
 use Symfony\Contracts\Service\ServiceProviderInterface;
 
@@ -43,6 +44,26 @@ public function getReceiversMapping(): array
         return $receivers;
     }
 
+
+    /**
+     * @return ReceiverInterface[]
+     */
+    public function getListableReceiversMapping(): array
+    {
+        $receivers = [];
+        foreach ($this->receiverNames as $receiverName) {
+            $receiver = $this->getReceiver($receiverName);
+
+            if (!$receiver instanceof ListableReceiverInterface) {
+                continue;
+            }
+
+            $receivers[$receiverName] = $receiver;
+        }
+
+        return $receivers;
+    }
+
     public function getReceiver(string $receiverName): ReceiverInterface
     {
         if (!\in_array($receiverName, $this->receiverNames, true) || !$this->receiverLocator->has($receiverName)) {

src/CoreShop/Bundle/MessengerBundle/Messenger/ReceiversRepositoryInterface.php

@@ -27,5 +27,10 @@ interface ReceiversRepositoryInterface
      */
     public function getReceiversMapping(): array;
 
+    /**
+     * @return ReceiverInterface[]
+     */
+    public function getListableReceiversMapping(): array;
+
     public function getReceiver(string $receiverName): ReceiverInterface;
 }

src/CoreShop/Bundle/MessengerBundle/Resources/config/pimcore/routing.yml

@@ -4,6 +4,12 @@ coreshop_admin_messenger_count:
   options:
     expose: true
 
+coreshop_admin_messenger_list_receivers:
+  path: /admin/messenger/list-receivers
+  defaults: { _controller: CoreShop\Bundle\MessengerBundle\Controller\ListMessagesController::listListableReceiversAction }
+  options:
+    expose: true
+
 coreshop_admin_messenger_list_failed:
   path: /admin/messenger/list-failed/{receiverName}
   defaults: { _controller: CoreShop\Bundle\MessengerBundle\Controller\ListMessagesController::listFailedMessagesAction }

src/CoreShop/Bundle/MessengerBundle/Resources/public/pimcore/js/list.js

@@ -304,7 +304,7 @@ coreshop.messenger.list = Class.create({
             store: {
                 proxy: {
                     type: 'ajax',
-                    url: Routing.generate('coreshop_admin_messenger_count'),
+                    url: Routing.generate('coreshop_admin_messenger_list_receivers'),
                     reader: {
                         type: 'json',
                         rootProperty: 'data'