diff options
Diffstat (limited to 'weed/mq/broker/brokder_grpc_pub.go')
| -rw-r--r-- | weed/mq/broker/brokder_grpc_pub.go | 16 |
1 files changed, 16 insertions, 0 deletions
diff --git a/weed/mq/broker/brokder_grpc_pub.go b/weed/mq/broker/brokder_grpc_pub.go new file mode 100644 index 000000000..a26be5171 --- /dev/null +++ b/weed/mq/broker/brokder_grpc_pub.go @@ -0,0 +1,16 @@ +package broker + +import ( + "github.com/seaweedfs/seaweedfs/weed/pb/mq_pb" +) + +/* +The messages is buffered in memory, and saved to filer under + /topics/<topic>/<date>/<hour>/<segment>/*.msg + /topics/<topic>/<date>/<hour>/segment + /topics/<topic>/info/segment_<id>.meta +*/ + +func (broker *MessageQueueBroker) Publish(stream mq_pb.SeaweedMessaging_PublishServer) error { + return nil +} |