IESServiceBusTrigger.cs 1.3 KB

12345678910111213141516171819202122232425262728293031323334353637
  1. using System;
  2. using System.Threading.Tasks;
  3. using Azure.Messaging.ServiceBus;
  4. using Microsoft.Azure.Functions.Worker;
  5. using Microsoft.Extensions.Logging;
  6. namespace TEAMModelOS.Function
  7. {
  8. public class IESServiceBusTrigger
  9. {
  10. private readonly ILogger<IESServiceBusTrigger> _logger;
  11. public IESServiceBusTrigger(ILogger<IESServiceBusTrigger> logger)
  12. {
  13. _logger = logger;
  14. }
  15. /// <summary>
  16. /// UseDevelopmentStorage=true
  17. /// </summary>
  18. /// <param name="message"></param>
  19. /// <param name="messageActions"></param>
  20. /// <returns></returns>
  21. [Function("BlobRoot")]
  22. public async Task BlobRoot(
  23. [ServiceBusTrigger("%Azure:ServiceBus:ActiveTask%", "blobroot", Connection = "Azure:ServiceBus:ConnectionString")]
  24. ServiceBusReceivedMessage message,
  25. ServiceBusMessageActions messageActions)
  26. {
  27. _logger.LogInformation("Message ID: {id}", message.MessageId);
  28. _logger.LogInformation("Message Body: {body}", message.Body);
  29. _logger.LogInformation("Message Content-Type: {contentType}", message.ContentType);
  30. // Complete the message
  31. await messageActions.CompleteMessageAsync(message);
  32. }
  33. }
  34. }