@@ -41,6 +41,7 @@ use rocketmq_remoting::rpc::client_metadata::ClientMetadata;
41
41
use rocketmq_remoting:: rpc:: rpc_client_impl:: RpcClientImpl ;
42
42
use rocketmq_remoting:: runtime:: config:: client_config:: TokioClientConfig ;
43
43
use rocketmq_remoting:: runtime:: RPCHook ;
44
+ use tracing:: debug;
44
45
use tracing:: error;
45
46
use tracing:: info;
46
47
@@ -207,10 +208,17 @@ impl BrokerOuterAPI {
207
208
request_header : RegisterBrokerRequestHeader ,
208
209
body : Vec < u8 > ,
209
210
) -> Option < RegisterBrokerResult > {
211
+ debug ! (
212
+ "Register broker to name server, namesrv_addr={},request_code={:?}, \
213
+ request_header={:?}, body={:?}",
214
+ namesrv_addr,
215
+ RequestCode :: RegisterBroker ,
216
+ request_header,
217
+ body
218
+ ) ;
210
219
let request =
211
220
RemotingCommand :: create_request_command ( RequestCode :: RegisterBroker , request_header)
212
221
. set_body ( Some ( body. clone ( ) ) ) ;
213
-
214
222
if oneway {
215
223
self . remoting_client
216
224
. invoke_oneway ( namesrv_addr, request, timeout_mills)
@@ -224,6 +232,12 @@ impl BrokerOuterAPI {
224
232
{
225
233
Ok ( response) => match From :: from ( response. code ( ) ) {
226
234
ResponseCode :: Success => {
235
+ info ! (
236
+ "Register broker to name server success, namesrv_addr={} response \
237
+ body={:?}",
238
+ namesrv_addr,
239
+ response. body( )
240
+ ) ;
227
241
let register_broker_result =
228
242
response. decode_command_custom_header :: < RegisterBrokerResponseHeader > ( ) ;
229
243
let mut result = RegisterBrokerResult :: default ( ) ;
0 commit comments