diff options
| author | Chris Lu <chris.lu@gmail.com> | 2020-04-19 23:37:04 -0700 |
|---|---|---|
| committer | Chris Lu <chris.lu@gmail.com> | 2020-04-19 23:37:50 -0700 |
| commit | ce3cb25cfbf30a06348386210f72cc51c3fbd13a (patch) | |
| tree | 217836bc07221d97a180f7f2fba41dd51ddb3eae /weed/messaging/client | |
| parent | f37323222751c104723273293a0b15b209021f32 (diff) | |
| download | seaweedfs-ce3cb25cfbf30a06348386210f72cc51c3fbd13a.tar.xz seaweedfs-ce3cb25cfbf30a06348386210f72cc51c3fbd13a.zip | |
working for in memory single log buffer
Diffstat (limited to 'weed/messaging/client')
| -rw-r--r-- | weed/messaging/client/publisher.go | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/weed/messaging/client/publisher.go b/weed/messaging/client/publisher.go index 238b67783..3480ff55d 100644 --- a/weed/messaging/client/publisher.go +++ b/weed/messaging/client/publisher.go @@ -61,7 +61,7 @@ func (mc *MessagingClient) NewPublisher(namespace, topic string) (*Publisher, er }, nil } -func (p *Publisher) Publish(m *messaging_pb.RawData) error { +func (p *Publisher) Publish(m *messaging_pb.Message) error { return p.publishClient.Send(&messaging_pb.PublishRequest{ Data: m, |