Add protocol name and version tags on deliver operation

References #952

(cherry picked from commit 014dc65)

Author: acogoluegnes

src/main/java/com/rabbitmq/client/observation/micrometer/DefaultDeliverObservationConvention.java

@@ -50,7 +50,9 @@ private String source(String destination) {
   public KeyValues getLowCardinalityKeyValues(DeliverContext context) {
     return KeyValues.of(
         LowCardinalityTags.MESSAGING_OPERATION.withValue(this.operation),
-        LowCardinalityTags.MESSAGING_SYSTEM.withValue("rabbitmq"));
+        LowCardinalityTags.MESSAGING_SYSTEM.withValue("rabbitmq"),
+        LowCardinalityTags.NET_PROTOCOL_NAME.withValue("amqp"),
+        LowCardinalityTags.NET_PROTOCOL_VERSION.withValue("0.9.1"));
   }
 
   @Override

src/test/java/com/rabbitmq/client/test/functional/MicrometerObservationCollectorMetrics.java

@@ -166,7 +166,9 @@ public SampleTestRunnerConsumer yourCode() {
               .hasTag("messaging.rabbitmq.destination.routing_key", "metrics.queue")
               .hasTag("messaging.destination.name", "amq.default")
               .hasTag("messaging.source.name", "metrics.queue")
-              .hasTag("messaging.message.payload_size_bytes", String.valueOf(PAYLOAD.length));
+              .hasTag("messaging.message.payload_size_bytes", String.valueOf(PAYLOAD.length))
+              .hasTag("net.protocol.name", "amqp")
+              .hasTag("net.protocol.version", "0.9.1");
           waitAtMost(
               () ->
                   getMeterRegistry().find("rabbitmq.publish").timer() != null
@@ -239,7 +241,9 @@ public SampleTestRunnerConsumer yourCode() {
               .hasTag("messaging.rabbitmq.destination.routing_key", "metrics.queue")
               .hasTag("messaging.destination.name", "amq.default")
               .hasTag("messaging.source.name", "metrics.queue")
-              .hasTag("messaging.message.payload_size_bytes", String.valueOf(PAYLOAD.length));
+              .hasTag("messaging.message.payload_size_bytes", String.valueOf(PAYLOAD.length))
+              .hasTag("net.protocol.name", "amqp")
+              .hasTag("net.protocol.version", "0.9.1");
           List<FinishedSpan> pollingSpans =
               spans.stream()
                   .filter(f -> f.size() == 1)
@@ -323,7 +327,9 @@ public SampleTestRunnerConsumer yourCode() {
               .hasTag("messaging.rabbitmq.destination.routing_key", "metrics.queue")
               .hasTag("messaging.destination.name", "amq.default")
               .hasTag("messaging.source.name", "metrics.queue")
-              .hasTag("messaging.message.payload_size_bytes", String.valueOf(PAYLOAD.length));
+              .hasTag("messaging.message.payload_size_bytes", String.valueOf(PAYLOAD.length))
+              .hasTag("net.protocol.name", "amqp")
+              .hasTag("net.protocol.version", "0.9.1");
           List<FinishedSpan> pollingSpans =
               spans.stream()
                   .filter(f -> f.size() == 1)