in application-workloads/pubnub/pubnub-eventhub-bridge/App_Data/jobs/continuous/pnwebjob/PNSubscribeToEH1EH2ToPNPublish.js [50:93]
var PNPublish = function (ehEvent) {
// console.log('Event Received from Egress EH, Publishing to PN: ');
// console.log(JSON.stringify(ehEvent.body));
// console.log("");
if (Array.isArray(ehEvent.body)){
ehEvent.body.forEach(function(element){
pubnub.publish({
channel: PNPubChannel,
message: element
},
function(status, response) {
if (status.error) {
console.log("PN Array Element Publish Error: ", status);
console.log("Message causing error: ", element);
}
else {
console.log("message published with server response: ", response);
console.log("Message published successfully: ", element);
}
});
});
} else {
console.log("No array detected.");
pubnub.publish({
channel: PNPubChannel,
message: ehEvent.body
},
function(status, response) {
if (status.error) {
console.log("PN Array Element Publish Error: ", status);
console.log("Message causing error: ", ehEvent.body);
}
else {
console.log("message published with server response: ", response);
console.log("Message published successfully: ", ehEvent.body);
}
});
}
};