View Source OpenTelemetry.SemConv.Incubating.MessagingAttributes (OpenTelemetry.SemConv v1.27.0)

OpenTelemetry Semantic Conventions for Messaging attributes.

Summary

Types

messaging_operation_type_values()

A string identifying the type of the messaging operation.

messaging_rocketmq_consumption_model_values()

Model of message consumption. This only applies to consumer spans.

messaging_rocketmq_message_type_values()

Type of message.

messaging_servicebus_disposition_status_values()

Describes the settlement type.

messaging_system_values()

The messaging system as identified by the client instrumentation.

Functions

messaging_batch_message_count()

The number of messages sent, received, or processed in the scope of the batching operation.

messaging_client_id()

A unique identifier for the client that consumes or produces a message.

messaging_consumer_group_name()

The name of the consumer group with which a consumer is associated.

messaging_destination_anonymous()

A boolean that is true if the message destination is anonymous (could be unnamed or have auto-generated name).

messaging_destination_name()

The message destination name

messaging_destination_partition_id()

The identifier of the partition messages are sent to or received from, unique within the messaging.destination.name.

messaging_destination_publish_anonymous() deprecated
messaging_destination_publish_name() deprecated
messaging_destination_subscription_name()

The name of the destination subscription from which a message is consumed.

messaging_destination_template()

Low cardinality representation of the messaging destination name

messaging_destination_temporary()

A boolean that is true if the message destination is temporary and might not exist anymore after messages are processed.

messaging_eventhubs_consumer_group() deprecated
messaging_eventhubs_message_enqueued_time()

The UTC epoch seconds at which the message has been accepted and stored in the entity.

messaging_gcp_pubsub_message_ack_deadline()

The ack deadline in seconds set for the modify ack deadline request.

messaging_gcp_pubsub_message_ack_id()

The ack id for a given message.

messaging_gcp_pubsub_message_delivery_attempt()

The delivery attempt for a given message.

messaging_gcp_pubsub_message_ordering_key()

The ordering key for a given message. If the attribute is not present, the message does not have an ordering key.

messaging_kafka_consumer_group() deprecated
messaging_kafka_destination_partition() deprecated
messaging_kafka_message_key()

Message keys in Kafka are used for grouping alike messages to ensure they're processed on the same partition. They differ from messaging.message.id in that they're not unique. If the key is null, the attribute MUST NOT be set.

messaging_kafka_message_offset() deprecated
messaging_kafka_message_tombstone()

A boolean that is true if the message is a tombstone.

messaging_kafka_offset()

The offset of a record in the corresponding Kafka partition.

messaging_message_body_size()

The size of the message body in bytes.

messaging_message_conversation_id()

The conversation ID identifying the conversation to which the message belongs, represented as a string. Sometimes called "Correlation ID".

messaging_message_envelope_size()

The size of the message body and metadata in bytes.

messaging_message_id()

A value used by the messaging system as an identifier for the message, represented as a string.

messaging_operation() deprecated
messaging_operation_name()

The system-specific name of the messaging operation.

messaging_operation_type()

A string identifying the type of the messaging operation.

messaging_operation_type_values()
messaging_rabbitmq_destination_routing_key()

RabbitMQ message routing key.

messaging_rabbitmq_message_delivery_tag()

RabbitMQ message delivery tag

messaging_rocketmq_client_group() deprecated
messaging_rocketmq_consumption_model()

Model of message consumption. This only applies to consumer spans.

messaging_rocketmq_consumption_model_values()
messaging_rocketmq_message_delay_time_level()

The delay time level for delay message, which determines the message delay time.

messaging_rocketmq_message_delivery_timestamp()

The timestamp in milliseconds that the delay message is expected to be delivered to consumer.

messaging_rocketmq_message_group()

It is essential for FIFO message. Messages that belong to the same message group are always processed one by one within the same consumer group.

messaging_rocketmq_message_keys()

Key(s) of message, another way to mark message besides message id.

messaging_rocketmq_message_tag()

The secondary classifier of message besides topic.

messaging_rocketmq_message_type()

Type of message.

messaging_rocketmq_message_type_values()
messaging_rocketmq_namespace()

Namespace of RocketMQ resources, resources in different namespaces are individual.

messaging_servicebus_destination_subscription_name() deprecated
messaging_servicebus_disposition_status()

Describes the settlement type.

messaging_servicebus_disposition_status_values()
messaging_servicebus_message_delivery_count()

Number of deliveries that have been attempted for this message.

messaging_servicebus_message_enqueued_time()

The UTC epoch seconds at which the message has been accepted and stored in the entity.

messaging_system()

The messaging system as identified by the client instrumentation.

messaging_system_values()

Types

Link to this type

messaging_operation_type_values()

View Source 
@type messaging_operation_type_values() :: %{
  publish: :publish,
  create: :create,
  receive: :receive,
  process: :process,
  settle: :settle,
  deliver: :deliver
}

A string identifying the type of the messaging operation.

Enum Values

  • :publish e - One or more messages are provided for publishing to an intermediary. If a single message is published, the context of the "Publish" span can be used as the creation context and no "Create" span needs to be created.

  • :create e - A message is created. "Create" spans always refer to a single message and are used to provide a unique creation context for messages in batch publishing scenarios.

  • :receive e - One or more messages are requested by a consumer. This operation refers to pull-based scenarios, where consumers explicitly call methods of messaging SDKs to receive messages.

  • :process e - One or more messages are processed by a consumer.

  • :settle e - One or more messages are settled.

  • :deliver e - deprecated Deprecated. Use process instead.

Link to this type

messaging_rocketmq_consumption_model_values()

View Source 
@type messaging_rocketmq_consumption_model_values() :: %{
  clustering: :clustering,
  broadcasting: :broadcasting
}

Model of message consumption. This only applies to consumer spans.

Enum Values

  • :clustering e - Clustering consumption model
  • :broadcasting e - Broadcasting consumption model
Link to this type

messaging_rocketmq_message_type_values()

View Source 
@type messaging_rocketmq_message_type_values() :: %{
  normal: :normal,
  fifo: :fifo,
  delay: :delay,
  transaction: :transaction
}

Type of message.

Enum Values

  • :normal e - Normal message
  • :fifo e - FIFO message
  • :delay e - Delay message
  • :transaction e - Transaction message
Link to this type

messaging_servicebus_disposition_status_values()

View Source 
@type messaging_servicebus_disposition_status_values() :: %{
  complete: :complete,
  abandon: :abandon,
  dead_letter: :dead_letter,
  defer: :defer
}

Describes the settlement type.

Enum Values

  • :complete e - Message is completed
  • :abandon e - Message is abandoned
  • :dead_letter e - Message is sent to dead letter queue
  • :defer e - Message is deferred
Link to this type

messaging_system_values()

View Source 
@type messaging_system_values() :: %{
  activemq: :activemq,
  aws_sqs: :aws_sqs,
  eventgrid: :eventgrid,
  eventhubs: :eventhubs,
  servicebus: :servicebus,
  gcp_pubsub: :gcp_pubsub,
  jms: :jms,
  kafka: :kafka,
  rabbitmq: :rabbitmq,
  rocketmq: :rocketmq,
  pulsar: :pulsar
}

The messaging system as identified by the client instrumentation.

Enum Values

  • :activemq e - Apache ActiveMQ
  • :aws_sqs e - Amazon Simple Queue Service (SQS)
  • :eventgrid e - Azure Event Grid
  • :eventhubs e - Azure Event Hubs
  • :servicebus e - Azure Service Bus
  • :gcp_pubsub e - Google Cloud Pub/Sub
  • :jms e - Java Message Service
  • :kafka e - Apache Kafka
  • :rabbitmq e - RabbitMQ
  • :rocketmq e - Apache RocketMQ
  • :pulsar e - Apache Pulsar

Functions

Link to this function

messaging_batch_message_count()

View Source 
@spec messaging_batch_message_count() :: :"messaging.batch.message_count"

The number of messages sent, received, or processed in the scope of the batching operation.

Value type

Value must be of type integer().

Notes

Instrumentations SHOULD NOT set messaging.batch.message_count on spans that operate with a single message. When a messaging client library supports both batch and single-message API for the same operation, instrumentations SHOULD use messaging.batch.message_count for batching APIs and SHOULD NOT use it for single-message APIs.

Examples 

[0, 1, 2]
iex> OpenTelemetry.SemConv.Incubating.MessagingAttributes.messaging_batch_message_count()
:"messaging.batch.message_count"
Link to this function

messaging_client_id()

View Source 
@spec messaging_client_id() :: :"messaging.client.id"

A unique identifier for the client that consumes or produces a message.

Value type

Value must be of type atom() | String.t().

Examples 

["client-5", "myhost@8742@s8083jm"]
iex> OpenTelemetry.SemConv.Incubating.MessagingAttributes.messaging_client_id()
:"messaging.client.id"
Link to this function

messaging_consumer_group_name()

View Source 
@spec messaging_consumer_group_name() :: :"messaging.consumer.group.name"

The name of the consumer group with which a consumer is associated.

Value type

Value must be of type atom() | String.t().

Notes

Semantic conventions for individual messaging systems SHOULD document whether messaging.consumer.group.name is applicable and what it means in the context of that system.

Examples 

["my-group", "indexer"]
iex> OpenTelemetry.SemConv.Incubating.MessagingAttributes.messaging_consumer_group_name()
:"messaging.consumer.group.name"
Link to this function

messaging_destination_anonymous()

View Source 
@spec messaging_destination_anonymous() :: :"messaging.destination.anonymous"

A boolean that is true if the message destination is anonymous (could be unnamed or have auto-generated name).

Value type

Value must be of type boolean().

iex> OpenTelemetry.SemConv.Incubating.MessagingAttributes.messaging_destination_anonymous()
:"messaging.destination.anonymous"
Link to this function

messaging_destination_name()

View Source 
@spec messaging_destination_name() :: :"messaging.destination.name"

The message destination name

Value type

Value must be of type atom() | String.t().

Notes

Destination name SHOULD uniquely identify a specific queue, topic or other entity within the broker. If
the broker doesn't have such notion, the destination name SHOULD uniquely identify the broker.

Examples 

["MyQueue", "MyTopic"]
iex> OpenTelemetry.SemConv.Incubating.MessagingAttributes.messaging_destination_name()
:"messaging.destination.name"
Link to this function

messaging_destination_partition_id()

View Source 
@spec messaging_destination_partition_id() :: :"messaging.destination.partition.id"

The identifier of the partition messages are sent to or received from, unique within the messaging.destination.name.

Value type

Value must be of type atom() | String.t().

Examples 

1
iex> OpenTelemetry.SemConv.Incubating.MessagingAttributes.messaging_destination_partition_id()
:"messaging.destination.partition.id"
Link to this function

messaging_destination_publish_anonymous()

View Source
This function is deprecated. No replacement at this time. . 
@spec messaging_destination_publish_anonymous() ::
  :"messaging.destination_publish.anonymous"
Link to this function

messaging_destination_publish_name()

View Source
This function is deprecated. No replacement at this time. . 
@spec messaging_destination_publish_name() :: :"messaging.destination_publish.name"
Link to this function

messaging_destination_subscription_name()

View Source 
@spec messaging_destination_subscription_name() ::
  :"messaging.destination.subscription.name"

The name of the destination subscription from which a message is consumed.

Value type

Value must be of type atom() | String.t().

Notes

Semantic conventions for individual messaging systems SHOULD document whether messaging.destination.subscription.name is applicable and what it means in the context of that system.

Examples 

["subscription-a"]
iex> OpenTelemetry.SemConv.Incubating.MessagingAttributes.messaging_destination_subscription_name()
:"messaging.destination.subscription.name"
Link to this function

messaging_destination_template()

View Source 
@spec messaging_destination_template() :: :"messaging.destination.template"

Low cardinality representation of the messaging destination name

Value type

Value must be of type atom() | String.t().

Notes

Destination names could be constructed from templates. An example would be a destination name involving a user name or product id. Although the destination name in this case is of high cardinality, the underlying template is of low cardinality and can be effectively used for grouping and aggregation.

Examples 

["/customers/{customerId}"]
iex> OpenTelemetry.SemConv.Incubating.MessagingAttributes.messaging_destination_template()
:"messaging.destination.template"
Link to this function

messaging_destination_temporary()

View Source 
@spec messaging_destination_temporary() :: :"messaging.destination.temporary"

A boolean that is true if the message destination is temporary and might not exist anymore after messages are processed.

Value type

Value must be of type boolean().

iex> OpenTelemetry.SemConv.Incubating.MessagingAttributes.messaging_destination_temporary()
:"messaging.destination.temporary"
Link to this function

messaging_eventhubs_consumer_group()

View Source
This function is deprecated. Replaced by `messaging.consumer.group.name`. . 
@spec messaging_eventhubs_consumer_group() :: :"messaging.eventhubs.consumer.group"
Link to this function

messaging_eventhubs_message_enqueued_time()

View Source 
@spec messaging_eventhubs_message_enqueued_time() ::
  :"messaging.eventhubs.message.enqueued_time"

The UTC epoch seconds at which the message has been accepted and stored in the entity.

Value type

Value must be of type integer().

Examples 

1701393730
iex> OpenTelemetry.SemConv.Incubating.MessagingAttributes.messaging_eventhubs_message_enqueued_time()
:"messaging.eventhubs.message.enqueued_time"
Link to this function

messaging_gcp_pubsub_message_ack_deadline()

View Source 
@spec messaging_gcp_pubsub_message_ack_deadline() ::
  :"messaging.gcp_pubsub.message.ack_deadline"

The ack deadline in seconds set for the modify ack deadline request.

Value type

Value must be of type integer().

Examples 

10
iex> OpenTelemetry.SemConv.Incubating.MessagingAttributes.messaging_gcp_pubsub_message_ack_deadline()
:"messaging.gcp_pubsub.message.ack_deadline"
Link to this function

messaging_gcp_pubsub_message_ack_id()

View Source 
@spec messaging_gcp_pubsub_message_ack_id() :: :"messaging.gcp_pubsub.message.ack_id"

The ack id for a given message.

Value type

Value must be of type atom() | String.t().

Examples 

ack_id
iex> OpenTelemetry.SemConv.Incubating.MessagingAttributes.messaging_gcp_pubsub_message_ack_id()
:"messaging.gcp_pubsub.message.ack_id"
Link to this function

messaging_gcp_pubsub_message_delivery_attempt()

View Source 
@spec messaging_gcp_pubsub_message_delivery_attempt() ::
  :"messaging.gcp_pubsub.message.delivery_attempt"

The delivery attempt for a given message.

Value type

Value must be of type integer().

Examples 

2
iex> OpenTelemetry.SemConv.Incubating.MessagingAttributes.messaging_gcp_pubsub_message_delivery_attempt()
:"messaging.gcp_pubsub.message.delivery_attempt"
Link to this function

messaging_gcp_pubsub_message_ordering_key()

View Source 
@spec messaging_gcp_pubsub_message_ordering_key() ::
  :"messaging.gcp_pubsub.message.ordering_key"

The ordering key for a given message. If the attribute is not present, the message does not have an ordering key.

Value type

Value must be of type atom() | String.t().

Examples 

ordering_key
iex> OpenTelemetry.SemConv.Incubating.MessagingAttributes.messaging_gcp_pubsub_message_ordering_key()
:"messaging.gcp_pubsub.message.ordering_key"
Link to this function

messaging_kafka_consumer_group()

View Source
This function is deprecated. Replaced by `messaging.consumer.group.name`. . 
@spec messaging_kafka_consumer_group() :: :"messaging.kafka.consumer.group"
Link to this function

messaging_kafka_destination_partition()

View Source
This function is deprecated. Replaced by `messaging.destination.partition.id`. . 
@spec messaging_kafka_destination_partition() ::
  :"messaging.kafka.destination.partition"
Link to this function

messaging_kafka_message_key()

View Source 
@spec messaging_kafka_message_key() :: :"messaging.kafka.message.key"

Message keys in Kafka are used for grouping alike messages to ensure they're processed on the same partition. They differ from messaging.message.id in that they're not unique. If the key is null, the attribute MUST NOT be set.

Value type

Value must be of type atom() | String.t().

Notes

If the key type is not string, it's string representation has to be supplied for the attribute. If the key has no unambiguous, canonical string form, don't include its value.

Examples 

myKey
iex> OpenTelemetry.SemConv.Incubating.MessagingAttributes.messaging_kafka_message_key()
:"messaging.kafka.message.key"
Link to this function

messaging_kafka_message_offset()

View Source
This function is deprecated. Replaced by `messaging.kafka.offset`. . 
@spec messaging_kafka_message_offset() :: :"messaging.kafka.message.offset"
Link to this function

messaging_kafka_message_tombstone()

View Source 
@spec messaging_kafka_message_tombstone() :: :"messaging.kafka.message.tombstone"

A boolean that is true if the message is a tombstone.

Value type

Value must be of type boolean().

iex> OpenTelemetry.SemConv.Incubating.MessagingAttributes.messaging_kafka_message_tombstone()
:"messaging.kafka.message.tombstone"
Link to this function

messaging_kafka_offset()

View Source 
@spec messaging_kafka_offset() :: :"messaging.kafka.offset"

The offset of a record in the corresponding Kafka partition.

Value type

Value must be of type integer().

Examples 

42
iex> OpenTelemetry.SemConv.Incubating.MessagingAttributes.messaging_kafka_offset()
:"messaging.kafka.offset"
Link to this function

messaging_message_body_size()

View Source 
@spec messaging_message_body_size() :: :"messaging.message.body.size"

The size of the message body in bytes.

Value type

Value must be of type integer().

Notes

This can refer to both the compressed or uncompressed body size. If both sizes are known, the uncompressed
body size should be used.

Examples 

1439
iex> OpenTelemetry.SemConv.Incubating.MessagingAttributes.messaging_message_body_size()
:"messaging.message.body.size"
Link to this function

messaging_message_conversation_id()

View Source 
@spec messaging_message_conversation_id() :: :"messaging.message.conversation_id"

The conversation ID identifying the conversation to which the message belongs, represented as a string. Sometimes called "Correlation ID".

Value type

Value must be of type atom() | String.t().

Examples 

MyConversationId
iex> OpenTelemetry.SemConv.Incubating.MessagingAttributes.messaging_message_conversation_id()
:"messaging.message.conversation_id"
Link to this function

messaging_message_envelope_size()

View Source 
@spec messaging_message_envelope_size() :: :"messaging.message.envelope.size"

The size of the message body and metadata in bytes.

Value type

Value must be of type integer().

Notes

This can refer to both the compressed or uncompressed size. If both sizes are known, the uncompressed
size should be used.

Examples 

2738
iex> OpenTelemetry.SemConv.Incubating.MessagingAttributes.messaging_message_envelope_size()
:"messaging.message.envelope.size"
Link to this function

messaging_message_id()

View Source 
@spec messaging_message_id() :: :"messaging.message.id"

A value used by the messaging system as an identifier for the message, represented as a string.

Value type

Value must be of type atom() | String.t().

Examples 

452a7c7c7c7048c2f887f61572b18fc2
iex> OpenTelemetry.SemConv.Incubating.MessagingAttributes.messaging_message_id()
:"messaging.message.id"
Link to this function

messaging_operation()

View Source
This function is deprecated. Replaced by `messaging.operation.type`. . 
@spec messaging_operation() :: :"messaging.operation"
Link to this function

messaging_operation_name()

View Source 
@spec messaging_operation_name() :: :"messaging.operation.name"

The system-specific name of the messaging operation.

Value type

Value must be of type atom() | String.t().

Examples 

["ack", "nack", "send"]
iex> OpenTelemetry.SemConv.Incubating.MessagingAttributes.messaging_operation_name()
:"messaging.operation.name"
Link to this function

messaging_operation_type()

View Source 
@spec messaging_operation_type() :: :"messaging.operation.type"

A string identifying the type of the messaging operation.

Notes

If a custom value is used, it MUST be of low cardinality.

iex> OpenTelemetry.SemConv.Incubating.MessagingAttributes.messaging_operation_type()
:"messaging.operation.type"

iex> OpenTelemetry.SemConv.Incubating.MessagingAttributes.messaging_operation_type_values().publish
:publish

iex> %{OpenTelemetry.SemConv.Incubating.MessagingAttributes.messaging_operation_type() => OpenTelemetry.SemConv.Incubating.MessagingAttributes.messaging_operation_type_values().publish}
%{:"messaging.operation.type" => :publish}
Link to this function

messaging_operation_type_values()

View Source 
@spec messaging_operation_type_values() :: messaging_operation_type_values()
Link to this function

messaging_rabbitmq_destination_routing_key()

View Source 
@spec messaging_rabbitmq_destination_routing_key() ::
  :"messaging.rabbitmq.destination.routing_key"

RabbitMQ message routing key.

Value type

Value must be of type atom() | String.t().

Examples 

myKey
iex> OpenTelemetry.SemConv.Incubating.MessagingAttributes.messaging_rabbitmq_destination_routing_key()
:"messaging.rabbitmq.destination.routing_key"
Link to this function

messaging_rabbitmq_message_delivery_tag()

View Source 
@spec messaging_rabbitmq_message_delivery_tag() ::
  :"messaging.rabbitmq.message.delivery_tag"

RabbitMQ message delivery tag

Value type

Value must be of type integer().

Examples 

123
iex> OpenTelemetry.SemConv.Incubating.MessagingAttributes.messaging_rabbitmq_message_delivery_tag()
:"messaging.rabbitmq.message.delivery_tag"
Link to this function

messaging_rocketmq_client_group()

View Source
This function is deprecated. Replaced by `messaging.consumer.group.name` on the consumer spans. No replacement for producer spans. . 
@spec messaging_rocketmq_client_group() :: :"messaging.rocketmq.client_group"
Link to this function

messaging_rocketmq_consumption_model()

View Source 
@spec messaging_rocketmq_consumption_model() ::
  :"messaging.rocketmq.consumption_model"

Model of message consumption. This only applies to consumer spans.

iex> OpenTelemetry.SemConv.Incubating.MessagingAttributes.messaging_rocketmq_consumption_model()
:"messaging.rocketmq.consumption_model"

iex> OpenTelemetry.SemConv.Incubating.MessagingAttributes.messaging_rocketmq_consumption_model_values().clustering
:clustering

iex> %{OpenTelemetry.SemConv.Incubating.MessagingAttributes.messaging_rocketmq_consumption_model() => OpenTelemetry.SemConv.Incubating.MessagingAttributes.messaging_rocketmq_consumption_model_values().clustering}
%{:"messaging.rocketmq.consumption_model" => :clustering}
Link to this function

messaging_rocketmq_consumption_model_values()

View Source 
@spec messaging_rocketmq_consumption_model_values() ::
  messaging_rocketmq_consumption_model_values()
Link to this function

messaging_rocketmq_message_delay_time_level()

View Source 
@spec messaging_rocketmq_message_delay_time_level() ::
  :"messaging.rocketmq.message.delay_time_level"

The delay time level for delay message, which determines the message delay time.

Value type

Value must be of type integer().

Examples 

3
iex> OpenTelemetry.SemConv.Incubating.MessagingAttributes.messaging_rocketmq_message_delay_time_level()
:"messaging.rocketmq.message.delay_time_level"
Link to this function

messaging_rocketmq_message_delivery_timestamp()

View Source 
@spec messaging_rocketmq_message_delivery_timestamp() ::
  :"messaging.rocketmq.message.delivery_timestamp"

The timestamp in milliseconds that the delay message is expected to be delivered to consumer.

Value type

Value must be of type integer().

Examples 

1665987217045
iex> OpenTelemetry.SemConv.Incubating.MessagingAttributes.messaging_rocketmq_message_delivery_timestamp()
:"messaging.rocketmq.message.delivery_timestamp"
Link to this function

messaging_rocketmq_message_group()

View Source 
@spec messaging_rocketmq_message_group() :: :"messaging.rocketmq.message.group"

It is essential for FIFO message. Messages that belong to the same message group are always processed one by one within the same consumer group.

Value type

Value must be of type atom() | String.t().

Examples 

myMessageGroup
iex> OpenTelemetry.SemConv.Incubating.MessagingAttributes.messaging_rocketmq_message_group()
:"messaging.rocketmq.message.group"
Link to this function

messaging_rocketmq_message_keys()

View Source 
@spec messaging_rocketmq_message_keys() :: :"messaging.rocketmq.message.keys"

Key(s) of message, another way to mark message besides message id.

Value type

Value must be of type [atom() | String.t()].

Examples 

["keyA", "keyB"]
iex> OpenTelemetry.SemConv.Incubating.MessagingAttributes.messaging_rocketmq_message_keys()
:"messaging.rocketmq.message.keys"
Link to this function

messaging_rocketmq_message_tag()

View Source 
@spec messaging_rocketmq_message_tag() :: :"messaging.rocketmq.message.tag"

The secondary classifier of message besides topic.

Value type

Value must be of type atom() | String.t().

Examples 

tagA
iex> OpenTelemetry.SemConv.Incubating.MessagingAttributes.messaging_rocketmq_message_tag()
:"messaging.rocketmq.message.tag"
Link to this function

messaging_rocketmq_message_type()

View Source 
@spec messaging_rocketmq_message_type() :: :"messaging.rocketmq.message.type"

Type of message.

iex> OpenTelemetry.SemConv.Incubating.MessagingAttributes.messaging_rocketmq_message_type()
:"messaging.rocketmq.message.type"

iex> OpenTelemetry.SemConv.Incubating.MessagingAttributes.messaging_rocketmq_message_type_values().normal
:normal

iex> %{OpenTelemetry.SemConv.Incubating.MessagingAttributes.messaging_rocketmq_message_type() => OpenTelemetry.SemConv.Incubating.MessagingAttributes.messaging_rocketmq_message_type_values().normal}
%{:"messaging.rocketmq.message.type" => :normal}
Link to this function

messaging_rocketmq_message_type_values()

View Source 
@spec messaging_rocketmq_message_type_values() ::
  messaging_rocketmq_message_type_values()
Link to this function

messaging_rocketmq_namespace()

View Source 
@spec messaging_rocketmq_namespace() :: :"messaging.rocketmq.namespace"

Namespace of RocketMQ resources, resources in different namespaces are individual.

Value type

Value must be of type atom() | String.t().

Examples 

myNamespace
iex> OpenTelemetry.SemConv.Incubating.MessagingAttributes.messaging_rocketmq_namespace()
:"messaging.rocketmq.namespace"
Link to this function

messaging_servicebus_destination_subscription_name()

View Source
This function is deprecated. Replaced by `messaging.servicebus.destination.subscription_name`. . 
@spec messaging_servicebus_destination_subscription_name() ::
  :"messaging.servicebus.destination.subscription_name"
Link to this function

messaging_servicebus_disposition_status()

View Source 
@spec messaging_servicebus_disposition_status() ::
  :"messaging.servicebus.disposition_status"

Describes the settlement type.

iex> OpenTelemetry.SemConv.Incubating.MessagingAttributes.messaging_servicebus_disposition_status()
:"messaging.servicebus.disposition_status"

iex> OpenTelemetry.SemConv.Incubating.MessagingAttributes.messaging_servicebus_disposition_status_values().complete
:complete

iex> %{OpenTelemetry.SemConv.Incubating.MessagingAttributes.messaging_servicebus_disposition_status() => OpenTelemetry.SemConv.Incubating.MessagingAttributes.messaging_servicebus_disposition_status_values().complete}
%{:"messaging.servicebus.disposition_status" => :complete}
Link to this function

messaging_servicebus_disposition_status_values()

View Source 
@spec messaging_servicebus_disposition_status_values() ::
  messaging_servicebus_disposition_status_values()
Link to this function

messaging_servicebus_message_delivery_count()

View Source 
@spec messaging_servicebus_message_delivery_count() ::
  :"messaging.servicebus.message.delivery_count"

Number of deliveries that have been attempted for this message.

Value type

Value must be of type integer().

Examples 

2
iex> OpenTelemetry.SemConv.Incubating.MessagingAttributes.messaging_servicebus_message_delivery_count()
:"messaging.servicebus.message.delivery_count"
Link to this function

messaging_servicebus_message_enqueued_time()

View Source 
@spec messaging_servicebus_message_enqueued_time() ::
  :"messaging.servicebus.message.enqueued_time"

The UTC epoch seconds at which the message has been accepted and stored in the entity.

Value type

Value must be of type integer().

Examples 

1701393730
iex> OpenTelemetry.SemConv.Incubating.MessagingAttributes.messaging_servicebus_message_enqueued_time()
:"messaging.servicebus.message.enqueued_time"
Link to this function

messaging_system()

View Source 
@spec messaging_system() :: :"messaging.system"

The messaging system as identified by the client instrumentation.

Notes

The actual messaging system may differ from the one known by the client. For example, when using Kafka client libraries to communicate with Azure Event Hubs, the messaging.system is set to kafka based on the instrumentation's best knowledge.

iex> OpenTelemetry.SemConv.Incubating.MessagingAttributes.messaging_system()
:"messaging.system"

iex> OpenTelemetry.SemConv.Incubating.MessagingAttributes.messaging_system_values().activemq
:activemq

iex> %{OpenTelemetry.SemConv.Incubating.MessagingAttributes.messaging_system() => OpenTelemetry.SemConv.Incubating.MessagingAttributes.messaging_system_values().activemq}
%{:"messaging.system" => :activemq}
Link to this function

messaging_system_values()

View Source 
@spec messaging_system_values() :: messaging_system_values()