修改配置bug

framework/core/infrastructure/message_queue/mqtt/mqtt.go

@@ -28,7 +28,6 @@ func New(address string, userName string, password string) (*MessageQueue, error
 		AddBroker(address).
 		SetClientID(clientID).
 		SetOrderMatters(false).
-		SetAutoAckDisabled(true).
 		SetWill(clientID+"/will", "dead", 2, true))
 
 	token := mqttClient.Connect()
@@ -87,8 +86,6 @@ func (messageQueue *MessageQueue) Subscribe(group string, topic string, handler
 				}
 			}()
 		}
-
-		message.Ack()
 	})
 
 	if !token.WaitTimeout(20 * time.Second) {

test/message_queue_test.go

@@ -120,12 +120,6 @@ func testMqttMessageQueue(t *testing.T, mqttMessageQueue *mqtt.MessageQueue) {
 	wg := sync.WaitGroup{}
 	wg.Add(2)
 
-	//err := mqttMessageQueue.Publish("test-mqtt",
-	//	data_protocol.NewCloudEvent("1", "test", "baize-test.com", "application/text", []byte("test-message")))
-	//if err != nil {
-	//	t.Fatalf("%+v\n", err)
-	//}
-
 	err := mqttMessageQueue.Subscribe("test1", "test-mqtt",
 		func(queue common.MessageQueue, topic string, event *data_protocol.CloudEvent) error {
 			if event.ID != "1" {