diff options
| author | Chris Lu <chris.lu@gmail.com> | 2020-04-18 01:12:01 -0700 |
|---|---|---|
| committer | Chris Lu <chris.lu@gmail.com> | 2020-04-18 01:12:01 -0700 |
| commit | 11f5a6d91346e5f3cbf3b46e0a660e231c5c2998 (patch) | |
| tree | 9cf930e9d832023c0a00345f9f95f62297ea5441 /weed/command | |
| parent | 5bea77010f2b290398c46a517d40fa7ad559dfed (diff) | |
| download | seaweedfs-11f5a6d91346e5f3cbf3b46e0a660e231c5c2998.tar.xz seaweedfs-11f5a6d91346e5f3cbf3b46e0a660e231c5c2998.zip | |
messaging can compile now
Diffstat (limited to 'weed/command')
| -rw-r--r-- | weed/command/msg_broker.go | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/weed/command/msg_broker.go b/weed/command/msg_broker.go index 36d164800..67ebdfb6d 100644 --- a/weed/command/msg_broker.go +++ b/weed/command/msg_broker.go @@ -9,7 +9,7 @@ import ( "google.golang.org/grpc/reflection" "github.com/chrislusf/seaweedfs/weed/glog" - "github.com/chrislusf/seaweedfs/weed/messaging" + "github.com/chrislusf/seaweedfs/weed/messaging/broker" "github.com/chrislusf/seaweedfs/weed/pb" "github.com/chrislusf/seaweedfs/weed/pb/filer_pb" "github.com/chrislusf/seaweedfs/weed/pb/messaging_pb" @@ -80,7 +80,7 @@ func (msgBrokerOpt *QueueOptions) startQueueServer() bool { } } - qs, err := messaging.NewMessageBroker(&messaging.MessageBrokerOption{ + qs, err := broker.NewMessageBroker(&broker.MessageBrokerOption{ Filers: []string{*msgBrokerOpt.filer}, DefaultReplication: "", MaxMB: 0, |