diff --git a/weed/mq/message_buffer/message_buffer.go b/weed/mq/message_buffer/message_buffer.go
new file mode 100644
index 000000000..27e457def
--- /dev/null
+++ b/weed/mq/message_buffer/message_buffer.go
@@ -0,0 +1,5 @@
+package message_buffer
+
+type MessagePipeline struct {
+	//TODO refactor weed/mq/client/publish_stream_processor.go
+}