diff --git a/src/main/java/com/lion/lionwebsite/Message/IdentityMessage.java b/src/main/java/com/lion/lionwebsite/Message/IdentityMessage.java index f0792f6..225d4c8 100644 --- a/src/main/java/com/lion/lionwebsite/Message/IdentityMessage.java +++ b/src/main/java/com/lion/lionwebsite/Message/IdentityMessage.java @@ -1,10 +1,15 @@ package com.lion.lionwebsite.Message; +import lombok.AllArgsConstructor; import lombok.Data; +import lombok.NoArgsConstructor; @Data +@AllArgsConstructor +@NoArgsConstructor public class IdentityMessage extends AbstractMessage{ { messageType = IDENTITY_MESSAGE; } + String identity; } diff --git a/src/main/java/com/lion/lionwebsite/Service/RemoteService.java b/src/main/java/com/lion/lionwebsite/Service/RemoteService.java index b9239e2..7447f5b 100644 --- a/src/main/java/com/lion/lionwebsite/Service/RemoteService.java +++ b/src/main/java/com/lion/lionwebsite/Service/RemoteService.java @@ -92,7 +92,7 @@ public class RemoteService { pushService.storageNodeOnline(); channel = channelFuture.channel(); - channel.writeAndFlush(new IdentityMessage()); + channel.writeAndFlush(new IdentityMessage("lionwebsite")); return true; }catch (Exception e){ e.printStackTrace(); diff --git a/src/main/java/com/lion/lionwebsite/Util/Response.java b/src/main/java/com/lion/lionwebsite/Util/Response.java index 0e9f225..3da8dd2 100644 --- a/src/main/java/com/lion/lionwebsite/Util/Response.java +++ b/src/main/java/com/lion/lionwebsite/Util/Response.java @@ -1,11 +1,8 @@ package com.lion.lionwebsite.Util; - import com.fasterxml.jackson.databind.JsonNode; -import com.fasterxml.jackson.databind.ObjectMapper; import com.fasterxml.jackson.databind.node.ObjectNode; -import java.util.HashMap; public class Response { ObjectNode result; @@ -63,7 +60,7 @@ public class Response { } public boolean isSuccess(){ - return result.get("result").equals("success"); + return result.get("result").asText().equals("success"); }