无法将自定义标头传递给 Ballerina RabbitMQ 发布消息(BasicProperties 中定义的标头除外)

问题描述 投票:0回答:1

我尝试将 Ballerina 编程语言与 RabbitMQ 客户端结合使用,我想在其中传递带有消息的自定义标头。在发布消息功能上我只能传递BasicProperties,它只能接受:

  • 回复
  • 相关 ID
  • 内容类型
  • 内容编码

但是,当我们根据自定义标头路由消息时,我们严重依赖自定义标头,并且在标准 RabbitMQ 客户端中,标头字典集合上的 BasicProperties 对象支持这一点。这是 RabbitMQ Ballerina 客户端的差距吗?

创建了一个 Ballerina 文件并尝试发布到 RabbitMQ,但我错过了 BasicProperties 对象上的 headers 属性。

rabbitmq:BasicProperties props = {
    replyTo: "reply-queue",
    // Expect headers property in the form of a dictionary
};

// Publishes the message using the `newClient` and the routing key named `OrderQueue`.
check self.orderClient->publishMessage({
    content: newOrder,
    routingKey: "",
    properties: props
});
    
return http:ACCEPTED;
rabbitmq ballerina ballerina-swan-lake
1个回答
0
投票

此支持已添加但尚未发布。您可以在此处跟踪进度:https://github.com/ballerina-platform/module-ballerinax-rabbitmq/pull/997

一旦该功能可用,我将更新此线程。

© www.soinside.com 2019 - 2024. All rights reserved.