package org.jgroups.tests;

import org.jgroups.JChannel;
import org.jgroups.Message;
import org.jgroups.blocks.MessageDispatcher;
import org.jgroups.blocks.RequestHandler;
import org.jgroups.blocks.RequestOptions;
import org.jgroups.util.RspList;
import org.jgroups.util.Util;

import java.util.Date;

/**
 * @author Bela Ban
 * @since x.y
 */
public class bla implements RequestHandler {
    protected JChannel a, b;
    protected MessageDispatcher disp, disp2;


    protected void start() throws Exception {
        a=new JChannel().name("A");
        b=new JChannel().name("B");
        disp=new MessageDispatcher(a, null, null, this);
        disp2=new MessageDispatcher(b, null, null, this);
        a.connect("demo");
        b.connect("demo");

        long start=System.currentTimeMillis();
        RspList<Object> rsps=disp.castMessage(null,new Message(),RequestOptions.SYNC());
        long diff=System.currentTimeMillis() - start;
        System.out.println("[" + diff + " ms] rsps = \n" + rsps);
        Util.close(b,a);
    }

    public Object handle(Message msg) throws Exception {
        return new Date();
    }

    public static void main(String[] args) throws Exception {
        new bla().start();
    }


}