emitter.on('connection', function connection(ws: any) {
    // Create a proxy for this client
    const proxy = new NgEmitter.Proxy();

    // Add the local service exposed to this client and grant it all right
    proxy.addLocalService('heartBeatService', heartBeatEmitter, {
        listen: true,
        emit: true,
        ack: true,
    });

    // message received: just hook to proxy.receive()
    ws.on('message', function incoming(message: any) {
        proxy.receive(message);
    });

    // Define the receive method: should call proxy.push()
    // after decoding the raw message
    proxy.receive = function receive(raw: any) {
        try {
            proxy.push(JSON.parse(raw));
        } catch (error) {}
    };

    // Define the send method
    proxy.send = function send(message: any) {
        ws.send(JSON.stringify(message));
    };

    // Clean up after everything is done
    ws.on('close', function close() {
        proxy.destroy();
    });
});

ws.on('open', function open() {
    // Add the remote service we want to access
    proxy.addRemoteService('heartBeatService');

    // Listen to the event 'heartBeat' on this service
    proxy.remoteServices.heartBeatService.on('heartBeat', (beat: any) => {});
});

ws.on('close', function close() {
    proxy.destroy();
});

proxy.receive = function receive(raw: any) {
    try {
        proxy.push(JSON.parse(raw));
    } catch (error) {}
};

ws.on('message', (message: any) => {
    proxy.receive(message);
});

 ws.on('message', function incoming(message: any) {
     proxy.receive(message);
 });