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);
}
}
TA贡献2003条经验 获得超2个赞
在异步函数中,使用返回值或IAsyncCollector
代替out
参数。对于 2.x,使用Message而不是像 BrokeredMessage 这样的IAsyncCollector<Message>
。
然后您可以设置MessageId
消息的属性。
var message = new Message() { MessageId = messageId};
- 2 回答
- 0 关注
- 133 浏览
添加回答
举报