Distributed Cache and CEP with Storm - Real-time Analytics with Storm and Cassandra - page 242

return "Price: " + price.toString() + " time: " +
timeStamp.toString();
}
}
Once we have the value object in place, the next step is to instantiate the Esper engine and
listener and wire in all the pieces together:
public class myEsperMain {
private static Random generator = new Random();
public static void
GenerateRandomCasinoWinEvent(EPRuntimecepRT) {
doubleprizeAmount = (double) generator.nextInt(10);
longtimeStamp = System.currentTimeMillis();
String game = "Roulette";
CasinoWinEventcasinoEvent = new CasinoWinEvent(game,
prizeAmount, timeStamp);
System.out.println("Sending Event:" + casinoEvent);
cepRT.sendEvent(casinoEvent);
}
public static class CEPListener implements UpdateListener
{
public void update(EventBean[] newData, EventBean[]
oldData) {
System.out.println("Event received: " +
newData[0].getUnderlying());
}
}
public static void main(String[] args) {
//The Configuration is meant only as an
initialization-time object.
Configuration cepConfig = new Configuration();
cepConfig.addEventType("CasinoEvent",
CasinoWinEvent.class.getName());
EPServiceProvidercep =
EPServiceProviderManager.getProvider("myCEPEngine",
cepConfig);
EPRuntimecepRT = cep.getEPRuntime();
EPAdministratorcepAdm = cep.getEPAdministrator();