Merge pull request #292 from scalecube/update/msg/metadata/codec

Updated msg and metadata codecs

Author: artem-v

cluster/src/main/java/io/scalecube/cluster/metadata/GetMetadataResponse.java

@@ -42,27 +42,27 @@ public void writeExternal(ObjectOutput out) throws IOException {
     // member
     out.writeObject(member);
     // metadata
-    byte[] bytes = metadata.array();
-    out.writeInt(bytes.length);
-    out.write(bytes);
+    byte[] metadataBytes = metadata.array();
+    out.writeInt(metadataBytes.length);
+    out.write(metadataBytes);
   }
 
   @Override
   public void readExternal(ObjectInput in) throws IOException, ClassNotFoundException {
     // member
     member = (Member) in.readObject();
     // metadata
-    int size = in.readInt();
-    byte[] bytes = new byte[size];
-    in.read(bytes);
-    metadata = ByteBuffer.wrap(bytes);
+    int metadataSize = in.readInt();
+    byte[] metadataBytes = new byte[metadataSize];
+    in.readFully(metadataBytes);
+    metadata = ByteBuffer.wrap(metadataBytes);
   }
 
   @Override
   public String toString() {
     return new StringJoiner(", ", GetMetadataResponse.class.getSimpleName() + "[", "]")
         .add("member=" + member)
-        .add("metadata=" + metadata.remaining())
+        .add("metadata(b=" + metadata.remaining() + ")")
         .toString();
   }
 }

transport-parent/transport-api/src/main/java/io/scalecube/cluster/transport/api/JdkMessageCodec.java

@@ -11,17 +11,17 @@ public class JdkMessageCodec implements MessageCodec {
   @Override
   public Message deserialize(InputStream is) throws IOException, ClassNotFoundException {
     Message message = new Message();
-    try (ObjectInputStream inputStream = new ObjectInputStream(is)) {
-      message.readExternal(inputStream);
-      return message;
+    try (ObjectInputStream ois = new ObjectInputStream(is)) {
+      message.readExternal(ois);
     }
+    return message;
   }
 
   @Override
   public void serialize(Message message, OutputStream os) throws IOException {
-    try (ObjectOutputStream outputStream = new ObjectOutputStream(os)) {
-      message.writeExternal(outputStream);
-      outputStream.flush();
+    try (ObjectOutputStream oos = new ObjectOutputStream(os)) {
+      message.writeExternal(oos);
+      oos.flush();
     }
   }
 }