/* this is the application layer */ public class AppC { public AppC() { } public static void main(String args[]) { try { int id; /** Intialization starts*/ DataAC dac=new DataAC(); DataCA dca=new DataCA(); id=Integer.parseInt(args[0]); comm t = new comm(id,1200+id*2,0,0,dac,dca); /* initialise the lower comm layer */ /** Initialization ends*/ AppC a = new AppC(); CoreMessage cm=new CoreMessage(92,"select * from emp_table",1); /* create a message */ for (int i=0;i<15;i++) { Thread.sleep(2000); // DataComm_app.addApp_comm(cm); // send a message App-->Comm System.out.println("producing"+i); dac.Produce(cm);} } catch(Exception r) { System.out.println("AppC" + r); } } }