import org.javasim.RestartException;
import org.javasim.SimulationException;
import org.javasim.SimulationProcess;
import org.javasim.streams.*;

import java.io.IOException;

/*
 * Generator of payload (of the type Ship). Generates Ships with same routing and similar 
 * service times with interarrival times from given distribution.
 */

public class Arrivals extends SimulationProcess
{

public Arrivals (RandomStream inter, RandomStream[] st, int hc)
    {
    InterArrivalTime = inter;
    servicetime = new RandomStream[hc];
    servtime = new double[hc];
    servicetime = st;
    harborcount= hc;
    }

public void run ()
    {
    for (;;)
    {
        try
        {
           for (int i=0; i< harborcount; i++) { servtime[i]= servicetime[i].getNumber();}
            Ship work = new Ship(servtime, harborcount); // new Ship is taken care of in its constructor
            hold(InterArrivalTime.getNumber());
      }
        catch (SimulationException e) {}
        catch (RestartException e) {}
        catch (IOException e) {}
    }
    }
private RandomStream InterArrivalTime;
private RandomStream[] servicetime;
private double[] servtime;
private int harborcount;
};