diff --git a/dtmsvr/cron.go b/dtmsvr/cron.go
index 14600de..4318102 100644
--- a/dtmsvr/cron.go
+++ b/dtmsvr/cron.go
@@ -16,7 +16,9 @@ func CronTransOnce(expireIn time.Duration) bool {
 	if trans == nil {
 		return false
 	}
-	defer WaitTransProcessed(trans.Gid)
+	if TransProcessedTestChan != nil {
+		defer WaitTransProcessed(trans.Gid)
+	}
 	trans.Process(dbGet())
 	return true
 }
diff --git a/dtmsvr/utils.go b/dtmsvr/utils.go
index a552ba2..ad87dcd 100644
--- a/dtmsvr/utils.go
+++ b/dtmsvr/utils.go
@@ -38,9 +38,6 @@ var TransProcessedTestChan chan string = nil
 
 // WaitTransProcessed only for test usage. wait for transaction processed once
 func WaitTransProcessed(gid string) {
-	if TransProcessedTestChan == nil {
-		return
-	}
 	logrus.Printf("waiting for gid %s", gid)
 	id := <-TransProcessedTestChan
 	for id != gid {