diff --git a/lib/4nk/MessageBus.ts b/lib/4nk/MessageBus.ts index cee397e..4761d49 100644 --- a/lib/4nk/MessageBus.ts +++ b/lib/4nk/MessageBus.ts @@ -199,11 +199,10 @@ export default class MessageBus { const accessToken = userStore.getAccessToken()!; const correlationId = uuidv4(); - console.log(correlationId); this.initMessageListener(correlationId); const unsubscribe = EventBus.getInstance().on('PROCESSES_RETRIEVED', (responseId: string, processes: any) => { - console.log(responseId); + console.log('MessageBus - PROCESSES_RETRIEVED', processes); if (responseId !== correlationId) { return; } @@ -452,7 +451,7 @@ export default class MessageBus { this.initMessageListener(correlationId); const unsubscribe = EventBus.getInstance().on('PROCESS_UPDATED', (responseId: string, updatedProcess: any) => { - console.log('PROCESS_UPDATED', updatedProcess); + console.log('MessageBus - PROCESS_UPDATED', updatedProcess); if (responseId !== correlationId) { return; } @@ -530,7 +529,7 @@ export default class MessageBus { this.initMessageListener(correlationId); const unsubscribe = EventBus.getInstance().on('STATE_VALIDATED', (responseId: string, updatedProcess: any) => { - console.log(updatedProcess); + console.log('MessageBus - STATE_VALIDATED', updatedProcess); if (responseId !== correlationId) { return; } @@ -727,7 +726,6 @@ export default class MessageBus { EventBus.getInstance().emit('ERROR_PROCESS_UPDATED', correlationId, error); return; } - console.log('PROCESS_UPDATED', message); EventBus.getInstance().emit('MESSAGE_RECEIVED', message); EventBus.getInstance().emit('PROCESS_UPDATED', correlationId, message.updatedProcess); break;