.attribute("price", Attribute.Type.FLOAT)
.attribute("volume", Attribute.Type.INT));
executionPlan.addSubscription(subscription);
SiddhiManager siddhiManager = new SiddhiManager();
siddhiManager.setExtension("inputtransport:inMemory", InMemoryInputTransport.class);
<BUG>ExecutionPlanRuntime executionPlanRuntime = siddhiManager.createExecutionPlanRuntime(executionPlan);
executionPlanRuntime.shutdown();</BUG>
}
@Test
public void subscriptionTest3() throws InterruptedException {

.attribute("price", Attribute.Type.FLOAT)
.attribute("volume", Attribute.Type.INT));
executionPlan.addSubscription(subscription);
SiddhiManager siddhiManager = new SiddhiManager();
siddhiManager.setExtension("inputtransport:inMemory", InMemoryInputTransport.class);
ExecutionPlanRuntime executionPlanRuntime = siddhiManager.createExecutionPlanRuntime(executionPlan);
executionPlanRuntime.start();
InMemoryBroker.publish("stock","{'symbol': 'WSO2', 'price': 56.75, 'volume': 5, 'country': 'Sri Lanka'}");
executionPlanRuntime.shutdown();
}
@Test
public void subscriptionTest3() throws InterruptedException {
