log.error(e);
System.err.println(e);
    public void start() throws Exception {        channel=new JChannel(props);        if(mode == 1) channel.setOpt(Channel.LOCAL, Boolean.FALSE);        channel.connect(groupname);        if(mode == 1) {            for(int j=0; j < num_msgs; j++) {                msg=createBigMessage(MSG_SIZE);                System.out.println("Sending msg (" + MSG_SIZE + " bytes)");                channel.send(msg);                System.out.println("Done Sending msg (" + MSG_SIZE + " bytes)");                Util.sleep(timeout);            }            System.out.println("Press [return] to exit");            System.in.read();        }        else {            System.out.println("Waiting for messages:");            while(true) {                try {                    obj=channel.receive(0);                    if(obj instanceof Message) {                        System.out.println("Received message: " + obj);                        Message tmp=(Message)obj;                        byte[] buf=tmp.getBuffer();                        for(int i=0; i < (10 < MSG_SIZE ? 10 : MSG_SIZE); i++) {                            System.out.print((char)buf[i]);                        }                        System.out.println();                    }                }                catch(Exception e) {                    log.error(e);                }            }        }        channel.close();    }