diff --git a/README.md b/README.md index ddcd2fea..fb873cd9 100644 --- a/README.md +++ b/README.md @@ -88,8 +88,8 @@ Feature list: | Delete KV Config | 102 | :sparkling_heart: :white_check_mark: | | | Get kv list by namespace | 219 | :sparkling_heart: :white_check_mark: | | | Query Data Version | 322 | :sparkling_heart: :white_check_mark: | | -| Register Broker | 103 | :sparkling_heart: :white_check_mark: | | -| Unregister Broker | 104 | :sparkling_heart: :white_check_mark: | | +| Register Broker | 103 | :heart: | | +| Unregister Broker | 104 | :broken_heart: :x: | | | Broker Heartbeat | 904 | :sparkling_heart: :white_check_mark: | | | Get broker member_group | 901 | :sparkling_heart: :white_check_mark: | | | Get broker cluster info | 106 | :sparkling_heart: :white_check_mark: | | diff --git a/rocketmq-namesrv/README.md b/rocketmq-namesrv/README.md index 2e84aead..b739c190 100644 --- a/rocketmq-namesrv/README.md +++ b/rocketmq-namesrv/README.md @@ -21,8 +21,8 @@ Feature list: | Delete KV Config | 102 | :sparkling_heart: :white_check_mark: | | | Get kv list by namespace | 219 | :sparkling_heart: :white_check_mark: | | | Query Data Version | 322 | :sparkling_heart: :white_check_mark: | | -| Register Broker | 103 | :sparkling_heart: :white_check_mark: | | -| Unregister Broker | 104 | :sparkling_heart: :white_check_mark: | | +| Register Broker | 103 | :heart: :white_check_mark: | | +| Unregister Broker | 104 | :broken_heart: :x: | | | Broker Heartbeat | 904 | :sparkling_heart: :white_check_mark: | | | Get broker member_group | 901 | :sparkling_heart: :white_check_mark: | | | Get broker cluster info | 106 | :sparkling_heart: :white_check_mark: | | diff --git a/rocketmq-namesrv/src/processor/default_request_processor.rs b/rocketmq-namesrv/src/processor/default_request_processor.rs index 8aa5e065..98cad395 100644 --- a/rocketmq-namesrv/src/processor/default_request_processor.rs +++ b/rocketmq-namesrv/src/processor/default_request_processor.rs @@ -307,12 +307,10 @@ impl DefaultRequestProcessor { } fn process_unregister_broker(&mut self, request: RemotingCommand) -> RemotingCommand { - let request_header = request + let _request_header = request .decode_command_custom_header::() .unwrap(); - self.route_info_manager - .write() - .un_register_broker(vec![request_header]); + //todo RemotingCommand::create_response_command() } }