ActivityEventListenerController.js

({
	doInit : function(component, event, helper) {
        //get the platform event channel
       var channel = '/event/Activity_Event__e';
       
        const replayId = -1;
        //get the empAPI component
        const empApi = component.find("empApi");
        
        //A callback function that's invoked for every event received
        const callback = function (message) {
            var result = message.data.payload;
            console.log('msg = '+JSON.stringify(result));
            console.log('Activity_Record_ID__c : ' +result.Activity_Record_ID__c );
            console.log('What_ID__c : ' +result.What_ID__c );
            console.log('Who_ID__c : ' +result.Who_ID__c );
            
			 if(result.What_ID__c == component.get("v.recordId") || result.Who_ID__c == cmp.get("v.recordId"))
             {
                 helper.navigateToActivityRecord(component,event,helper,result.Activity_Record_ID__c);
             }			
        };
        // Subscribe to the channel and save the returned subscription object.
        empApi.subscribe(channel, replayId, callback).then(function(newSubscription) {
            //console.log("Subscribed to channel" + channel);
        });
        const errorHandler = function (message) {
            console.error("Received error ", JSON.stringify(message));
        };
        //A callback function that's called when an error response is received from the server for the handshake, connect, subscribe, and unsubscribe meta channels.
        empApi.onError(errorHandler);     
	}
})