Rocket.Chat/apps/meteor/server/startup/localServices.ts

import { api, LocalBroker } from '@rocket.chat/core-services';

import { StreamerCentral } from '../modules/streamer/streamer.module';

const broker = new LocalBroker();

broker.onBroadcast((eventName: string, args: unknown[]) => {
	StreamerCentral.emit('broadcast', 'local', 'broadcast', [{ eventName, args }]);
});

api.setBroker(broker);
void api.start();