Ph5

integrationWorker.py

@@ -66,6 +66,11 @@ PROCESSING_MODULES = {
         INTEGRATION_MODULE_DIR + "/data_xml/processing-module-archive.sh",
         INTEGRATION_MODULE_DIR + "/data_xml/processing-module-inventory.sh",
     ],
+    "seismic_data_ph5": [
+        INTEGRATION_MODULE_DIR + "/data_ph5/0-check-format.sh",
+        INTEGRATION_MODULE_DIR + "/data_ph5/1-inventory.sh",
+    ],
+
     "metadata_stationxml": [
         INTEGRATION_MODULE_DIR
         + "/metadata_xml/0-processing-module-one-file-only.bash",
@@ -126,13 +131,13 @@ if __name__ == "__main__":
 
             # wait for next message
             logging.info("waiting for incoming message")
-            message = receiver.receive(timeout=None).body.decode('utf-8')
+            message = receiver.receive(timeout=None).body
 
             # from now on, the message has been acknowledged, and should not be lost by code failure.
             # if it happens anyway, this is a helper to manual-send the message again :
             logging.info("message acknowledged : '%s'" % message)
             logging.info(
-                "transaction may be executed again with : cli-proton-python-sender --broker-url \"%s/%s\" --msg-content \"b'%s'\" --log-msgs body"
+                "transaction may be executed again with : cli-proton-python-sender --broker-url \"%s/%s\" --msg-content \"%s\" --log-msgs body"
                 % (AMQP_SERVER, QUEUE, message)
             )