Implementation is probably straight-forward of the project that aim to follow chain-of-responsiblity and functional options for friendly APIs pattern to solve the complexity and make abstraction layer to a user that use the this library.
- Middlewares for exchange, queue and queue bind.
- Functional options for producer publishing the message.
- Re-establish connection and channel to Publisher and Consumer.
- Consumer retry queue middleware.
- Consumer retry queue middleware with backoff config.
- Closed connection and channel gracefully.
import (
"log"
rabbitmq "github.com/iamgoangle/go-rabbitmq/pkg/rabbitmq"
middlewares "github.com/iamgoangle/go-rabbitmq/pkg/rabbitmq/middlewares"
)
func main() {
conf := rabbitmq.Config{
Host: "localhost",
Port: 5672,
Username: "admin",
Password: "1234",
Vhost: "/",
}
connection, err := rabbitmq.NewAMQPConnection(conf)
if err != nil {
log.Panic(err)
}
connection.Use(middlewares.ExchangeDeclare("exchange_test", middlewares.ExchangeDirect, nil))
connection.Use(middlewares.QueueDeclare("test", nil))
connection.Use(middlewares.QueueBind("test", "", "exchange_test", false, nil))
if err := connection.Run(); err != nil {
log.Panic(err)
}
producer := rabbitmq.NewProducer("exchange_test", "", "", connection)
err = producer.Publish([]byte(`{"Name":"Alice","Body":"Hello","Time":1294706395881547000}`))
if err != nil {
log.Println("unable to publish body")
}
}import (
"fmt"
"log"
rabbitmq "github.com/iamgoangle/go-rabbitmq/pkg/rabbitmq"
middlewares "github.com/iamgoangle/go-rabbitmq/pkg/rabbitmq/middlewares"
)
type handler struct {
}
func main() {
conf := rabbitmq.Config{
Host: "localhost",
Port: 5672,
Username: "admin",
Password: "1234",
Vhost: "/",
}
connection, err := rabbitmq.NewAMQPConnection(conf)
if err != nil {
log.Panic(err)
}
connection.Use(middlewares.ExchangeDeclare("exchange_test", middlewares.ExchangeDirect, nil))
connection.Use(middlewares.QueueDeclare("test", nil))
connection.Use(middlewares.QueueBind("test", "", "exchange_test", false, nil))
if err := connection.Run(); err != nil {
log.Panic(err)
}
consumer := rabbitmq.NewConsumer("test", "consumer_name", connection)
consumer.Use(newConsumerHandler())
if err := consumer.Consume(); err != nil {
log.Panic(err)
}
}
func newConsumerHandler() rabbitmq.ConsumerHandler {
return &handler{}
}
func (h *handler) Do(msg []byte) error {
fmt.Println(string(msg))
return nil
}
React
Typescript
Django
Laravel
Facebook
Microsoft
Google
Alibaba
D3
Tencent