@ -1,5 +0,0 @@
package message_buffer
type MessagePipeline struct {
//TODO refactor weed/mq/client/publish_stream_processor.go
}