pullpushtest.java

来自「JGRoups源码」· Java 代码 · 共 65 行

// $Id: PullPushTest.java,v 1.7 2005/05/30 16:15:12 belaban Exp $


package org.jgroups.tests;


import org.jgroups.Channel;
import org.jgroups.JChannel;
import org.jgroups.Message;
import org.jgroups.MessageListener;
import org.jgroups.blocks.PullPushAdapter;


/**
 * Uses PullPush building block to send/receive messages. Reception is passive, e.g. the receiver's
 * receive() method is invoked whenever a message is received. The receiver has to register a callback method
 * when creating the channel.
 * @author Bela Ban
 */
public class PullPushTest implements MessageListener {
    private Channel channel;
    private PullPushAdapter adapter;

    public void receive(Message msg) {
        System.out.println("Received msg: " + msg);
    }

    public byte[] getState() {  // only called if channel option GET_STATE_EVENTS is set to true
        return null;
    }

    public void setState(byte[] state) {

    }


    public void start() throws Exception {

        channel=new JChannel();
        channel.connect("PullPushTest");
        adapter=new PullPushAdapter(channel);
        adapter.setListener(this);

        for(int i=0; i < 10; i++) {
            System.out.println("Sending msg #" + i);
            adapter.send(new Message(null, null, "Hello world".getBytes()));
            Thread.sleep(1000);
        }

        channel.close();
    }


    public static void main(String args[]) {
        PullPushTest t=new PullPushTest();
        try {
            t.start();
        }
        catch(Exception e) {
            System.err.println(e);
        }
    }

}