[overlord-commits] Overlord SVN: r144 - sam/trunk/src/main/java/org/jboss/sam/simulation.
overlord-commits at lists.jboss.org
overlord-commits at lists.jboss.org
Sun Jul 13 08:33:19 EDT 2008
Author: heiko.braun at jboss.com
Date: 2008-07-13 08:33:18 -0400 (Sun, 13 Jul 2008)
New Revision: 144
Modified:
sam/trunk/src/main/java/org/jboss/sam/simulation/EventSimulation.java
Log:
Allow creation of unbound statements in EventSimulation
Modified: sam/trunk/src/main/java/org/jboss/sam/simulation/EventSimulation.java
===================================================================
--- sam/trunk/src/main/java/org/jboss/sam/simulation/EventSimulation.java 2008-07-13 11:46:12 UTC (rev 143)
+++ sam/trunk/src/main/java/org/jboss/sam/simulation/EventSimulation.java 2008-07-13 12:33:18 UTC (rev 144)
@@ -78,7 +78,7 @@
// Constants
public final static String TOTAL_SIM_TIME = "sam.total-sim-time";
public final static String NUM_UNMATCHED_EVENTS = "sam.unmatched-events";
-
+
private EventSimulation(Properties config, URL bootstrap)
{
// thread setup
@@ -132,9 +132,24 @@
return source;
}
+ /**
+ * Create a aggregation/filtering statement
+ * @param stmt
+ */
+ public void createStatement(String stmt)
+ {
+ this.eventProcessor.registerStatement(
+ UUID.randomUUID().toString(), stmt
+ );
+ }
+
+ /**
+ * Bind a statment that forwards to an EventSink
+ * @param stmt
+ * @param sink
+ */
public void bindStatement(String stmt, EventSinkEntity sink)
{
- // bind the results to a stream output (EventSink)
this.eventProcessor.registerBoundStatement(
sink.getStreamName(), UUID.randomUUID().toString(), stmt
);
@@ -253,6 +268,13 @@
}
}
+ public static EventSimulation bootstrap(Properties config)
+ {
+ return new EventSimulation(config,
+ Thread.currentThread().getContextClassLoader().getResource("samples/esper-default-cfg.xml")
+ );
+ }
+
public static EventSimulation bootstrap(Properties config, URL bootstrap)
{
return new EventSimulation(config, bootstrap);
More information about the overlord-commits
mailing list