Merge pull request #198 from MaggieNgWu/release-2.7.0

fix bug of print message conteent

Author: MaggieNgWu

sdk-amop/src/main/java/org/fisco/bcos/sdk/amop/AmopImp.java

@@ -115,13 +115,18 @@ public void sendAmopMsg(AmopMsgOut content, AmopResponseCallback callback) {
                 new ResponseCallback() {
                     @Override
                     public void onResponse(Response response) {
+                        logger.trace(
+                                "receive response from subscriber, seq:{}",
+                                response.getMessageID());
                         AmopResponse amopResponse = new AmopResponse(response);
                         callback.onResponse(amopResponse);
                     }
                 };
         this.channel.asyncSendToRandom(msg, cb, ops);
         logger.info(
-                "send amop msg to a random peer, seq{} topic{}", msg.getSeq(), content.getTopic());
+                "send amop msg to a random peer, seq: {} topic: {}",
+                msg.getSeq(),
+                content.getTopic());
     }
 
     @Override

sdk-core/src/main/java/org/fisco/bcos/sdk/channel/ChannelImp.java

@@ -327,6 +327,10 @@ public void run(Timeout timeout) {
     @Override
     public void asyncSendToRandom(Message out, ResponseCallback callback, Options options) {
         List<String> peerList = getAvailablePeer();
+        if (peerList.size() == 0) {
+            logger.warn(
+                    "no available peer to send to, seq: {}, type: {}", out.getSeq(), out.getType());
+        }
         int random = (int) (Math.random() * (peerList.size()));
         String peerIpPort = peerList.get(random);
         logger.trace("send message to random peer {} ", peerIpPort);

sdk-core/src/main/java/org/fisco/bcos/sdk/channel/ChannelMsgHandler.java

@@ -129,10 +129,10 @@ public void onMessage(ChannelHandlerContext ctx, Message msg) {
         if (callback != null) {
             callback.cancelTimeout();
             logger.trace(
-                    " receive response, seq: {}, result: {}, content: {}",
+                    " call registered callback, seq: {}, type: {} ,result: {}",
                     msg.getSeq(),
-                    msg.getResult(),
-                    new String(msg.getData()));
+                    msg.getType(),
+                    msg.getResult());
 
             Response response = new Response();
             if (msg.getResult() != 0) {
@@ -145,10 +145,10 @@ public void onMessage(ChannelHandlerContext ctx, Message msg) {
             callback.onResponse(response);
         } else {
             logger.trace(
-                    " receive response with invalid seq, type: {}, result: {}, content: {}",
+                    " receive message, no callback, try call handler, seq:{} , type: {}, result: {}",
+                    msg.getSeq(),
                     (int) msg.getType(),
-                    msg.getResult(),
-                    new String(msg.getData()));
+                    msg.getResult());
             MsgHandler msgHandler = msgHandlers.get(msg.getType().intValue());
             if (msgHandler != null) {
                 msgHandler.onMessage(ctx, msg);