finder.java

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

package examples.finder;

import com.ibm.aglet.*;
import java.io.PrintStream;
import java.util.Hashtable;

public class Finder extends Aglet
{

    Hashtable _database;

    public Finder()
    {
        _database = new Hashtable();
    }

    public boolean handleMessage(Message message)
    {
        if(message.sameKind("Lookup"))
            message.sendReply(_database.get(message.getArg()));
        else
        if(message.sameKind("Register"))
        {
            System.out.println("Registering .. " + message.getArg("NAME"));
            System.out.println(message.getArg("PROXY"));
            _database.put(message.getArg("NAME"), message.getArg("PROXY"));
        } else
        if(message.sameKind("Unregister"))
            _database.remove(message.getArg("NAME"));
        else
            return false;
        return true;
    }

    public void onCreation(Object obj)
    {
        com.ibm.aglet.AgletProxy agletproxy = getAgletContext().getAgletProxy(getAgletID());
        getAgletContext().setProperty("finder", agletproxy);
    }
}