Microservices

1import { createApp, MicroserviceOptions, Transport } from "canxjs";
2
3async function bootstrap() {
4  const app = createApp();
5
6  // Connect Microservice strategy
7  app.connectMicroservice<MicroserviceOptions>({
8    transport: Transport.TCP,
9    options: {
10      host: 'localhost',
11      port: 3001
12    }
13  });
14
15  await app.startAllMicroservices();
16}

1import { Controller } from "canxjs";
2import { MessageHandler, EventHandler } from "canxjs/microservices";
3
4@Controller()
5export class MathController {
6
7  // Request-Response pattern
8  @MessageHandler({ cmd: 'sum' })
9  accumulate(data: number[]): number {
10    return (data || []).reduce((a, b) => a + b);
11  }
12
13  // Event pattern (Fire and forget)
14  @EventHandler('user_created')
15  handleUserCreated(data: Record<string, unknown>) {
16    console.log('User created event received', data);
17  }
18}

1import { ClientProxy, ClientProxyFactory, Transport } from "canxjs/microservices";
2
3export class UserService {
4  private client: ClientProxy;
5
6  constructor() {
7    this.client = ClientProxyFactory.create({
8      transport: Transport.TCP,
9      options: { port: 3001 }
10    });
11  }
12
13  getSum(numbers: number[]) {
14    return this.client.send({ cmd: 'sum' }, numbers);
15  }
16}