Skip to content

Commit 9b2ff12

Browse files
author
sachin-maheshwari
authored
Merge pull request #8 from topcoder-platform/feature/version-support
supporting new bus event format.
2 parents c2c571f + f4c28ad commit 9b2ff12

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

src/app.js

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -51,7 +51,8 @@ function configureKafkaConsumer(handlers) {
5151
return null;
5252
}
5353
let emailModel = {};
54-
const messageJSON = JSON.parse(message);
54+
const busPayload = JSON.parse(message);
55+
const messageJSON = busPayload.payload;
5556
const handlerAsync = Promise.promisify(handler);
5657
// use handler to create notification instances for each recipient
5758
return models.Email.create(

0 commit comments

Comments
 (0)