diff options
| author | Chris Lu <chris.lu@gmail.com> | 2020-04-16 02:55:09 -0700 |
|---|---|---|
| committer | Chris Lu <chris.lu@gmail.com> | 2020-04-16 02:55:09 -0700 |
| commit | f5a748d33c52a2874dbde92746a03140ef379296 (patch) | |
| tree | 21a9bdf9c329a94249ca026e2aa04647c414beb4 /weed/command/msg_broker.go | |
| parent | ce4b369be25f61be0810e2bc119964b613cca121 (diff) | |
| download | seaweedfs-f5a748d33c52a2874dbde92746a03140ef379296.tar.xz seaweedfs-f5a748d33c52a2874dbde92746a03140ef379296.zip | |
refactoring
Diffstat (limited to 'weed/command/msg_broker.go')
| -rw-r--r-- | weed/command/msg_broker.go | 7 |
1 files changed, 3 insertions, 4 deletions
diff --git a/weed/command/msg_broker.go b/weed/command/msg_broker.go index 3cb424298..f77582f03 100644 --- a/weed/command/msg_broker.go +++ b/weed/command/msg_broker.go @@ -8,13 +8,12 @@ import ( "google.golang.org/grpc/reflection" + "github.com/chrislusf/seaweedfs/weed/glog" + "github.com/chrislusf/seaweedfs/weed/messaging" "github.com/chrislusf/seaweedfs/weed/pb" "github.com/chrislusf/seaweedfs/weed/pb/filer_pb" "github.com/chrislusf/seaweedfs/weed/pb/messaging_pb" "github.com/chrislusf/seaweedfs/weed/security" - weed_server "github.com/chrislusf/seaweedfs/weed/server" - - "github.com/chrislusf/seaweedfs/weed/glog" "github.com/chrislusf/seaweedfs/weed/util" ) @@ -79,7 +78,7 @@ func (msgBrokerOpt *QueueOptions) startQueueServer() bool { } } - qs, err := weed_server.NewMessageBroker(&weed_server.MessageBrokerOption{ + qs, err := messaging.NewMessageBroker(&messaging.MessageBrokerOption{ Filers: []string{*msgBrokerOpt.filer}, DefaultReplication: "", MaxMB: 0, |