@Test public void getMessageData() { String src = "io.riguron.type.T:{some serialized object}"; MessageDataExtractor extractor = new MessageDataExtractor(); MessageData messageData = extractor.getMessageData(src.getBytes()); assertEquals("io.riguron.type.T",messageData.getType()); assertEquals("{some serialized object}", messageData.getContent()); }
public MessageData getMessageData(byte[] payload) { String dataString = new String(payload, StandardCharsets.UTF_8); int separator = dataString.indexOf(':'); return new MessageData(dataString.substring(0, separator), dataString.substring(separator + 1, dataString.length())); }
MessageDataExtractor { public MessageData getMessageData(byte[] payload) { String dataString = new String(payload, StandardCharsets.UTF_8); int separator = dataString.indexOf(':'); return new MessageData(dataString.substring(0, separator), dataString.substring(separator + 1, dataString.length())); } }
MessageDataExtractor { public MessageData getMessageData(byte[] payload) { String dataString = new String(payload, StandardCharsets.UTF_8); int separator = dataString.indexOf(':'); return new MessageData(dataString.substring(0, separator), dataString.substring(separator + 1, dataString.length())); }  }
MessageDataExtractor { public MessageData getMessageData(byte[] payload) { String dataString = new String(payload, StandardCharsets.UTF_8); int separator = dataString.indexOf(':'); return new MessageData(dataString.substring(0, separator), dataString.substring(separator + 1, dataString.length())); }  MessageData getMessageData(byte[] payload); }
MessageDataExtractor { public MessageData getMessageData(byte[] payload) { String dataString = new String(payload, StandardCharsets.UTF_8); int separator = dataString.indexOf(':'); return new MessageData(dataString.substring(0, separator), dataString.substring(separator + 1, dataString.length())); }  MessageData getMessageData(byte[] payload);  }