From ae9a9f6b0dadf5322b2e60627abeab7cd481dfc3 Mon Sep 17 00:00:00 2001
From: Maksim Kotlyar <kotlyar.maksim@gmail.com>
Date: Mon, 8 May 2017 11:09:52 +0300
Subject: [PATCH] Enqueue recipes.

---
 .../0.3/etc/packages/enqueue_amqp.yaml        | 23 +++++++++++++++++++
 enqueue/amqp-ext/0.3/manifest.json            | 12 ++++++++++
 enqueue/enqueue-bundle/0.3/Makefile           |  3 +++
 .../0.3/etc/packages/test/enqueue.yaml        |  6 +++++
 enqueue/enqueue-bundle/0.3/manifest.json      |  8 +++++++
 enqueue/enqueue-bundle/0.3/post_install.txt   |  1 +
 enqueue/fs/0.3/etc/packages/enqueue_fs.yaml   |  5 ++++
 enqueue/fs/0.3/manifest.json                  | 12 ++++++++++
 enqueue/fs/0.3/var/queue/.gitkeep             |  0
 9 files changed, 70 insertions(+)
 create mode 100644 enqueue/amqp-ext/0.3/etc/packages/enqueue_amqp.yaml
 create mode 100644 enqueue/amqp-ext/0.3/manifest.json
 create mode 100644 enqueue/enqueue-bundle/0.3/Makefile
 create mode 100644 enqueue/enqueue-bundle/0.3/etc/packages/test/enqueue.yaml
 create mode 100644 enqueue/enqueue-bundle/0.3/manifest.json
 create mode 100644 enqueue/enqueue-bundle/0.3/post_install.txt
 create mode 100644 enqueue/fs/0.3/etc/packages/enqueue_fs.yaml
 create mode 100644 enqueue/fs/0.3/manifest.json
 create mode 100644 enqueue/fs/0.3/var/queue/.gitkeep

diff --git a/enqueue/amqp-ext/0.3/etc/packages/enqueue_amqp.yaml b/enqueue/amqp-ext/0.3/etc/packages/enqueue_amqp.yaml
new file mode 100644
index 000000000..6875e25f7
--- /dev/null
+++ b/enqueue/amqp-ext/0.3/etc/packages/enqueue_amqp.yaml
@@ -0,0 +1,23 @@
+enqueue:
+    transport:
+        default: 'amqp'
+        amqp:
+            host: '%env(ENQUEUE_AMQP_HOST)%'
+            port: '%env(ENQUEUE_AMQP_PORT)%'
+            login: '%env(ENQUEUE_AMQP_LOGIN)%'
+            password: '%env(ENQUEUE_AMQP_PASSWORD)%'
+            vhost: '%env(ENQUEUE_AMQP_VHOST)%'
+
+#        If you use RabbitMQ broker you can replace amqp transport with this one. It enables specific features like priorities, delays.
+#        default: 'rabbitmq_amqp'
+#        rabbitmq_amqp:
+#
+#            host: '%env(ENQUEUE_AMQP_HOST)%'
+#            port: '%env(ENQUEUE_AMQP_PORT)%'
+#            login: '%env(ENQUEUE_AMQP_LOGIN)%'
+#            password: '%env(ENQUEUE_AMQP_PASSWORD)%'
+#            vhost: '%env(ENQUEUE_AMQP_VHOST)%'
+#
+#            # The option tells whether RabbitMQ broker has delay plugin installed or not
+#            delay_plugin_installed: false
+
diff --git a/enqueue/amqp-ext/0.3/manifest.json b/enqueue/amqp-ext/0.3/manifest.json
new file mode 100644
index 000000000..8176ff389
--- /dev/null
+++ b/enqueue/amqp-ext/0.3/manifest.json
@@ -0,0 +1,12 @@
+{
+    "copy-from-recipe": {
+        "etc/": "%ETC_DIR%/"
+    },
+    "env": {
+        "ENQUEUE_AMQP_HOST": "localhost",
+        "ENQUEUE_AMQP_PORT": "5672",
+        "ENQUEUE_AMQP_LOGIN": "guest",
+        "ENQUEUE_AMQP_PASSWORD": "guest",
+        "ENQUEUE_AMQP_VHOST": "/"
+    }
+}
diff --git a/enqueue/enqueue-bundle/0.3/Makefile b/enqueue/enqueue-bundle/0.3/Makefile
new file mode 100644
index 000000000..f70b3658b
--- /dev/null
+++ b/enqueue/enqueue-bundle/0.3/Makefile
@@ -0,0 +1,3 @@
+consume:
+	@test -f bin/console && bin/console enqueue:consume --setup-broker || echo "cannot consume messages (needs symfony/console)"
+.PHONY: consume
diff --git a/enqueue/enqueue-bundle/0.3/etc/packages/test/enqueue.yaml b/enqueue/enqueue-bundle/0.3/etc/packages/test/enqueue.yaml
new file mode 100644
index 000000000..16975e867
--- /dev/null
+++ b/enqueue/enqueue-bundle/0.3/etc/packages/test/enqueue.yaml
@@ -0,0 +1,6 @@
+enqueue:
+    transport:
+        default: 'null'
+        'null': ~
+    client:
+        traceable_producer: true
diff --git a/enqueue/enqueue-bundle/0.3/manifest.json b/enqueue/enqueue-bundle/0.3/manifest.json
new file mode 100644
index 000000000..3e9efa667
--- /dev/null
+++ b/enqueue/enqueue-bundle/0.3/manifest.json
@@ -0,0 +1,8 @@
+{
+    "bundles": {
+        "Enqueue\\Bundle\\EnqueueBundle": ["all"]
+    },
+    "copy-from-recipe": {
+        "etc/": "%ETC_DIR%/"
+    }
+}
diff --git a/enqueue/enqueue-bundle/0.3/post_install.txt b/enqueue/enqueue-bundle/0.3/post_install.txt
new file mode 100644
index 000000000..60050235e
--- /dev/null
+++ b/enqueue/enqueue-bundle/0.3/post_install.txt
@@ -0,0 +1 @@
+[Enqueue] Run <comment>make consume</> command to consume messages
\ No newline at end of file
diff --git a/enqueue/fs/0.3/etc/packages/enqueue_fs.yaml b/enqueue/fs/0.3/etc/packages/enqueue_fs.yaml
new file mode 100644
index 000000000..c9a29915a
--- /dev/null
+++ b/enqueue/fs/0.3/etc/packages/enqueue_fs.yaml
@@ -0,0 +1,5 @@
+enqueue:
+    transport:
+        default: 'fs'
+        fs:
+            store_dir: '%env(ENQUEUE_FS_STORAGE)%'
diff --git a/enqueue/fs/0.3/manifest.json b/enqueue/fs/0.3/manifest.json
new file mode 100644
index 000000000..6b1a5c76b
--- /dev/null
+++ b/enqueue/fs/0.3/manifest.json
@@ -0,0 +1,12 @@
+{
+    "copy-from-recipe": {
+        "etc/": "%ETC_DIR%/",
+        "var/": "%VAR_DIR%"
+    },
+    "env": {
+        "ENQUEUE_FS_STORAGE": "%VAR%/queue"
+    },
+    "gitignore": [
+        "/var/queue"
+    ]
+}
diff --git a/enqueue/fs/0.3/var/queue/.gitkeep b/enqueue/fs/0.3/var/queue/.gitkeep
new file mode 100644
index 000000000..e69de29bb