1 package emissary.place; 2 3 import emissary.core.IBaseDataObject; 4 5 import java.io.IOException; 6 import java.io.InputStream; 7 8 public class MyStreamConfigedTestPlace extends ServiceProviderPlace { 9 10 boolean finishedSuperConstructor = false; 11 12 int processCounter = 0; 13 14 public MyStreamConfigedTestPlace(String placeLocation) throws IOException { 15 super(placeLocation); 16 finishedSuperConstructor = true; 17 } 18 19 public MyStreamConfigedTestPlace(String configFile, String dir, String placeLocation) throws IOException { 20 super(configFile, dir, placeLocation); 21 finishedSuperConstructor = true; 22 } 23 24 public MyStreamConfigedTestPlace(InputStream configStream, String dir, String placeLocation) throws IOException { 25 super(configStream, dir, placeLocation); 26 finishedSuperConstructor = true; 27 } 28 29 30 public boolean getFinishedSuperConstructor() { 31 return finishedSuperConstructor; 32 } 33 34 @Override 35 public void process(IBaseDataObject payload) { 36 processCounter++; 37 } 38 }