Babex

The Babex allows you to make a chain of microservices on the fly with the help of RabbitMQ, Kafka, etc.

Docs

• About the Babex
• Receiving messages
• Middleware
• Examples

Adapters

• Kafka
• Rabbit

Usage

For example, we create service which will add the number to counter. We will use the Kafka adapter.

package main

import (
	"github.com/babex-group/babex"
	"github.com/babex-group/babex-kafka"
	"log"
	"os"
	"os/signal"
	"encoding/json"
)

func main() {
	a, err := kafka.NewAdapter(kafka.Options{
		Name:   "babex-sandbox"
		Topics: []string{"example-topic"},
		Addrs:  []string{"localhost:29092"},
	})
	if err != nil {
		log.Fatal(err)
	}

	s := babex.NewService(a)

	defer s.Close()

	s.Handler("example-topic", "", func(msg *babex.Message) error {
		var data struct{
			Count int `json:"count"`
		}

		if err := json.Unmarshal(msg.Data, &data); err != nil {
			msg.Ack() // The message has invalid format, skip it.
			return err
		}

		data.Count += 1

		fmt.Printf("count = %v\r\n", data.Count)

		return s.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:

$ count = 1

Excellent! Let's change the message:

{
  "data": {
    "count": 0
  },
  "chain": [
    {
      "exchange": "example-topic"
    },
    {
      "exchange": "example-topic"
    }
  ]
}

Check logs:

$ count = 1
$ count = 2

The service receive two message via chain, and increment the count.