FmqClient { public FmqClient () { ctx = new ZContext (); pipe = ZThread.fork (ctx, new ClientThread ()); } FmqClient(); void destroy(); void configure(final String configFile); void setoption(final String path, final String value); void connect(final String endpoint); ZMsg recv(); Socket handle(); void subscribe(final String path); void setInbox(final String path); void setResync(long enabled); static void zclock_log(String fmt, Object ... args);  }
@Test public void testFmqClient () { System.out.printf (" * FmqClient: "); FmqClient self; self = new FmqClient (); assert (self != null); self.configure ("src/test/resources/client_test.cfg"); self.connect ("tcp: try { Thread.sleep (1000); } catch (Exception e) {} self.destroy (); System.out.printf ("OK\n"); }