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 6c778f4 commit 99f24ddCopy full SHA for 99f24dd
lib/actions/splitOnJsonata.js
@@ -6,7 +6,6 @@ const { messages } = require('elasticio-node');
6
* @this processAction
7
*/
8
async function processAction(msg, cfg) {
9
- const self = this;
10
const split = JsonataTransform.jsonataTransform(msg, cfg);
11
12
if (!Array.isArray(split)) {
@@ -21,7 +20,7 @@ async function processAction(msg, cfg) {
21
20
22
const results = [];
23
split.forEach((elem) => results.push(elem));
24
- self.logger.debug('%s parts to emit found', results.length);
+ this.logger.debug('%s parts to emit found', results.length);
25
results.forEach(async (result) => {
26
if (result) {
27
await this.emit('data', messages.newMessageWithBody(result));
0 commit comments