pop add topic

Author: zouyi

build.sh

@@ -5,7 +5,7 @@ if [[ `uname -s` == "Darwin" ]]; then
     CGO_ENABLED=0 GOOS=windows GOARCH=amd64 go build -ldflags '-w' -o dist/delay-queue-win-64
     go build -ldflags '-w' -o dist/delay-queue-macos-64
 else
-    echo "system is macos"
+    echo "system is linux"
     CGO_ENABLED=0 GOOS=macos GOARCH=amd64 go build -ldflags '-w' -o dist/delay-queue-linux-64
     CGO_ENABLED=0 GOOS=windows GOARCH=amd64 go build -ldflags '-w' -o dist/delay-queue-win-64
     go build -ldflags '-w' -o dist/delay-queue-macos-64

delayqueue/delay_queue.go

@@ -143,7 +143,7 @@ func initTimers() {
 	var bucketName string
 	for i := 0; i < config.Setting.BucketSize; i++ {
 
-		 // 每 1s 执行一次
+		// 每 1s 执行一次
 		timers[i] = time.NewTicker(1 * time.Second)
 
 		// 如果这里部署多实例的话，就会产生竞争

delayqueue/job.go

@@ -10,8 +10,8 @@ type Job struct {
 	Topic string `json:"topic" msgpack:"1"` // topic ，唯一
 	Id    string `json:"id" msgpack:"2"`    // job唯一标识ID 。客户端需要保证唯一性。有关联关系的
 	Delay int64  `json:"delay" msgpack:"3"` // 延迟时间, unix时间戳
-	TTR   int64  `json:"ttr" msgpack:"4"` // 超时时间,TTR的设计目的是为了保证消息传输的可靠性。
-	Body  string `json:"body" msgpack:"5"`// body
+	TTR   int64  `json:"ttr" msgpack:"4"`   // 超时时间,TTR的设计目的是为了保证消息传输的可靠性。
+	Body  string `json:"body" msgpack:"5"`  // body
 }
 
 // 获取Job

dist/delay-queue-linux-64

@@ -90,12 +90,14 @@ func Pop(resp http.ResponseWriter, req *http.Request) {
 	}
 
 	type Data struct {
+        Topic string `json:"topic"`
 		Id   string `json:"id"`
 		Body string `json:"body"`
 	}
 
 	data := Data{
 		Id:   job.Id,
+        Topic: job.Topic,
 		Body: job.Body,
 	}