@Test public void runAllParagraphTest() throws Exception { Client.initialize(validWebsocketUrl, validWebsocketUrl, "TOKEN", null); Client.getInstance().start(); ZeppelinhubClient zeppelinhubClient = ZeppelinhubClient.getInstance(); boolean runStatus = zeppelinhubClient.runAllParagraph("2AB7SY361", runNotebookMsg); assertTrue(runStatus); runStatus = zeppelinhubClient.runAllParagraph("2AB7SY361", invalidRunNotebookMsg); assertFalse(runStatus); Client.getInstance().stop(); }
boolean runAllParagraph(String noteId, String hubMsg) { return true; }
ZeppelinhubClient { boolean runAllParagraph(String noteId, String hubMsg) { return true; } }
ZeppelinhubClient { boolean runAllParagraph(String noteId, String hubMsg) { return true; } private  ZeppelinhubClient(String url, String token); }
ZeppelinhubClient { boolean runAllParagraph(String noteId, String hubMsg) { return true; } private  ZeppelinhubClient(String url, String token); static ZeppelinhubClient initialize(String zeppelinhubUrl, String token); static ZeppelinhubClient getInstance(); void start(); void initUser(String token); void stop(); void stopUser(String token); String getToken(); void send(String msg, String token); void removeSession(String token); void handleMsgFromZeppelinHub(String message); }
ZeppelinhubClient { boolean runAllParagraph(String noteId, String hubMsg) { return true; } private  ZeppelinhubClient(String url, String token); static ZeppelinhubClient initialize(String zeppelinhubUrl, String token); static ZeppelinhubClient getInstance(); void start(); void initUser(String token); void stop(); void stopUser(String token); String getToken(); void send(String msg, String token); void removeSession(String token); void handleMsgFromZeppelinHub(String message);  }