source: branches/objectmq-1.0/test/test2/MobileThread.java @ 33

package test2;

import omq.common.broker.Broker;

public class MobileThread extends Thread {
        private String name;
        private Object lock;

        public MobileThread(String name, Object lock) {
                this.name = name;
                this.lock = lock;
        }

        @Override
        public void run() {
                try {
                        Mobile mobile = (Mobile) Broker.lookup(name, Mobile.class);
                        synchronized (lock) {
                                mobile.sendMessage("Hello this is Sergi");
                                mobile.sendMessage("and this is a test");
                                Thread.sleep(1000);
                                lock.notify();
                        }
                } catch (Exception e) {

                }
        }
}