func init()

in plugin/connector/rocketmq/constants/rocketmq_message_properties.go [25:61]

• 37 lines of code
• 1 McCabe index (conditional complexity)

func init() {
	RocketMQMessageProperties = gs.NewSet[string]()
	RocketMQMessageProperties.Add(" ")
	RocketMQMessageProperties.Add("KEYS")
	RocketMQMessageProperties.Add("TAGS")
	RocketMQMessageProperties.Add("WAIT")
	RocketMQMessageProperties.Add("DELAY")
	RocketMQMessageProperties.Add("RETRY_TOPIC")
	RocketMQMessageProperties.Add("REAL_TOPIC")
	RocketMQMessageProperties.Add("REAL_QID")
	RocketMQMessageProperties.Add("TRAN_MSG")
	RocketMQMessageProperties.Add("PGROUP")
	RocketMQMessageProperties.Add("MIN_OFFSET")
	RocketMQMessageProperties.Add("MAX_OFFSET")
	RocketMQMessageProperties.Add("BUYER_ID")
	RocketMQMessageProperties.Add("ORIGIN_MESSAGE_ID")
	RocketMQMessageProperties.Add("TRANSFER_FLAG")
	RocketMQMessageProperties.Add("CORRECTION_FLAG")
	RocketMQMessageProperties.Add("MQ2_FLAG")
	RocketMQMessageProperties.Add("RECONSUME_TIME")
	RocketMQMessageProperties.Add("MSG_REGION")
	RocketMQMessageProperties.Add("TRACE_ON")
	RocketMQMessageProperties.Add("UNIQ_KEY")
	RocketMQMessageProperties.Add("MAX_RECONSUME_TIMES")
	RocketMQMessageProperties.Add("CONSUME_START_TIME")
	RocketMQMessageProperties.Add("TRAN_PREPARED_QUEUE_OFFSET")
	RocketMQMessageProperties.Add("TRANSACTION_CHECK_TIMES")
	RocketMQMessageProperties.Add("CHECK_IMMUNITY_TIME_IN_SECONDS")
	RocketMQMessageProperties.Add("SHARDING_KEY")
	RocketMQMessageProperties.Add("__transactionId__")
	RocketMQMessageProperties.Add("CORRELATION_ID")
	RocketMQMessageProperties.Add("REPLY_TO_CLIENT")
	RocketMQMessageProperties.Add("TTL")
	RocketMQMessageProperties.Add("ARRIVE_TIME")
	RocketMQMessageProperties.Add("MSG_TYPE")
	RocketMQMessageProperties.Add("CLUSTER")
}