1 files changed, 11 insertions, 0 deletions
diff --git a/weed/msgqueue/message_queue.go b/weed/msgqueue/message_queue.go
new file mode 100644
index 000000000..6d57b9b3b
--- /dev/null
+++ b/weed/msgqueue/message_queue.go
@@ -0,0 +1,11 @@
+package msgqueue
+
+import "github.com/golang/protobuf/proto"
+
+type MessageQueue interface {
+	// GetName gets the name to locate the configuration in message_queue.toml file
+	GetName() string
+	// Initialize initializes the file store
+	Initialize(configuration Configuration) error
+	SendMessage(key string, message proto.Message) error
+}