add todo

2 years ago · 977c8e7830
1 changed files with 5 additions and 0 deletions
--- a/weed/mq/message_buffer/message_buffer.go
+++ 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
+}