diff options
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, |