diff --git a/pkgs/mq/client/agent/agent.go b/pkgs/mq/client/agent/agent.go
index 0434faf..e5c8991 100644
--- a/pkgs/mq/client/agent/agent.go
+++ b/pkgs/mq/client/agent/agent.go
@@ -1,7 +1,7 @@
 package agent
 
 import (
-	"gitlink.org.cn/cloudream/common/pkg/mq"
+	"gitlink.org.cn/cloudream/common/pkgs/mq"
 	agtmsg "gitlink.org.cn/cloudream/storage-common/pkgs/mq/message/agent"
 )
 
diff --git a/pkgs/mq/client/agent/client.go b/pkgs/mq/client/agent/client.go
index 18e1bbb..4ed0119 100644
--- a/pkgs/mq/client/agent/client.go
+++ b/pkgs/mq/client/agent/client.go
@@ -1,7 +1,7 @@
 package agent
 
 import (
-	"gitlink.org.cn/cloudream/common/pkg/mq"
+	"gitlink.org.cn/cloudream/common/pkgs/mq"
 	mymq "gitlink.org.cn/cloudream/storage-common/pkgs/mq"
 	"gitlink.org.cn/cloudream/storage-common/pkgs/mq/config"
 )
diff --git a/pkgs/mq/client/agent/ipfs.go b/pkgs/mq/client/agent/ipfs.go
index dae648b..22bbc61 100644
--- a/pkgs/mq/client/agent/ipfs.go
+++ b/pkgs/mq/client/agent/ipfs.go
@@ -1,7 +1,7 @@
 package agent
 
 import (
-	"gitlink.org.cn/cloudream/common/pkg/mq"
+	"gitlink.org.cn/cloudream/common/pkgs/mq"
 	agtmsg "gitlink.org.cn/cloudream/storage-common/pkgs/mq/message/agent"
 )
 
diff --git a/pkgs/mq/client/agent/object.go b/pkgs/mq/client/agent/object.go
index 300e05e..933056a 100644
--- a/pkgs/mq/client/agent/object.go
+++ b/pkgs/mq/client/agent/object.go
@@ -1,7 +1,7 @@
 package agent
 
 import (
-	"gitlink.org.cn/cloudream/common/pkg/mq"
+	"gitlink.org.cn/cloudream/common/pkgs/mq"
 	agtmsg "gitlink.org.cn/cloudream/storage-common/pkgs/mq/message/agent"
 )
 
diff --git a/pkgs/mq/client/agent/storage.go b/pkgs/mq/client/agent/storage.go
index 628f59c..87d57ae 100644
--- a/pkgs/mq/client/agent/storage.go
+++ b/pkgs/mq/client/agent/storage.go
@@ -1,7 +1,7 @@
 package agent
 
 import (
-	"gitlink.org.cn/cloudream/common/pkg/mq"
+	"gitlink.org.cn/cloudream/common/pkgs/mq"
 	agtmsg "gitlink.org.cn/cloudream/storage-common/pkgs/mq/message/agent"
 )
 
diff --git a/pkgs/mq/client/coordinator/agent.go b/pkgs/mq/client/coordinator/agent.go
index 3ee13b6..542a507 100644
--- a/pkgs/mq/client/coordinator/agent.go
+++ b/pkgs/mq/client/coordinator/agent.go
@@ -1,7 +1,7 @@
 package coordinator
 
 import (
-	"gitlink.org.cn/cloudream/common/pkg/mq"
+	"gitlink.org.cn/cloudream/common/pkgs/mq"
 	coormsg "gitlink.org.cn/cloudream/storage-common/pkgs/mq/message/coordinator"
 )
 
diff --git a/pkgs/mq/client/coordinator/bucket.go b/pkgs/mq/client/coordinator/bucket.go
index 2dcbb9c..b78de89 100644
--- a/pkgs/mq/client/coordinator/bucket.go
+++ b/pkgs/mq/client/coordinator/bucket.go
@@ -1,7 +1,7 @@
 package coordinator
 
 import (
-	"gitlink.org.cn/cloudream/common/pkg/mq"
+	"gitlink.org.cn/cloudream/common/pkgs/mq"
 	coormsg "gitlink.org.cn/cloudream/storage-common/pkgs/mq/message/coordinator"
 )
 
diff --git a/pkgs/mq/client/coordinator/client.go b/pkgs/mq/client/coordinator/client.go
index 3b406d7..03afaeb 100644
--- a/pkgs/mq/client/coordinator/client.go
+++ b/pkgs/mq/client/coordinator/client.go
@@ -1,7 +1,7 @@
 package coordinator
 
 import (
-	"gitlink.org.cn/cloudream/common/pkg/mq"
+	"gitlink.org.cn/cloudream/common/pkgs/mq"
 	mymq "gitlink.org.cn/cloudream/storage-common/pkgs/mq"
 	"gitlink.org.cn/cloudream/storage-common/pkgs/mq/config"
 )
diff --git a/pkgs/mq/client/coordinator/object.go b/pkgs/mq/client/coordinator/object.go
index b5aa2e9..b2ca061 100644
--- a/pkgs/mq/client/coordinator/object.go
+++ b/pkgs/mq/client/coordinator/object.go
@@ -1,7 +1,7 @@
 package coordinator
 
 import (
-	"gitlink.org.cn/cloudream/common/pkg/mq"
+	"gitlink.org.cn/cloudream/common/pkgs/mq"
 	coormsg "gitlink.org.cn/cloudream/storage-common/pkgs/mq/message/coordinator"
 )
 
diff --git a/pkgs/mq/client/coordinator/storage.go b/pkgs/mq/client/coordinator/storage.go
index 6db11a2..c816664 100644
--- a/pkgs/mq/client/coordinator/storage.go
+++ b/pkgs/mq/client/coordinator/storage.go
@@ -1,7 +1,7 @@
 package coordinator
 
 import (
-	"gitlink.org.cn/cloudream/common/pkg/mq"
+	"gitlink.org.cn/cloudream/common/pkgs/mq"
 	coormsg "gitlink.org.cn/cloudream/storage-common/pkgs/mq/message/coordinator"
 )
 
diff --git a/pkgs/mq/client/scanner/client.go b/pkgs/mq/client/scanner/client.go
index e610a96..8962a19 100644
--- a/pkgs/mq/client/scanner/client.go
+++ b/pkgs/mq/client/scanner/client.go
@@ -1,7 +1,7 @@
 package scanner
 
 import (
-	"gitlink.org.cn/cloudream/common/pkg/mq"
+	"gitlink.org.cn/cloudream/common/pkgs/mq"
 	mymq "gitlink.org.cn/cloudream/storage-common/pkgs/mq"
 	"gitlink.org.cn/cloudream/storage-common/pkgs/mq/config"
 )
diff --git a/pkgs/mq/client/scanner/event.go b/pkgs/mq/client/scanner/event.go
index 2af3eca..c2942b0 100644
--- a/pkgs/mq/client/scanner/event.go
+++ b/pkgs/mq/client/scanner/event.go
@@ -4,7 +4,7 @@ import (
 	"fmt"
 	"time"
 
-	"gitlink.org.cn/cloudream/common/pkg/mq"
+	"gitlink.org.cn/cloudream/common/pkgs/mq"
 	scmsg "gitlink.org.cn/cloudream/storage-common/pkgs/mq/message/scanner"
 )
 
diff --git a/pkgs/mq/message/agent/agent.go b/pkgs/mq/message/agent/agent.go
index f0a1c7c..b78f33f 100644
--- a/pkgs/mq/message/agent/agent.go
+++ b/pkgs/mq/message/agent/agent.go
@@ -1,7 +1,7 @@
 package agent
 
 import (
-	"gitlink.org.cn/cloudream/common/pkg/mq"
+	"gitlink.org.cn/cloudream/common/pkgs/mq"
 )
 
 type GetState struct {
diff --git a/pkgs/mq/message/agent/ipfs.go b/pkgs/mq/message/agent/ipfs.go
index 0143220..eb917fa 100644
--- a/pkgs/mq/message/agent/ipfs.go
+++ b/pkgs/mq/message/agent/ipfs.go
@@ -1,7 +1,7 @@
 package agent
 
 import (
-	"gitlink.org.cn/cloudream/common/pkg/mq"
+	"gitlink.org.cn/cloudream/common/pkgs/mq"
 	"gitlink.org.cn/cloudream/storage-common/pkgs/db/model"
 )
 
diff --git a/pkgs/mq/message/agent/object.go b/pkgs/mq/message/agent/object.go
index 8e5eb90..f06cf10 100644
--- a/pkgs/mq/message/agent/object.go
+++ b/pkgs/mq/message/agent/object.go
@@ -1,6 +1,6 @@
 package agent
 
-import "gitlink.org.cn/cloudream/common/pkg/mq"
+import "gitlink.org.cn/cloudream/common/pkgs/mq"
 
 type StartPinningObject struct {
 	FileHash string `json:"fileHash"`
diff --git a/pkgs/mq/message/agent/storage.go b/pkgs/mq/message/agent/storage.go
index 5246970..0629afa 100644
--- a/pkgs/mq/message/agent/storage.go
+++ b/pkgs/mq/message/agent/storage.go
@@ -1,7 +1,7 @@
 package agent
 
 import (
-	"gitlink.org.cn/cloudream/common/pkg/mq"
+	"gitlink.org.cn/cloudream/common/pkgs/mq"
 	"gitlink.org.cn/cloudream/storage-common/models"
 	"gitlink.org.cn/cloudream/storage-common/pkgs/db/model"
 )
diff --git a/pkgs/mq/message/coordinator/agent.go b/pkgs/mq/message/coordinator/agent.go
index 72920ee..2ea6fa7 100644
--- a/pkgs/mq/message/coordinator/agent.go
+++ b/pkgs/mq/message/coordinator/agent.go
@@ -1,6 +1,6 @@
 package coordinator
 
-import "gitlink.org.cn/cloudream/common/pkg/mq"
+import "gitlink.org.cn/cloudream/common/pkgs/mq"
 
 // 代理端发给协调端，告知临时缓存的数据
 type TempCacheReport struct {
diff --git a/pkgs/mq/message/coordinator/bucket.go b/pkgs/mq/message/coordinator/bucket.go
index aed1ba2..40751dc 100644
--- a/pkgs/mq/message/coordinator/bucket.go
+++ b/pkgs/mq/message/coordinator/bucket.go
@@ -1,7 +1,7 @@
 package coordinator
 
 import (
-	"gitlink.org.cn/cloudream/common/pkg/mq"
+	"gitlink.org.cn/cloudream/common/pkgs/mq"
 	"gitlink.org.cn/cloudream/storage-common/pkgs/db/model"
 )
 
diff --git a/pkgs/mq/message/coordinator/coordinator_test.go b/pkgs/mq/message/coordinator/coordinator_test.go
index 41f8f38..57b6ed1 100644
--- a/pkgs/mq/message/coordinator/coordinator_test.go
+++ b/pkgs/mq/message/coordinator/coordinator_test.go
@@ -4,7 +4,7 @@ import (
 	"testing"
 
 	. "github.com/smartystreets/goconvey/convey"
-	"gitlink.org.cn/cloudream/common/pkg/mq"
+	"gitlink.org.cn/cloudream/common/pkgs/mq"
 )
 
 func TestSerder(t *testing.T) {
diff --git a/pkgs/mq/message/coordinator/object.go b/pkgs/mq/message/coordinator/object.go
index 6b82d50..8629d80 100644
--- a/pkgs/mq/message/coordinator/object.go
+++ b/pkgs/mq/message/coordinator/object.go
@@ -1,7 +1,7 @@
 package coordinator
 
 import (
-	"gitlink.org.cn/cloudream/common/pkg/mq"
+	"gitlink.org.cn/cloudream/common/pkgs/mq"
 	"gitlink.org.cn/cloudream/storage-common/pkgs/db/model"
 	ramsg "gitlink.org.cn/cloudream/storage-common/pkgs/mq/message"
 )
diff --git a/pkgs/mq/message/coordinator/storage.go b/pkgs/mq/message/coordinator/storage.go
index 881e17b..809a312 100644
--- a/pkgs/mq/message/coordinator/storage.go
+++ b/pkgs/mq/message/coordinator/storage.go
@@ -1,7 +1,7 @@
 package coordinator
 
 import (
-	"gitlink.org.cn/cloudream/common/pkg/mq"
+	"gitlink.org.cn/cloudream/common/pkgs/mq"
 	"gitlink.org.cn/cloudream/storage-common/models"
 	"gitlink.org.cn/cloudream/storage-common/pkgs/db/model"
 )
diff --git a/pkgs/mq/message/publics.go b/pkgs/mq/message/publics.go
index cbc6fdd..bfe2fd2 100644
--- a/pkgs/mq/message/publics.go
+++ b/pkgs/mq/message/publics.go
@@ -2,7 +2,7 @@ package message
 
 import (
 	"gitlink.org.cn/cloudream/common/models"
-	"gitlink.org.cn/cloudream/common/pkg/mq"
+	"gitlink.org.cn/cloudream/common/pkgs/mq"
 	myreflect "gitlink.org.cn/cloudream/common/utils/reflect"
 	mymodels "gitlink.org.cn/cloudream/storage-common/models"
 )
diff --git a/pkgs/mq/message/scanner/event.go b/pkgs/mq/message/scanner/event.go
index c951dd7..81b806c 100644
--- a/pkgs/mq/message/scanner/event.go
+++ b/pkgs/mq/message/scanner/event.go
@@ -3,7 +3,7 @@ package scanner
 import (
 	"fmt"
 
-	"gitlink.org.cn/cloudream/common/pkg/mq"
+	"gitlink.org.cn/cloudream/common/pkgs/mq"
 	scevt "gitlink.org.cn/cloudream/storage-common/pkgs/mq/message/scanner/event"
 )
 
diff --git a/pkgs/mq/server/agent/agent.go b/pkgs/mq/server/agent/agent.go
index 0c67809..b434143 100644
--- a/pkgs/mq/server/agent/agent.go
+++ b/pkgs/mq/server/agent/agent.go
@@ -1,7 +1,7 @@
 package agent
 
 import (
-	"gitlink.org.cn/cloudream/common/pkg/mq"
+	"gitlink.org.cn/cloudream/common/pkgs/mq"
 	agtmsg "gitlink.org.cn/cloudream/storage-common/pkgs/mq/message/agent"
 )
 
diff --git a/pkgs/mq/server/agent/ipfs.go b/pkgs/mq/server/agent/ipfs.go
index 3ee2dd1..09da2f5 100644
--- a/pkgs/mq/server/agent/ipfs.go
+++ b/pkgs/mq/server/agent/ipfs.go
@@ -1,7 +1,7 @@
 package agent
 
 import (
-	"gitlink.org.cn/cloudream/common/pkg/mq"
+	"gitlink.org.cn/cloudream/common/pkgs/mq"
 	agtmsg "gitlink.org.cn/cloudream/storage-common/pkgs/mq/message/agent"
 )
 
diff --git a/pkgs/mq/server/agent/object.go b/pkgs/mq/server/agent/object.go
index cf06966..a600566 100644
--- a/pkgs/mq/server/agent/object.go
+++ b/pkgs/mq/server/agent/object.go
@@ -1,7 +1,7 @@
 package agent
 
 import (
-	"gitlink.org.cn/cloudream/common/pkg/mq"
+	"gitlink.org.cn/cloudream/common/pkgs/mq"
 	agtmsg "gitlink.org.cn/cloudream/storage-common/pkgs/mq/message/agent"
 )
 
diff --git a/pkgs/mq/server/agent/server.go b/pkgs/mq/server/agent/server.go
index b0e458f..285d560 100644
--- a/pkgs/mq/server/agent/server.go
+++ b/pkgs/mq/server/agent/server.go
@@ -1,7 +1,7 @@
 package agent
 
 import (
-	"gitlink.org.cn/cloudream/common/pkg/mq"
+	"gitlink.org.cn/cloudream/common/pkgs/mq"
 	mymq "gitlink.org.cn/cloudream/storage-common/pkgs/mq"
 	"gitlink.org.cn/cloudream/storage-common/pkgs/mq/config"
 )
diff --git a/pkgs/mq/server/agent/storage.go b/pkgs/mq/server/agent/storage.go
index 0f581e0..85aea61 100644
--- a/pkgs/mq/server/agent/storage.go
+++ b/pkgs/mq/server/agent/storage.go
@@ -1,7 +1,7 @@
 package agent
 
 import (
-	"gitlink.org.cn/cloudream/common/pkg/mq"
+	"gitlink.org.cn/cloudream/common/pkgs/mq"
 	agtmsg "gitlink.org.cn/cloudream/storage-common/pkgs/mq/message/agent"
 )
 
diff --git a/pkgs/mq/server/coordinator/bucket.go b/pkgs/mq/server/coordinator/bucket.go
index e44c9fa..be68c6a 100644
--- a/pkgs/mq/server/coordinator/bucket.go
+++ b/pkgs/mq/server/coordinator/bucket.go
@@ -1,7 +1,7 @@
 package coordinator
 
 import (
-	"gitlink.org.cn/cloudream/common/pkg/mq"
+	"gitlink.org.cn/cloudream/common/pkgs/mq"
 	coormsg "gitlink.org.cn/cloudream/storage-common/pkgs/mq/message/coordinator"
 )
 
diff --git a/pkgs/mq/server/coordinator/object.go b/pkgs/mq/server/coordinator/object.go
index c62e422..b76758d 100644
--- a/pkgs/mq/server/coordinator/object.go
+++ b/pkgs/mq/server/coordinator/object.go
@@ -1,7 +1,7 @@
 package coordinator
 
 import (
-	"gitlink.org.cn/cloudream/common/pkg/mq"
+	"gitlink.org.cn/cloudream/common/pkgs/mq"
 	coormsg "gitlink.org.cn/cloudream/storage-common/pkgs/mq/message/coordinator"
 )
 
diff --git a/pkgs/mq/server/coordinator/server.go b/pkgs/mq/server/coordinator/server.go
index eeb48aa..16ee076 100644
--- a/pkgs/mq/server/coordinator/server.go
+++ b/pkgs/mq/server/coordinator/server.go
@@ -1,7 +1,7 @@
 package coordinator
 
 import (
-	"gitlink.org.cn/cloudream/common/pkg/mq"
+	"gitlink.org.cn/cloudream/common/pkgs/mq"
 	mymq "gitlink.org.cn/cloudream/storage-common/pkgs/mq"
 	"gitlink.org.cn/cloudream/storage-common/pkgs/mq/config"
 )
diff --git a/pkgs/mq/server/coordinator/storage.go b/pkgs/mq/server/coordinator/storage.go
index b38433e..5e7f1a6 100644
--- a/pkgs/mq/server/coordinator/storage.go
+++ b/pkgs/mq/server/coordinator/storage.go
@@ -1,7 +1,7 @@
 package coordinator
 
 import (
-	"gitlink.org.cn/cloudream/common/pkg/mq"
+	"gitlink.org.cn/cloudream/common/pkgs/mq"
 	coormsg "gitlink.org.cn/cloudream/storage-common/pkgs/mq/message/coordinator"
 )
 
diff --git a/pkgs/mq/server/scanner/server.go b/pkgs/mq/server/scanner/server.go
index a4bcb76..537dad5 100644
--- a/pkgs/mq/server/scanner/server.go
+++ b/pkgs/mq/server/scanner/server.go
@@ -1,7 +1,7 @@
 package scanner
 
 import (
-	"gitlink.org.cn/cloudream/common/pkg/mq"
+	"gitlink.org.cn/cloudream/common/pkgs/mq"
 	mymq "gitlink.org.cn/cloudream/storage-common/pkgs/mq"
 	"gitlink.org.cn/cloudream/storage-common/pkgs/mq/config"
 )