按照样例写运行之后直接退出 about aliyun-mns HOT 3 CLOSED

for {
    c.Run()
}

package main

import (
	"log"

	"github.com/xiaojiaoyu100/aliyun-mns"
)

func HandleExample(rm *aliyun_mns.ReceiveMessage) error {
	log.Println(rm.MessageBody)
	return nil
}

func main() {
	aliyun_mns.QuickDebug()
	c := aliyun_mns.New(
		endpoint,
		accessKeyId,
		accessKeySecret)
	c.AddQueue(&aliyun_mns.Queue{
		Name:     "example",
		Parallel: 2,
		QueueAttributeSetters: []aliyun_mns.QueueAttributeSetter{
			aliyun_mns.WithDelaySeconds(10)},
		OnReceive: HandleExample,
	})
	c.Run()
	
	done := make(chan bool)
	<-done
}