我需要在 rabbitMQ 代理中发送消息,但是使用基于 azure-amqp 协议的 cloudevents sdk-go 库。我知道如何使用 stradway-amqp 设置交换,但我需要使用新版本的 amqp (1+)。对于这种情况,我需要使用 cloudevents sdk-go 库。我发现,当我们创建一个新协议时,我们设置了地址和节点。Node - 是代理中的消息队列。但我希望新协议创建一个交换,而不是一个队列。我怎么能这样做?我可以这样做吗?)
我需要在 rabbitMQ 代理中发送消息,但是使用基于 azure-amqp 协议的 cloudevents sdk-go 库。我知道如何使用 stradway-amqp 设置交换,但我需要使用新版本的 amqp (1+)。对于这种情况,我需要使用 cloudevents sdk-go 库。我发现,当我们创建一个新协议时,我们设置了地址和节点。Node - 是代理中的消息队列。但我希望新协议创建一个交换,而不是一个队列。我怎么能这样做?我可以这样做吗?)