opts := []rmq.Options{
rmq.Url("amqp://guest:guest@localhost:5672"),
rmq.Durable(false),
rmq.AutoAck(true),
rmq.Exclusive(false),
rmq.NoLocal(false),
rmq.NoWait(false),
rmq.Args(nil),
rmq.Name("hello"),
}
rbt, err := rmq.NewService(opts...)
utils.FailOnError(err, "Failed to connect to RabbitMQ")
defer rbt.Close()
q, err := rbt.QueueDeclare("hello", false, false, false, false, nil)
utils.FailOnError(err, "Failed to declare queue")
err := rbt.Publish("exchange","subject", []byte("Hello World!"))
utils.FailOnError(err, "Failed to publish message")
More examples can be found at examples.
We use SemVer for versioning. You can see the versions available by checking the tags on this repository.
For more details about our license model, please take a look at the LICENSE file
2022, thiagozs