metwork-framework · thebaptiste · Oct 15, 2024
diff --git a/...es/plugins/amqplistener/cookiecutter.json → ...plugins/amqp09_listener/cookiecutter.json b/...es/plugins/amqplistener/cookiecutter.json → ...plugins/amqp09_listener/cookiecutter.json
diff --git a/adm/templates/plugins/amqplistener/hooks → adm/templates/plugins/amqp09_listener/hooks b/adm/templates/plugins/amqplistener/hooks → adm/templates/plugins/amqp09_listener/hooks
diff --git a/...cookiecutter.name}}/.autorestart_excludes → ...cookiecutter.name}}/.autorestart_excludes b/...cookiecutter.name}}/.autorestart_excludes → ...cookiecutter.name}}/.autorestart_excludes
diff --git a/...cookiecutter.name}}/.autorestart_includes → ...cookiecutter.name}}/.autorestart_includes b/...cookiecutter.name}}/.autorestart_includes → ...cookiecutter.name}}/.autorestart_includes
diff --git a/...listener/{{cookiecutter.name}}/.gitignore → ...listener/{{cookiecutter.name}}/.gitignore b/...listener/{{cookiecutter.name}}/.gitignore → ...listener/{{cookiecutter.name}}/.gitignore
diff --git a/...okiecutter.name}}/.layerapi2_dependencies → ...okiecutter.name}}/.layerapi2_dependencies b/...okiecutter.name}}/.layerapi2_dependencies → ...okiecutter.name}}/.layerapi2_dependencies
diff --git a/...er/{{cookiecutter.name}}/.layerapi2_label → ...er/{{cookiecutter.name}}/.layerapi2_label b/...er/{{cookiecutter.name}}/.layerapi2_label → ...er/{{cookiecutter.name}}/.layerapi2_label
diff --git a/...ookiecutter.name}}/.plugin_format_version → ...ookiecutter.name}}/.plugin_format_version b/...ookiecutter.name}}/.plugin_format_version → ...ookiecutter.name}}/.plugin_format_version
diff --git a/...ener/{{cookiecutter.name}}/.releaseignore → ...ener/{{cookiecutter.name}}/.releaseignore b/...ener/{{cookiecutter.name}}/.releaseignore → ...ener/{{cookiecutter.name}}/.releaseignore
diff --git a/...qplistener/{{cookiecutter.name}}/Makefile → ...9_listener/{{cookiecutter.name}}/Makefile b/...qplistener/{{cookiecutter.name}}/Makefile → ...9_listener/{{cookiecutter.name}}/Makefile
diff --git a/...{cookiecutter.name}}/bin/amqp_listener.py → ...{cookiecutter.name}}/bin/amqp_listener.py b/...{cookiecutter.name}}/bin/amqp_listener.py → ...{cookiecutter.name}}/bin/amqp_listener.py
diff --git a/...listener/{{cookiecutter.name}}/config.ini → ...listener/{{cookiecutter.name}}/config.ini b/...listener/{{cookiecutter.name}}/config.ini → ...listener/{{cookiecutter.name}}/config.ini
diff --git a/...mqplistener/{{cookiecutter.name}}/crontab → ...09_listener/{{cookiecutter.name}}/crontab b/...mqplistener/{{cookiecutter.name}}/crontab → ...09_listener/{{cookiecutter.name}}/crontab
diff --git a/...ns/amqp09_listener/{{cookiecutter.name}}/python3_virtualenv_sources/allow_binary_packages b/...ns/amqp09_listener/{{cookiecutter.name}}/python3_virtualenv_sources/allow_binary_packages
diff --git a/...qp09_listener/{{cookiecutter.name}}/python3_virtualenv_sources/requirements-to-freeze.txt b/...qp09_listener/{{cookiecutter.name}}/python3_virtualenv_sources/requirements-to-freeze.txt
@@ -0,0 +1 @@
+pika
diff --git a/adm/templates/plugins/amqp10_listener/cookiecutter.json b/adm/templates/plugins/amqp10_listener/cookiecutter.json
@@ -0,0 +1,9 @@
+{
+    "version": "{% raw %}{{MFMODULE_VERSION}}{% endraw %}",
+    "release": "1",
+    "one_line_summary": "one line summary about your plugin",
+    "license": ["Proprietary", "BSD", "MIT", "GPL", "Specific"],
+    "url": "http://yourpluginhomepage",
+    "maintainer": "Firstname FAMILYNAME <email>",
+    "vendor": "MetWork"
+}
diff --git a/adm/templates/plugins/amqp10_listener/hooks b/adm/templates/plugins/amqp10_listener/hooks
@@ -0,0 +1 @@
+../_common/hooks/
diff --git a/adm/templates/plugins/amqp10_listener/{{cookiecutter.name}}/.autorestart_excludes b/adm/templates/plugins/amqp10_listener/{{cookiecutter.name}}/.autorestart_excludes
@@ -0,0 +1 @@
+../../_common/autorestart_excludes
diff --git a/adm/templates/plugins/amqp10_listener/{{cookiecutter.name}}/.autorestart_includes b/adm/templates/plugins/amqp10_listener/{{cookiecutter.name}}/.autorestart_includes
@@ -0,0 +1 @@
+../../_common/autorestart_includes
diff --git a/adm/templates/plugins/amqp10_listener/{{cookiecutter.name}}/.gitignore b/adm/templates/plugins/amqp10_listener/{{cookiecutter.name}}/.gitignore
@@ -0,0 +1 @@
+../../_common/.gitignore
diff --git a/adm/templates/plugins/amqp10_listener/{{cookiecutter.name}}/.layerapi2_dependencies b/adm/templates/plugins/amqp10_listener/{{cookiecutter.name}}/.layerapi2_dependencies
@@ -0,0 +1 @@
+../../_common/python3_layerapi2_dependencies
diff --git a/adm/templates/plugins/amqp10_listener/{{cookiecutter.name}}/.layerapi2_label b/adm/templates/plugins/amqp10_listener/{{cookiecutter.name}}/.layerapi2_label
@@ -0,0 +1 @@
+../../_common/layerapi2_label
diff --git a/adm/templates/plugins/amqp10_listener/{{cookiecutter.name}}/.plugin_format_version b/adm/templates/plugins/amqp10_listener/{{cookiecutter.name}}/.plugin_format_version
@@ -0,0 +1 @@
+../../_common/.plugin_format_version
diff --git a/adm/templates/plugins/amqp10_listener/{{cookiecutter.name}}/.releaseignore b/adm/templates/plugins/amqp10_listener/{{cookiecutter.name}}/.releaseignore
@@ -0,0 +1 @@
+../../_common/.releaseignore
diff --git a/adm/templates/plugins/amqp10_listener/{{cookiecutter.name}}/Makefile b/adm/templates/plugins/amqp10_listener/{{cookiecutter.name}}/Makefile
@@ -0,0 +1 @@
+../../_common/Makefile
diff --git a/adm/templates/plugins/amqp10_listener/{{cookiecutter.name}}/bin/amqp10_listener.py b/adm/templates/plugins/amqp10_listener/{{cookiecutter.name}}/bin/amqp10_listener.py
@@ -0,0 +1,25 @@
+#!/usr/bin/env python3
+
+import time
+import sys
+import proton
+import xattrfile
+import signal
+import os
+from acquisition.listener import AcquisitionListener
+
+
+# To be written !
+
+class Ampq10Listener(AcquisitionListener):
+
+    def listen(self):
+        self.info("Listening...")
+        while True:
+            time.sleep(1)
+
+
+if __name__ == "__main__":
+    x = Listener()
+    x.run()
+
diff --git a/adm/templates/plugins/amqp10_listener/{{cookiecutter.name}}/config.ini b/adm/templates/plugins/amqp10_listener/{{cookiecutter.name}}/config.ini
@@ -0,0 +1,17 @@
+{% extends "_common/config.ini" %}
+
+{% block step %}
+{% endblock %}
+{% block switch %}
+{% endblock %}
+
+{% block extra_daemons %}
+[extra_daemon_amqp10listener]
+_cmd_and_args = amqp10_listener.py --step-name=main
+numprocesses=1
+{% endblock %}
+
+{% block custom %}
+# To be written
+{% endblock %}
+
diff --git a/adm/templates/plugins/amqp10_listener/{{cookiecutter.name}}/crontab b/adm/templates/plugins/amqp10_listener/{{cookiecutter.name}}/crontab
@@ -0,0 +1 @@
+../../_common/crontab
diff --git a/...ns/amqp10_listener/{{cookiecutter.name}}/python3_virtualenv_sources/allow_binary_packages b/...ns/amqp10_listener/{{cookiecutter.name}}/python3_virtualenv_sources/allow_binary_packages
diff --git a/...qp10_listener/{{cookiecutter.name}}/python3_virtualenv_sources/requirements-to-freeze.txt b/...qp10_listener/{{cookiecutter.name}}/python3_virtualenv_sources/requirements-to-freeze.txt
@@ -0,0 +1 @@
+python-qpid-proton
diff --git a/adm/templates/plugins/amqplistener/{{cookiecutter.name}}/python3_virtualenv_sources b/adm/templates/plugins/amqplistener/{{cookiecutter.name}}/python3_virtualenv_sources