I am subscribing external socket to get data from socket api and then I am publishing to redis somewhat like below. I am getting maximum event emitter listeners exceeded error for redis.on.I can't move redis on outside the socket in that way I won't be able to send to the socket the required data to subscribe the data. How to solve this issue ? .Can I remove the redis listneer inside the on event?
const socketConnect=()=>{
// Singleton Method To Avoid Multiple Socket Connections
var SingletonSocket = (function () {
var instance;
function createInstance() {
var object = new WebSocket('url');
return object;
}
return {
getInstance: function () {
if (! instance) {
instance = createInstance();
}
return instance;
}
};
})();
/**
* Can Subscribe rto multiple channels
*/
// here the redis subscriber givee us message that a new centralid has been added
const ws = SingletonSocket.getInstance();
const key = 'centralidslist';
const unsubscribechannel="matchunsubscribe";
const channel = "eventchannel"
ws.on('open', async function open() {
log.debug({
level: 'info',
message:"Socket Opened Odd",
timstamp:momenttz().tz("Asia/Kolkata").format("YYYY-MM-DD HH:mm:ss")
});
redis.subscribe(channel, unsubscribechannel,async (error, count) => {
if (error) {
throw new Error(error);
}
log.debug(`Subscribed to ${channel} channel. Listening for updates on the ${channel} channel.`);
await data.publish(channel,"Publishing First Time"); // publishing the event to the channel so that socket subscription can be started
});
redis.on('message', async (channel, message) => {
/// How to remove listener once the message is recieved and done processing
if(channel==unsubscribechannel)
{
ws.send();
redis.removeListners(); // is it a good practice to do it here ?
}
else{
ws.send();
}
});
});
ws.on('error', function(error) {
log.debug({
level: 'info',
message:"Socket Error Unable To Connect To URl"+error,
timstamp:momenttz().tz("Asia/Kolkata").format("YYYY-MM-DD HH:mm:ss")
});
});
ws.on('close', function close() {
log.debug({
level: 'info',
message:"Socket Closed",
timstamp:momenttz().tz("Asia/Kolkata").format("YYYY-MM-DD HH:mm:ss")
});
setTimeout(()=>{
console.log("Trying to Reconnect");
log.debug({
level: 'info',
message:"Trying To Reconnect To Socket",
timstamp:momenttz().tz("Asia/Kolkata").format("YYYY-MM-DD HH:mm:ss")
});
socketConnect()}, 5000)
});
ws.on('message', async function incoming(message) {
});
}
socketConnect();