Hey!
There is rabbitMQ, it has the ability to configure not only queues, but also exchanges. Everything works well on his amqp protocol version 0.9 (streadway/amqp)
For this, we have a special method channel.ExchangeDeclare()
But now I need use amqp version 1.0+ (Azure/go-amqp)
Also, I need to use cloud-events. For this I use this library: github.com/cloudevents/sdk-go
But I can’t find how to send and receive messages not just in rabbit queue when we set protocol, but send and receive it in rabbit exchanges.
I use this example:
Can someone please help to understand how to do that? How to set exchanges?