Axón

Permite a la neurona conectarse con NATS y establecer comunicación con otras neuronas. Facilita la transmisión de mensajes y datos entre neuronas

Onbbu Axon es el componente encargado de permitir la conexión entre una neurona (que representa un microservicio en Onbbu) y otras neuronas. Actúa como el punto de comunicación que se integra con NATS, un sistema de mensajería distribuido, para manejar las conexiones y la comunicación en tiempo real entre los diferentes servicios.

A través de Axon, las neuronas pueden intercambiar datos y coordinar sus acciones, facilitando la interoperabilidad y el flujo eficiente de información dentro de una arquitectura de microservicios

// Install
npm i onbbu-axon
pnpm i onbbu-axon
yarn add onbbu-axon

Funciones

Establecer conexiones con el broker NATS

Enviar y recibir mensajes

Manejar la comunicación con otras neuronas

Implementación y uso

Su implementación consta de instanciar la clase Axon a esta es posible adherir nuevos mensajes al sistema nervioso (Message Brocker NATS)

const axon: Axon = new Axon("demo")

axon.close()

Método Add

Envía un objeto de datos a un endpoint específico dentro de una neurona y espera la respuesta procesada

axon.add({}, "method")

Método Add Async

Envía un objeto de datos a un endpoint sin esperar una respuesta, permitiendo continuar con otras tareas sin bloqueo

axon.addAsync({}, "method")

Ejemplo

sdfsdfdf

class PresynapticImpl {
  private name: string
  private instance: Presynaptic

  constructor(name: string) {

    this.name = name

    this.instance = new Presynaptic(this.name)
  }

  async create(payload: ICreate) {

    await this.instance.sendSignal(payload, "create");
  }

  async update(payload: IUpdate) {

    return await this.instance.sendSignal(payload, "update");
  }
}