Skip to content

Commit 765d51d

Browse files
Update producer.js
1 parent ccfe373 commit 765d51d

File tree

1 file changed

+6
-0
lines changed

1 file changed

+6
-0
lines changed

src/producer.js

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -26,6 +26,12 @@ try {
2626
pgClient.on('notification', async (message) => {
2727
try {
2828
payloadcopy = ""
29+
logger.debug('Entering producer 1')
30+
logger.debug(message.toString())
31+
logger.debug('Entering producer 2')
32+
logger.debug(message)
33+
logger.debug('Entering producer 3')
34+
logger.debug(JSON.stringify(message.payload))
2935
const payload = JSON.parse(message.payload)
3036
payloadcopy = message
3137
const validTopicAndOriginator = (pgOptions.triggerTopics.includes(payload.topic)) && (pgOptions.triggerOriginators.includes(payload.originator)) // Check if valid topic and originator

0 commit comments

Comments
 (0)