The Babex allows you to make a chain of microservices on the fly with the help of RabbitMQ, Kafka, etc.
For example, we create service which will add the number to counter. We will use the Kafka adapter.
package mainimport ("github.com/babex-group/babex""github.com/babex-group/babex-kafka""log""os""os/signal""encoding/json")funcmain() {a,err:=kafka.NewAdapter(kafka.Options{Name:"babex-sandbox"Topics: []string{"example-topic"},Addrs: []string{"localhost:29092"},})iferr!=nil {log.Fatal(err)}s:=babex.NewService(a)defers.Close()s.Handler("example-topic","",func(msg*babex.Message)error {vardatastruct{Countint`json:"count"`}iferr:=json.Unmarshal(msg.Data,&data);err!=nil {msg.Ack()// The message has invalid format, skip it.returnerr}data.Count+=1fmt.Printf("count = %v\r\n",data.Count)returns.Next(msg,data,nil)// Next automatically use msg.Ack()})signals:=make(chan os.Signal,1)signal.Notify(signals,os.Interrupt)<-signals}And publish the message to the topic "babex-sandbox":
{"data": {"count":0 },"chain": [ {"exchange":"example-topic" } ]}Check logs:
Excellent! Let's change the message:
{"data": {"count":0 },"chain": [ {"exchange":"example-topic" }, {"exchange":"example-topic" } ]}Check logs:
The service receive two message via chain, and increment the count.
