From 977c8e78305e4aa911e7f75a2322cb16ffe37bee Mon Sep 17 00:00:00 2001
From: chrislu <chris.lu@gmail.com>
Date: Sun, 18 Sep 2022 16:49:10 -0700
Subject: [PATCH] add todo

---
 weed/mq/message_buffer/message_buffer.go | 5 +++++
 1 file changed, 5 insertions(+)
 create mode 100644 weed/mq/message_buffer/message_buffer.go

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
+}