RabbitMQ client to put message into queue.
package main
func main() {
err := golem.InitPublisher(
"golemClientTest",
&golem.Params{
User: "rabbit",
Password: "password",
Host: "localhost",
Port: 5672,
},
&golem.Exchange{
Name: "golemClientTest",
Kind: golem.KindFanout,
AutoDelete: true,
},
)
if err != nil {
log.Fatalln(err)
}
}
golem.Info("test info message", 100)
golem.Error("test error message", 409)
golem.Fatal("test fatal message")
defer golem.Recover()