diff options
| author | Chris Lu <chris.lu@gmail.com> | 2020-04-16 02:21:23 -0700 |
|---|---|---|
| committer | Chris Lu <chris.lu@gmail.com> | 2020-04-16 02:21:23 -0700 |
| commit | ce4b369be25f61be0810e2bc119964b613cca121 (patch) | |
| tree | 8912660d5036999750456a75a7afe76323643dc5 /weed/command/msg_broker.go | |
| parent | 5f772dacd2a494c8912dd60c425f022e5d32989a (diff) | |
| download | seaweedfs-ce4b369be25f61be0810e2bc119964b613cca121.tar.xz seaweedfs-ce4b369be25f61be0810e2bc119964b613cca121.zip | |
scaffolding messaging
Diffstat (limited to 'weed/command/msg_broker.go')
| -rw-r--r-- | weed/command/msg_broker.go | 6 |
1 files changed, 2 insertions, 4 deletions
diff --git a/weed/command/msg_broker.go b/weed/command/msg_broker.go index 093cff4a6..3cb424298 100644 --- a/weed/command/msg_broker.go +++ b/weed/command/msg_broker.go @@ -10,7 +10,7 @@ import ( "github.com/chrislusf/seaweedfs/weed/pb" "github.com/chrislusf/seaweedfs/weed/pb/filer_pb" - "github.com/chrislusf/seaweedfs/weed/pb/queue_pb" + "github.com/chrislusf/seaweedfs/weed/pb/messaging_pb" "github.com/chrislusf/seaweedfs/weed/security" weed_server "github.com/chrislusf/seaweedfs/weed/server" @@ -25,14 +25,12 @@ var ( type QueueOptions struct { filer *string port *int - defaultTtl *string } func init() { cmdMsgBroker.Run = runMsgBroker // break init cycle messageBrokerStandaloneOptions.filer = cmdMsgBroker.Flag.String("filer", "localhost:8888", "filer server address") messageBrokerStandaloneOptions.port = cmdMsgBroker.Flag.Int("port", 17777, "queue server gRPC listen port") - messageBrokerStandaloneOptions.defaultTtl = cmdMsgBroker.Flag.String("ttl", "1h", "time to live, e.g.: 1m, 1h, 1d, 1M, 1y") } var cmdMsgBroker = &Command{ @@ -94,7 +92,7 @@ func (msgBrokerOpt *QueueOptions) startQueueServer() bool { glog.Fatalf("failed to listen on grpc port %d: %v", *msgBrokerOpt.port, err) } grpcS := pb.NewGrpcServer(security.LoadServerTLS(util.GetViper(), "grpc.msg_broker")) - queue_pb.RegisterSeaweedQueueServer(grpcS, qs) + messaging_pb.RegisterSeaweedMessagingServer(grpcS, qs) reflection.Register(grpcS) grpcS.Serve(grpcL) |