magento enqueue

Author: ASKozienko

README.md

@@ -0,0 +1,21 @@
+
+
+app/etc/local.xml
+```xml
+<config>
+  <default>
+    <enqueue>
+      <processors>
+        <processor1>
+          <topic>topic1</topic>
+          <helper>magento-helper-name1</helper>
+        </processor1>
+        <processor2>
+          <topic>topic2</topic>
+          <helper>magento-helper-name2</helper>
+        </processor2>
+      </processors>
+    </enqueue>
+  </default>
+</config>
+```

src/Enqueue/Enqueue/Helper/Data.php

@@ -17,18 +17,18 @@ public function bindProcessors()
 
         foreach ($processors as $name => $config) {
             if (empty($config['topic'])) {
-                throw new \LogicException('Topic name is not set for processor: "%s"', $name);
+                throw new \LogicException(sprintf('Topic name is not set for processor: "%s"', $name));
             }
 
             if (empty($config['helper'])) {
-                throw new \LogicException('Helper name is not set for processor: "%s"', $name);
+                throw new \LogicException(sprintf('Helper name is not set for processor: "%s"', $name));
             }
 
             $this->getClient()->bind($config['topic'], $name, function () use ($config) {
                 $processor = Mage::helper($config['helper']);
 
                 if (false == $processor instanceof PsrProcessor) {
-                    throw new \LogicException();
+                    throw new \LogicException(sprintf('Expects processor is instance of: "%s"', PsrProcessor::class));
                 }
 
                 call_user_func_array([$processor, 'process'], func_get_args());