我尝试将 Ballerina 编程语言与 RabbitMQ 客户端结合使用,我想在其中传递带有消息的自定义标头。在发布消息功能上我只能传递BasicProperties,它只能接受:
但是,当我们根据自定义标头路由消息时,我们严重依赖自定义标头,并且在标准 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;
此支持已添加但尚未发布。您可以在此处跟踪进度:https://github.com/ballerina-platform/module-ballerinax-rabbitmq/pull/997。
一旦该功能可用,我将更新此线程。