Skip to content

Commit f8495e6

Browse files
[skip ci]
[skip ci]
1 parent ed10ad7 commit f8495e6

File tree

1 file changed

+8
-0
lines changed

1 file changed

+8
-0
lines changed

src/producer.js

Lines changed: 8 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -26,7 +26,15 @@ 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))
35+
2936
const payload = JSON.parse(message.payload)
37+
3038
payloadcopy = message
3139
const validTopicAndOriginator = (pgOptions.triggerTopics.includes(payload.topic)) && (pgOptions.triggerOriginators.includes(payload.originator)) // Check if valid topic and originator
3240
if (validTopicAndOriginator) {

0 commit comments

Comments
 (0)