weed/messaging/client/publisher.go


1
2
3
4
5
6
7
8
9
10
11
12
13
14

package client

import "github.com/chrislusf/seaweedfs/weed/pb/messaging_pb"

type Publisher struct {
}

func (c *MessagingClient) NewPublisher(namespace, topic string) *Publisher {
	return &Publisher{}
}

func (p *Publisher) Publish(m *messaging_pb.RawData) error{
	return nil
}