register.java

在IBM AGLET平台下可实现AGNET注册服务的代码

package examples.finder;

import com.ibm.aglet.*;
import com.ibm.aglet.event.MobilityAdapter;
import com.ibm.aglet.event.MobilityEvent;
import java.io.PrintStream;

public class Register extends MobilityAdapter
{

    AgletProxy _finder;
    Message _msg;

    Register(Aglet aglet, AgletProxy agletproxy, String s)
    {
        _msg = new Message("Register");
        aglet.addMobilityListener(this);
        _msg.setArg("NAME", s);
        _finder = agletproxy;
        AgletProxy agletproxy1 = aglet.getAgletContext().getAgletProxy(aglet.getAgletID());
        register(agletproxy1);
    }

    public void onArrival(MobilityEvent mobilityevent)
    {
        System.out.println(mobilityevent.getAgletProxy());
        register(mobilityevent.getAgletProxy());
    }

    public void register(AgletProxy agletproxy)
    {
        _msg.setArg("PROXY", agletproxy);
        try
        {
            _finder.sendOnewayMessage(_msg);
        }
        catch(Exception exception)
        {
            exception.printStackTrace();
        }
    }

    public void unregister()
    {
        Message message = new Message("Unregister");
        message.setArg("NAME", _msg.getArg("NAME"));
        try
        {
            _finder.sendOnewayMessage(message);
        }
        catch(Exception exception)
        {
            exception.printStackTrace();
        }
    }
}