We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent e6c2305 commit 5fb7250Copy full SHA for 5fb7250
lib/triggers/consume.js
@@ -17,7 +17,7 @@ function processAction(msg, cfg) {
17
const amqpURI = cfg.amqpURI;
18
const amqpExchange = cfg.topic;
19
const queueName = `eio_consumer_${process.env.ELASTICIO_TASK_ID}_${process.env.ELASTICIO_USER_ID}`;
20
- const keys = cfg.bindingKeys.split(',').map((s)=>s.trim());
+ const keys = (cfg.bindingKeys || '#').split(',').map((s)=>s.trim());
21
const consumer = (msg) => {
22
console.log('consuming message %s in generator', JSON.stringify(msg.content.toString()));
23
};
0 commit comments