diff --git a/extension/WebJobs.Extensions.RabbitMQ/Trigger/RabbitMQListener.cs b/extension/WebJobs.Extensions.RabbitMQ/Trigger/RabbitMQListener.cs
index 24bf0f2..cab2283 100644
--- a/extension/WebJobs.Extensions.RabbitMQ/Trigger/RabbitMQListener.cs
+++ b/extension/WebJobs.Extensions.RabbitMQ/Trigger/RabbitMQListener.cs
@@ -107,6 +107,9 @@ public Task StartAsync(CancellationToken cancellationToken)
         async Task ReceivedHandler(object model, BasicDeliverEventArgs args)
         {
             using Activity activity = RabbitMQActivitySource.StartActivity(args.BasicProperties);
+            activity?.AddTag("amqp.queue", this.queue);
+            activity?.AddTag("amqp.channel", this.channel);
+            activity?.AddTag("amqp.bodySize", args.Body.Length);
 
             var input = new TriggeredFunctionData() { TriggerValue = args };
 
@@ -118,6 +121,7 @@ async Task ReceivedHandler(object model, BasicDeliverEventArgs args)
                 args.BasicProperties.Headers ??= new Dictionary<string, object>();
                 args.BasicProperties.Headers.TryGetValue(RequeueCountHeaderName, out object headerValue);
                 int requeueCount = Convert.ToInt32(headerValue, CultureInfo.InvariantCulture) + 1;
+                activity?.AddTag("amqp.requeueCount", requeueCount);
 
                 if (requeueCount >= 5)
                 {