AMQP-Messaging

Highly efficient library to communicate with other microservices using RabbitMQ(AMQP Protocol) in Go

Installing

Install via go get:

$ go get github.com/farhadiis/amqp-messaging

Creating messaging variable

import rabbitmq "github.com/farhadiis/amqp-messaging"

messaging := rabbitmq.NewMessaging("RABBITMQ-ADDRESS");
//now you can work with messaging APIs

Work Queues

When you want to push to a queue and go ahead, You’re not waiting for any responses. you can see this example:

err := messaging.AddWorker("mySampleQueue", func(message rabbitmq.Message) (*interface{}, rabbitmq.Acknowledge) {
	log.Printf("Received a message: %s\n", message.Body)
	return nil, rabbitmq.None
})
if err != nil {
	log.Fatal(err)
}

var data interface{} = "foo"
err = messaging.SendPush("mySampleQueue", &data)
if err != nil {
	log.Fatal(err)
}

default QOSPrefetch is set to 1 in options. If you set it more than 1 Rabbitmq will give more than 1 items at once.

Publish/Subscribe

err := messaging.Subscribe("mySampleTopic", func(message rabbitmq.Message) {
	log.Printf("Received a message: %s\n", message.Body)
})
if err != nil {
	log.Fatal(err)
}

var data interface{} = "foo"
err = messaging.Publish("mySampleTopic", &data)
if err != nil {
	log.Fatal(err)
}

RPC

err := messaging.AddWorker("findUser", func(message rabbitmq.Message) (*interface{}, rabbitmq.Acknowledge) {
	var result interface{} = "Farhad"
	return &result, rabbitmq.None
})
if err != nil {
	log.Fatal(err)
}

var data interface{} = "12"
err, result := messaging.RpcCall("findUser", &data)
if err != nil {
	log.Fatal(err)
}
log.Printf("user is %s\n", result)

Finish all jobs and stop all rabbitmq workers

You can stop Gracefully shutdown with command below. It will cancel all Workers.

err := messaging.CancelWorkers()
if err != nil {
	log.Fatal(err)
}

Develop

We’re open for pull requests. in order to run tests just run go test -v

GitHub

View Github