Set the connector:
try { // create instance of Connector Connector conn = Connector.createInstance(localhost,60201); // instantiate and set the listener MyListener listener = new MyListener(); conn.setListener(listener,null); // start the listener thread conn.startThread(); } catch (Exception e) { // code to handle exception } catch (IOException e) { // code to handle exception } catch (UnknownHostException e) { // code to handle exception }Send a message:
Message m = new Message("my command", "my 1st parameter"); m.addParameter("my 2nd parameter"); m.addParameter(3); try { Connector.sendMessage(m); } catch (Exception e) { // code to handle exception }Receive messages:
public class MyListener implements MessageListener { public void processIncomingMessage(Message m, Object o) { System.out.println("command: "+m.getCommand()); m.resetParCount(); while(m.hasMorePars()) { String p=m.getNextParameter(); System.out.println("parameter: "+p); } } }
NOTE! it the connector is started with the ability of listening for incoming messages it starts a background thread, it is mandatory to stop the backgraound thread before stopping the execution of the application otherwise the application will not stop.