weed/messaging/client/subscriber.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 Subscriber struct {
}

func (c *MessagingClient) NewSubscriber(namespace, topic string) *Subscriber {
	return &Subscriber{}
}

func (p *Subscriber) Subscribe(processFn func(m *messaging_pb.Message)) error{
	return nil
}