myapp.sendMessageToAll("hi there");
client.sendQuery(Server.ENVELOPE_TAG, query);
    public static void main(String args[]) {        logger.debug("Starting Client peer ....");        Client myapp = new Client(new FakeDataSource());        try {            BufferedReader reader = new BufferedReader(new InputStreamReader(System.in));            String line = null;            while ((line = reader.readLine()) != null) {                if (line.equals(CMD_MESSAGE)) {                    myapp.sendMessageToAll("hi there");                } else if (line.equals(CMD_QUIT)) {                    System.exit(0);                }            }        } catch (IOException e) {            logger.error(e);        }    }