Functions.Templates/Templates/ServiceBusTopicTrigger-CSharp-Isolated/ServiceBusTopicTriggerCSharp.cs

using System;
using System.Threading.Tasks;
using Azure.Messaging.ServiceBus;
using Microsoft.Azure.Functions.Worker;
using Microsoft.Extensions.Logging;

namespace Company.Function;

public class ServiceBusTopicTriggerCSharp
{
    private readonly ILogger<ServiceBusTopicTriggerCSharp> _logger;

    public ServiceBusTopicTriggerCSharp(ILogger<ServiceBusTopicTriggerCSharp> logger)
    {
        _logger = logger;
    }

    [Function(nameof(ServiceBusTopicTriggerCSharp))]
    public async Task Run(
        [ServiceBusTrigger("TopicNameValue", "SubscriptionNameValue", Connection = "ConnectionValue")]
        ServiceBusReceivedMessage message,
        ServiceBusMessageActions messageActions)
    {
        _logger.LogInformation("Message ID: {id}", message.MessageId);
        _logger.LogInformation("Message Body: {body}", message.Body);
        _logger.LogInformation("Message Content-Type: {contentType}", message.ContentType);

            // Complete the message
        await messageActions.CompleteMessageAsync(message);
    }
}