Skip to content

Commit 51da3ad

Browse files
committed
Now publishing payload in publish action
1 parent 9cc11ab commit 51da3ad

File tree

1 file changed

+1
-2
lines changed

1 file changed

+1
-2
lines changed

lib/actions/publish.js

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -30,8 +30,7 @@ function processAction(msg, cfg) {
3030
}
3131
console.log('Publishing message id=%s', msg.id);
3232
let encryptedData = encryptor.encryptMessageContent({
33-
id: msg.id,
34-
body: msg.body,
33+
body: msg.body.payload || msg.body,
3534
attachments: msg.attachments
3635
});
3736
channel.publish(amqpExchange, 'foo', encryptedData, {

0 commit comments

Comments
 (0)