path: root/weed/mq/message_buffer/message_buffer.go

package message_buffer

type MessagePipeline struct {
	//TODO refactor weed/mq/client/publish_stream_processor.go
}