[fix][backend]Fix mq compression bug. (#324)

taoyifan89 · web-flow · commit 0ebf3d311095 · 2025-12-03T11:02:25.000+08:00
Fix mq compression bug.

Change-Id: I7a1e90ba1c4379a23ca8b6034cced1b3330ea5e3
diff --git a/backend/infra/mq/rocketmq/factory.go b/backend/infra/mq/rocketmq/factory.go
@@ -37,9 +37,6 @@ func (f *Factory) NewProducer(config mq.ProducerConfig) (mq.IProducer, error) {
 	if config.RetryTimes > 0 {
 		opts = append(opts, producer.WithRetry(config.RetryTimes))
 	}
-	if config.Compression != mq.CompressionNone {
-		return nil, errors.New("compression not supported")
-	}
 	if config.ProducerGroup != nil {
 		opts = append(opts, producer.WithGroupName(*config.ProducerGroup))
 	}

Original file line number	Diff line number	Diff line change
`@@ -37,9 +37,6 @@ func (f *Factory) NewProducer(config mq.ProducerConfig) (mq.IProducer, error) {`
`37`	`37`	`if config.RetryTimes > 0 {`
`38`	`38`	`opts = append(opts, producer.WithRetry(config.RetryTimes))`
`39`	`39`	`}`
`40`		`- if config.Compression != mq.CompressionNone {`
`41`		`- return nil, errors.New("compression not supported")`
`42`		`- }`
`43`	`40`	`if config.ProducerGroup != nil {`
`44`	`41`	`opts = append(opts, producer.WithGroupName(*config.ProducerGroup))`
`45`	`42`	`}`