added queue for segment add and remove contacts

Author: pandathuan

Queue/MessageQueues/SegmentAdd/Publisher.php

@@ -0,0 +1,13 @@
+<?php declare(strict_types=1);
+
+namespace Lof\Mautic\Queue\MessageQueues\SegmentAdd;
+
+use Lof\Mautic\Queue\MessageQueues\AbstractPublisher;
+
+class Publisher extends AbstractPublisher
+{
+    /**
+     * {@inheritdoc}
+     */
+    protected $_topic_name = 'mautic.magento.segment.add';
+}

Queue/MessageQueues/SegmentRemove/Publisher.php

@@ -0,0 +1,13 @@
+<?php declare(strict_types=1);
+
+namespace Lof\Mautic\Queue\MessageQueues\SegmentRemove;
+
+use Lof\Mautic\Queue\MessageQueues\AbstractPublisher;
+
+class Publisher extends AbstractPublisher
+{
+    /**
+     * {@inheritdoc}
+     */
+    protected $_topic_name = 'mautic.magento.segment.remove';
+}

etc/communication.xml

@@ -5,4 +5,6 @@
     <topic name="mautic.magento.review.save" request="string"/>
     <topic name="mautic.magento.subscriber.save" request="string"/>
     <topic name="mautic.magento.contact.delete" request="string"/>
+    <topic name="mautic.magento.segment.add" request="string"/>
+    <topic name="mautic.magento.segment.remove" request="string"/>
 </config>

etc/queue_consumer.xml

@@ -13,4 +13,8 @@
     <consumer name="mautic_subscriber_save" queue="mautic_subscriber_save" connection="amqp" handler="Lof\Mautic\Queue\MessageQueues\Consumer::processMessage"/>
 
     <consumer name="mautic_contact_delete" queue="mautic_contact_delete" connection="amqp" handler="Lof\Mautic\Queue\MessageQueues\ContactDelete\Consumer::processMessage"/>
+
+    <consumer name="mautic_segment_add" queue="mautic_segment_add" connection="amqp" handler="Lof\Mautic\Queue\MessageQueues\SegmentAdd\Consumer::processMessage"/>
+
+    <consumer name="mautic_segment_remove" queue="mautic_segment_remove" connection="amqp" handler="Lof\Mautic\Queue\MessageQueues\SegmentRemove\Consumer::processMessage"/>
 </config>

etc/queue_publisher.xml

@@ -19,4 +19,12 @@
     <publisher topic="mautic.magento.contact.delete">
         <connection name="amqp" exchange="mautic.magento.contact.delete" />
     </publisher>
+
+    <publisher topic="mautic.magento.segment.add">
+        <connection name="amqp" exchange="mautic.magento.segment.add" />
+    </publisher>
+
+    <publisher topic="mautic.magento.segment.remove">
+        <connection name="amqp" exchange="mautic.magento.segment.remove" />
+    </publisher>
 </config>

etc/queue_topology.xml

@@ -26,4 +26,12 @@
     <exchange name="mautic.magento.contact.delete" type="topic" connection="amqp">
         <binding id="mautic_contact_delete" topic="mautic.magento.contact.delete" destinationType="queue" destination="mautic_contact_delete"/>
     </exchange>
+
+    <exchange name="mautic.magento.segment.add" type="topic" connection="amqp">
+        <binding id="mautic_segment_add" topic="mautic.magento.segment.add" destinationType="queue" destination="mautic_segment_add"/>
+    </exchange>
+
+    <exchange name="mautic.magento.segment.remove" type="topic" connection="amqp">
+        <binding id="mautic_segment_remove" topic="mautic.magento.segment.remove" destinationType="queue" destination="mautic_segment_remove"/>
+    </exchange>
 </config>