diff options
Diffstat (limited to 'weed/messaging/broker_append.go')
| -rw-r--r-- | weed/messaging/broker_append.go | 3 |
1 files changed, 0 insertions, 3 deletions
diff --git a/weed/messaging/broker_append.go b/weed/messaging/broker_append.go index 07b3755c0..a0c0e8614 100644 --- a/weed/messaging/broker_append.go +++ b/weed/messaging/broker_append.go @@ -58,7 +58,6 @@ func (broker *MessageBroker) appendToFile(targetFile string, topicConfig *messag func (broker *MessageBroker) assignAndUpload(topicConfig *messaging_pb.TopicConfiguration, data []byte) (*operation.AssignResult, *operation.UploadResult, error) { var assignResult = &operation.AssignResult{} - var collection, replication string // assign a volume location if err := broker.WithFilerClient(func(client filer_pb.SeaweedFilerClient) error { @@ -84,8 +83,6 @@ func (broker *MessageBroker) assignAndUpload(topicConfig *messaging_pb.TopicConf assignResult.PublicUrl = resp.PublicUrl assignResult.Count = uint64(resp.Count) - collection, replication = resp.Collection, resp.Replication - return nil }); err != nil { return nil, nil, err |