Send message in RabbitMQ via amqp v.1+

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?

This topic was automatically closed 90 days after the last reply. New replies are no longer allowed.