visitingaglet.java

在IBM AGLET平台下可实现AGLET在不同主机间巡回的代码

package examples.itinerary;

import com.ibm.aglet.*;
import com.ibm.agletx.patterns.Meeting;
import com.ibm.agletx.util.MeetingsItinerary;
import com.ibm.agletx.util.SeqItinerary;
import java.awt.Component;
import java.awt.Window;
import java.net.URL;
import java.util.Vector;

// Referenced classes of package examples.itinerary:
//            AgletTask, VisitingFrame

public class VisitingAglet extends Aglet
{

    MeetingsItinerary itinerary;
    Vector addresses;

    public VisitingAglet()
    {
        addresses = new Vector();
    }

    public void createStationaryAglets(MeetingsItinerary meetingsitinerary)
        throws Exception
    {
        Object obj = null;
        for(int i = 0; i < addresses.size(); i++)
            try
            {
                String s;
                Meeting meeting = new Meeting(s = (String)addresses.elementAt(i));
                AgletProxy agletproxy = getAgletContext().createAglet(null, "examples.itinerary.StationaryAglet", meeting);
                agletproxy.dispatch(new URL(s));
                meetingsitinerary.addMeetingTask(new AgletTask(meeting));
            }
            catch(Exception exception)
            {
                exception.printStackTrace();
            }

    }

    public boolean handleMessage(Message message)
    {
        if(message.sameKind("dialog"))
        {
            VisitingFrame visitingframe = new VisitingFrame(this);
            visitingframe.pack();
            visitingframe.setVisible(true);
            return true;
        } else
        {
            return false;
        }
    }

    public void onCreation(Object obj)
    {
        itinerary = new MeetingsItinerary(this);
    }

    public void start()
    {
        try
        {
            itinerary.clear();
            createStationaryAglets(itinerary);
            itinerary.startTrip();
        }
        catch(Exception exception)
        {
            exception.printStackTrace();
        }
    }
}