config

Documentation

Index

• type ClientConfig

Types

type ClientConfig

type ClientConfig struct {
	// AccessPoints addresses of rocketmq name servers, join by ";"
	AccessPoints string `json:"access_points"`
	// Namespace client namespace
	Namespace string `json:"namespace"`
	// InstanceName client instance name
	InstanceName string `json:"instance_name"`
	// ProducerGroupName producer client group name
	ProducerGroupName string `json:"group_name"`
	// SendMsgTimeout producer send message timeout (ms), default 3000ms
	SendMsgTimeout string `json:"send_msg_timeout"`
	// ProducerRetryTimes producer retry time
	ProducerRetryTimes string `json:"producer_retry_times"`
	// CompressMsgBodyThreshold producer compress message body threshold
	CompressMsgBodyThreshold string `json:"compress_msg_body_threshold"`

	// ConsumerGroup consumer group
	ConsumerGroup string `json:"consumer_group"`
	// MaxReconsumeTimes max reconsume times
	MaxReconsumeTimes string `json:"max_reconsume_times"`
	// MessageModel message model of consumer, can be BROADCASTING or CLUSTERING
	MessageModel string `json:"message_model"`
}

ClientConfig config of RocketMQ client