Fixed Queue generation and form

Author: Vitaliy Boyko

resources/fileTemplates/internal/Magento Message Queue Consumer Class.php.ft

@@ -0,0 +1,16 @@
+<?php
+#parse("PHP File Header.php")
+#if (${NAMESPACE})
+
+namespace ${NAMESPACE};
+#end
+
+use Magento\Framework\MessageQueue\ConsumerInterface;
+
+class ${CLASS_NAME} implements ConsumerInterface
+{
+   public function process($maxNumberOfMessages = null)
+   {
+       // TODO: Implement process() method.
+   }
+}

resources/fileTemplates/internal/Magento Message Queue Consumer Class.php.html

@@ -0,0 +1,14 @@
+<?php
+#parse("PHP File Header.php")
+#if (${NAMESPACE})
+
+namespace ${NAMESPACE};
+#end
+
+class ${CLASS_NAME}
+{
+    public function execute()
+    {
+        //TODO: implement method
+    }
+}

resources/fileTemplates/internal/Magento Message Queue Handler Class.php.ft

@@ -0,0 +1 @@
+

resources/fileTemplates/internal/Magento Message Queue Handler Class.php.html

@@ -0,0 +1,85 @@
+/*
+ * Copyright © Magento, Inc. All rights reserved.
+ * See COPYING.txt for license details.
+ */
+
+package com.magento.idea.magento2plugin.actions.generation.data;
+
+import com.magento.idea.magento2plugin.magento.files.MessageQueueClassPhp;
+
+@SuppressWarnings({"PMD.DataClass"})
+public class MessageQueueClassData {
+    private final String name;
+    private final String namespace;
+    private final String path;
+    private final String fqn;
+    private final MessageQueueClassPhp.Type type;
+
+    /**
+     * MessageQueueClassData constructor.
+     *
+     * @param name String
+     * @param namespace String
+     * @param path String
+     * @param fqn String
+     * @param type MessageQueueClassPhp.Type
+     */
+    public MessageQueueClassData(
+            final String name,
+            final String namespace,
+            final String path,
+            final String fqn,
+            final MessageQueueClassPhp.Type type
+    ) {
+        this.name = name;
+        this.namespace = namespace;
+        this.path = path;
+        this.fqn = fqn;
+        this.type = type;
+    }
+
+    /**
+     * Get data provider class name.
+     *
+     * @return String
+     */
+    public String getName() {
+        return name;
+    }
+
+    /**
+     * Get data provider class namespace.
+     *
+     * @return String
+     */
+    public String getNamespace() {
+        return namespace;
+    }
+
+    /**
+     * Get path.
+     *
+     * @return String
+     */
+    public String getPath() {
+        return path;
+    }
+
+    /**
+     * Get FQN.
+     *
+     * @return String
+     */
+    public String getFqn() {
+        return fqn;
+    }
+
+    /**
+     * Get Type.
+     *
+     * @return MessageQueueClassPhp.Type
+     */
+    public MessageQueueClassPhp.Type getType() {
+        return type;
+    }
+}

src/com/magento/idea/magento2plugin/actions/generation/data/MessageQueueClassData.java

@@ -12,6 +12,7 @@ public class QueueConsumerData {
     private final String maxMessages;
     private final String connectionName;
     private final String moduleName;
+    private final String handler;
 
     /**
      * Constructor.
@@ -22,14 +23,16 @@ public QueueConsumerData(
             final String consumerType,
             final String maxMessages,
             final String connectionName,
-            final String moduleName
+            final String moduleName,
+            final String handler
     ) {
         this.consumerName = consumerName;
         this.queueName = queueName;
         this.consumerType = consumerType;
         this.maxMessages = maxMessages;
         this.connectionName = connectionName;
         this.moduleName = moduleName;
+        this.handler = handler;
     }
 
     public String getConsumerName() {
@@ -40,7 +43,7 @@ public String getQueueName() {
         return queueName;
     }
 
-    public String getConsumerType() {
+    public String getConsumerClass() {
         return consumerType;
     }
 
@@ -55,4 +58,8 @@ public String getConnectionName() {
     public String getModuleName() {
         return moduleName;
     }
+
+    public String getHandler() {
+        return handler;
+    }
 }