agents-client

Libreria para la implementación del cliente para el consumo de agentes sobre kafka.

import { AgentsClient } from '@coppel/agents-client'

class Demo {
    // Variable para la isntancia del cliente
    private client: AgentsClient;

    constructor() {
        // Instancias la clase para realizar la conexion
        this.client = AgentsClient.connect({ Kafka: ['kafka:9092'] });
    }

    // Ejemplo basado en callback
    public example(): void {
        // Forma de implementacion basada en callback
        this.client.call('AgentName', 'Actions', ['params', 2], (err: any, resp: any) => {
            // Validar si ocurrio un error
        });
    }

    // Ejemplo async
    public async exampleAsync(): Promise<any> {
        const resp: any = await this.client.call('AgentName', 'Actions', ['params', 2]);
    }
}