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();