Now using configurable topic

Author: zubairov

README.md

@@ -40,7 +40,6 @@ infrastructure, it expects following environment variables to be present when st
 * ``ELASTICIO_AMQP_URI`` something like ``amqp://foo:bar@server``
 * ``ELASTICIO_MESSAGE_CRYPTO_IV`` vector for symmetric encryption
 * ``ELASTICIO_MESSAGE_CRYPTO_PASSWORD`` password for symmetric encryption
-* ``ELASTICIO_TASK_ID`` ID of the currently running task, used to construct name for exchange
 * ``ELASTICIO_USER_ID`` ID of the current user, used to construct name of the exchange
 
 

component.json

@@ -15,6 +15,14 @@
     "publish": {
       "title": "Publish",
       "main": "./lib/actions/publish.js",
+      "fields": {
+        "topic": {
+          "label": "Exchange",
+          "viewClass": "TextFieldView",
+          "required": true,
+          "placeholder": "up_to_200_symbols"
+        }
+      },
       "metadata": {
       }
     }

lib/actions/publish.js

@@ -16,7 +16,7 @@ module.exports.process = processAction;
 function processAction(msg, cfg) {
   console.log('Action started');
   const amqpURI = cfg.amqpURI;
-  const amqpExchange = `pubsub_${process.env.ELASTICIO_TASK_ID}_${process.env.ELASTICIO_USER_ID}`;
+  const amqpExchange = `pubsub_${process.env.ELASTICIO_USER_ID}_${cfg.topc}`;
   co(function*() {
     if (!conn) {
       console.log('Connecting to amqpURI=%s', amqpURI);