File tree Expand file tree Collapse file tree 1 file changed +2
-2
lines changed Expand file tree Collapse file tree 1 file changed +2
-2
lines changed Original file line number Diff line number Diff line change @@ -20,11 +20,11 @@ function processAction(msg, cfg) {
20
20
const queueName = `eio_consumer_${ process . env . ELASTICIO_TASK_ID } _${ process . env . ELASTICIO_USER_ID } ` ;
21
21
const keys = ( cfg . bindingKeys || '#' ) . split ( ',' ) . map ( ( s ) => s . trim ( ) ) ;
22
22
const consumer = ( msg ) => {
23
- console . log ( 'Have got message id=%s fields =%j' , msg . id , msg . fields ) ;
23
+ console . log ( 'Have got message fields=%j properties =%j' , msg . fields , msg . properties ) ;
24
24
const decrypted = encryptor . decryptMessageContent ( msg . content ) ;
25
25
debug ( 'Decrypted message=%j' , decrypted ) ;
26
26
const newMsg = eioUtils . newMessageWithBody ( decrypted . body || { } ) ;
27
- newMsg . id = msg . id ;
27
+ newMsg . id = msg . properties . messageId ;
28
28
newMsg . attachments = decrypted . attachments || { } ;
29
29
this . emit ( 'data' , newMsg ) ;
30
30
} ;
You can’t perform that action at this time.
0 commit comments