|
@@ -33,7 +33,7 @@ export class MessageAuditorService implements MessageAuditorServiceInterface {
|
|
|
missingMsg.subscribe({
|
|
missingMsg.subscribe({
|
|
|
next: element => {
|
|
next: element => {
|
|
|
msg.next(element)
|
|
msg.next(element)
|
|
|
- console.log(`Audit: Returning missing messages ${element.appData.msgId} ....`)
|
|
|
|
|
|
|
+ console.log(`AuditService: Returning missing messages ${element.appData.msgId} ....`)
|
|
|
}
|
|
}
|
|
|
})
|
|
})
|
|
|
}
|
|
}
|
|
@@ -106,7 +106,7 @@ export class MessageAuditorService implements MessageAuditorServiceInterface {
|
|
|
if (args.arr2.some(obj => obj.appData.msgId === msgElement.appData.msgId)) {
|
|
if (args.arr2.some(obj => obj.appData.msgId === msgElement.appData.msgId)) {
|
|
|
console.log(`Item Found!`)
|
|
console.log(`Item Found!`)
|
|
|
} else {
|
|
} else {
|
|
|
- console.log(`This ${msgElement.appData.msgId} is not found`)
|
|
|
|
|
|
|
+ console.log(`This ${msgElement.appData.msgId} is missing`)
|
|
|
missingMsg.push(msgElement)
|
|
missingMsg.push(msgElement)
|
|
|
resolve(missingMsg)
|
|
resolve(missingMsg)
|
|
|
}
|
|
}
|
