96979899100101102103104105106
public void run() { MistClient sinkClient = null; try { sinkClient = new MistClient(Role.PRODUCER, 1); sinkClient.mount(true, fwdExchange.toString()); sinkClient.attach(); } catch(Exception e) { e.printStackTrace(); return; }