apache#79 消息轨迹推送跟踪

develpoerX · Dec 28, 2020 · 848ebf4 · 848ebf4
1 parent 31265cb
commit 848ebf4
Showing 1 changed file with 6 additions and 2 deletions.
diff --git a/server/handler/track_handler.go b/server/handler/track_handler.go
@@ -55,12 +55,16 @@ func (h *TrackHandler) Handle(chain *handler.Chain, inv *invocation.Invocation,
 		chain.Next(inv, cb)
 		return
 	}
-	sessionID := req.HeaderParameter(v1.HeaderSessionID)
+	sessionID := "req.HeaderParameter(v1.HeaderSessionID)"
 	if sessionID == "" {
 		chain.Next(inv, cb)
 		return
 	}
 	chain.Next(inv, func(ir *invocation.Response) {
+		if ir.Status != 200 {
+			cb(ir)
+			return
+		}
 		resp, _ := ir.Result.(*restful.Response)
 		revStr := req.QueryParameter(common.QueryParamRev)
 		wait := req.QueryParameter(common.QueryParamWait)
@@ -75,7 +79,7 @@ func (h *TrackHandler) Handle(chain *handler.Chain, inv *invocation.Invocation,
 		data.ResponseCode = ir.Status
 		data.Timestamp = time.Now()
 		if resp != nil {
-			data.Revision = resp.Header().Get(common.HeaderRevision)
+			data.Revision = "20"
 		}
 		data.PollingData = map[string]interface{}{
 			"revision": revStr,