ZeppelinhubMessage { public static ZeppelinhubMessage deserialize(String zeppelinhubMessage) { if (StringUtils.isBlank(zeppelinhubMessage)) { return EMPTY; } ZeppelinhubMessage msg; try { msg = gson.fromJson(zeppelinhubMessage, ZeppelinhubMessage.class); } catch (JsonSyntaxException ex) { LOG.error("Cannot deserialize zeppelinhub message", ex); msg = EMPTY; } return msg; } private  ZeppelinhubMessage(); private  ZeppelinhubMessage(Object op, Object data, Map<String, String> meta); static ZeppelinhubMessage newMessage(Object op, Object data, Map<String, String> meta); static ZeppelinhubMessage newMessage(Message zeppelinMsg, Map<String, String> meta); String serialize(); static ZeppelinhubMessage deserialize(String zeppelinhubMessage); static final ZeppelinhubMessage EMPTY; public Object op; public Object data; public Map<String, String> meta; }
@Test public void testThatInvalidStringReturnEmptyZeppelinhubMessage() { assertEquals(ZeppelinhubMessage.EMPTY, ZeppelinhubMessage.deserialize("")); assertEquals(ZeppelinhubMessage.EMPTY, ZeppelinhubMessage.deserialize("dwfewewrewr")); }