saudeid-kafka v0.5.0

gestao-saude-broker-wrapper

Como usar:

• Defina as envs para conexão do broker;
• Importe o broker ou brokerConsumer e use o método desejado;

Métodos disponíveis (broker):

• send(eventName: string, payload: any): void | Envia um payload para o broker;
• listen(events: <T extends IService>[]): void | Passe uma lista dos eventos que deseja ouvir e uma função de callback para cada um, mantém uma conexão com o broker.