为了账号安全,请及时绑定邮箱和手机立即绑定

我们如何向消息添加属性?

我们如何向消息添加属性?

C#
MYYA 2023-08-13 16:25:19
进行绑定时是否可以设置消息属性(我认为它们称为 UserProperties)?在我的函数中,我正在将输出绑定到服务总线:    [return: ServiceBus("%Detach:Done%", Connection = "Detach:ServiceBus", EntityType = EntityType.Topic)]当我们绑定到ServiceBus时,我们如何设置消息属性?
查看完整描述

2 回答

?
慕莱坞森

TA贡献1810条经验 获得超4个赞

public static class Function7

{

    [FunctionName("Function7")]

    [return: ServiceBus("test2", 

        Connection = "AzureServiceBusConnectionString", EntityType = EntityType.Queue)] 

    public static async Task<Message> Run([ServiceBusTrigger("test", 

        Connection = "AzureServiceBusConnectionString")]string myQueueItem, ILogger log)

    {

        log.LogInformation(

            $"C# ServiceBus queue trigger function processed message: {myQueueItem}");


        var message = new Message(Encoding.UTF8.GetBytes("{}"));

        message.Label = "Hello";

        message.UserProperties.Add("abc", 123);

        return await Task.FromResult<Message>(message);

    }

}


查看完整回答
反对 回复 2023-08-13
?
湖上湖

TA贡献2003条经验 获得超2个赞

在异步函数中,使用返回值或IAsyncCollector代替out参数。对于 2.x,使用Message而不是像 BrokeredMessage 这样的IAsyncCollector<Message>

然后您可以设置MessageId消息的属性。

var message = new Message() { MessageId = messageId};


查看完整回答
反对 回复 2023-08-13
  • 2 回答
  • 0 关注
  • 133 浏览

添加回答

举报

0/150
提交
取消
意见反馈 帮助中心 APP下载
官方微信