public void receive(Event[] events) {
EventPrinter.print(events);
}
});
executionPlanRuntime.start();
<BUG>Thread.sleep(5000);
executionPlanRuntime.shutdown();</BUG>
}
@Test(expected = ExecutionPlanValidationException.class)
public void subscriptionTest2() throws InterruptedException {

public void receive(Event[] events) {
EventPrinter.print(events);
}
});
executionPlanRuntime.start();
InMemoryBroker.publish("stock","{'symbol': 'WSO2', 'price': 56.75, 'volume': 5, 'country': 'Sri Lanka'}");
executionPlanRuntime.shutdown();
}
@Test(expected = ExecutionPlanValidationException.class)
public void subscriptionTest2() throws InterruptedException {
