diff --git a/pkg/cache/type.go b/pkg/cache/type.go
index 5327760e..e5844c9f 100644
--- a/pkg/cache/type.go
+++ b/pkg/cache/type.go
@@ -17,8 +17,8 @@ type Adapter interface {
 	GetQueue(name string, f func(message Message) error)
 }
 
-type Message struct {
-	ID     string
-	Stream string
-	Values map[string]interface{}
+type Message interface {
+	SetID(string)
+	SetStream(string)
+	SetValue(map[string]interface{})
 }