[overlord-commits] Overlord SVN: r164 - in sam/trunk: src/test/java/org/jboss/test/sam/samples and 1 other directories.

overlord-commits at lists.jboss.org overlord-commits at lists.jboss.org
Mon Jul 14 15:01:56 EDT 2008


Author: heiko.braun at jboss.com
Date: 2008-07-14 15:01:56 -0400 (Mon, 14 Jul 2008)
New Revision: 164

Added:
   sam/trunk/src/test/java/org/jboss/test/sam/samples/falloff/
   sam/trunk/src/test/java/org/jboss/test/sam/samples/falloff/FalloffTestCase.java
   sam/trunk/src/test/java/org/jboss/test/sam/samples/falloff/ProductionEventMessage.java
Modified:
   sam/trunk/SAM.iws
Log:
Added falloff example

Modified: sam/trunk/SAM.iws
===================================================================
--- sam/trunk/SAM.iws	2008-07-14 17:04:28 UTC (rev 163)
+++ sam/trunk/SAM.iws	2008-07-14 19:01:56 UTC (rev 164)
@@ -21,20 +21,17 @@
     <list default="true" name="Default" comment="">
       <change type="MODIFICATION" beforePath="/home/hbraun/dev/prj/javasim/JavaSim/trunk/src/main/java/org/javasim/internal/SimulationProcessList.java" afterPath="/home/hbraun/dev/prj/javasim/JavaSim/trunk/src/main/java/org/javasim/internal/SimulationProcessList.java" />
       <change type="MODIFICATION" beforePath="/home/hbraun/dev/prj/javasim/JavaSim/trunk/src/main/java/org/javasim/Scheduler.java" afterPath="/home/hbraun/dev/prj/javasim/JavaSim/trunk/src/main/java/org/javasim/Scheduler.java" />
-      <change type="NEW" beforePath="" afterPath="$PROJECT_DIR$/src/test/java/org/jboss/test/sam/samples/aggregation" />
+      <change type="NEW" beforePath="" afterPath="$PROJECT_DIR$/src/test/java/org/jboss/test/sam/samples/falloff/ProductionEventMessage.java" />
       <change type="MODIFICATION" beforePath="/home/hbraun/dev/prj/javasim/JavaSim/trunk/src/main/java/org/javasim/stats/Histogram.java" afterPath="/home/hbraun/dev/prj/javasim/JavaSim/trunk/src/main/java/org/javasim/stats/Histogram.java" />
-      <change type="MODIFICATION" beforePath="$PROJECT_DIR$/src/test/java/org/jboss/test/sam/samples/filtering/FilteringTestCase.java" afterPath="$PROJECT_DIR$/src/test/java/org/jboss/test/sam/samples/filtering/FilteringTestCase.java" />
-      <change type="NEW" beforePath="" afterPath="$PROJECT_DIR$/src/test/java/org/jboss/test/sam/samples/aggregation/AggregationTestCase.java" />
       <change type="NEW" beforePath="" afterPath="/home/hbraun/dev/prj/javasim/JavaSim/trunk/src/main/java/org/javasim/util" />
       <change type="MODIFICATION" beforePath="/home/hbraun/dev/prj/javasim/JavaSim/trunk/src/main/java/org/javasim/stats/SimpleHistogram.java" afterPath="/home/hbraun/dev/prj/javasim/JavaSim/trunk/src/main/java/org/javasim/stats/SimpleHistogram.java" />
       <change type="NEW" beforePath="" afterPath="/home/hbraun/dev/prj/javasim/JavaSim/trunk/src/main/java/org/javasim/util/ThreadUtil.java" />
       <change type="MODIFICATION" beforePath="/home/hbraun/dev/prj/javasim/JavaSim/trunk/pom.xml" afterPath="/home/hbraun/dev/prj/javasim/JavaSim/trunk/pom.xml" />
       <change type="MODIFICATION" beforePath="$PROJECT_DIR$/SAM.iws" afterPath="$PROJECT_DIR$/SAM.iws" />
-      <change type="MODIFICATION" beforePath="$PROJECT_DIR$/src/main/java/org/jboss/sam/simulation/SimulationContext.java" afterPath="$PROJECT_DIR$/src/main/java/org/jboss/sam/simulation/SimulationContext.java" />
+      <change type="NEW" beforePath="" afterPath="$PROJECT_DIR$/src/test/java/org/jboss/test/sam/samples/falloff" />
+      <change type="NEW" beforePath="" afterPath="$PROJECT_DIR$/src/test/java/org/jboss/test/sam/samples/falloff/FalloffTestCase.java" />
       <change type="MODIFICATION" beforePath="/home/hbraun/dev/prj/javasim/JavaSim/trunk/src/main/java/org/javasim/stats/Variance.java" afterPath="/home/hbraun/dev/prj/javasim/JavaSim/trunk/src/main/java/org/javasim/stats/Variance.java" />
-      <change type="MODIFICATION" beforePath="$PROJECT_DIR$/sam-trunk.iml" afterPath="$PROJECT_DIR$/sam-trunk.iml" />
       <change type="MODIFICATION" beforePath="/home/hbraun/dev/prj/javasim/JavaSim/trunk/src/main/java/org/javasim/stats/Mean.java" afterPath="/home/hbraun/dev/prj/javasim/JavaSim/trunk/src/main/java/org/javasim/stats/Mean.java" />
-      <change type="NEW" beforePath="" afterPath="$PROJECT_DIR$/src/test/java/org/jboss/test/sam/samples/aggregation/SalesEventMessage.java" />
       <change type="MODIFICATION" beforePath="/home/hbraun/dev/prj/javasim/JavaSim/trunk/src/main/java/org/javasim/SimulationProcess.java" afterPath="/home/hbraun/dev/prj/javasim/JavaSim/trunk/src/main/java/org/javasim/SimulationProcess.java" />
     </list>
   </component>
@@ -120,7 +117,7 @@
         <option name="CONDITION" value="" />
         <option name="LOG_MESSAGE" value="" />
       </breakpoint>
-      <breakpoint url="file://$PROJECT_DIR$/src/test/java/org/jboss/test/sam/samples/aggregation/AggregationTestCase.java" line="160" class="org.jboss.test.sam.samples.aggregation.AggregationTestCase" package="org.jboss.test.sam.samples.aggregation">
+      <breakpoint url="file://$PROJECT_DIR$/src/test/java/org/jboss/test/sam/samples/falloff/FalloffTestCase.java" line="102" class="Class at FalloffTestCase.java:103" package="org.jboss.test.sam.samples.falloff">
         <option name="ENABLED" value="true" />
         <option name="SUSPEND_POLICY" value="SuspendAll" />
         <option name="LOG_ENABLED" value="false" />
@@ -133,19 +130,6 @@
         <option name="CONDITION" value="" />
         <option name="LOG_MESSAGE" value="" />
       </breakpoint>
-      <breakpoint url="file://$PROJECT_DIR$/src/test/java/org/jboss/test/sam/samples/aggregation/AggregationTestCase.java" line="129" class="Class at AggregationTestCase.java:129" package="org.jboss.test.sam.samples.aggregation">
-        <option name="ENABLED" value="true" />
-        <option name="SUSPEND_POLICY" value="SuspendAll" />
-        <option name="LOG_ENABLED" value="false" />
-        <option name="LOG_EXPRESSION_ENABLED" value="false" />
-        <option name="COUNT_FILTER_ENABLED" value="false" />
-        <option name="COUNT_FILTER" value="0" />
-        <option name="CONDITION_ENABLED" value="false" />
-        <option name="CLASS_FILTERS_ENABLED" value="false" />
-        <option name="INSTANCE_FILTERS_ENABLED" value="false" />
-        <option name="CONDITION" value="" />
-        <option name="LOG_MESSAGE" value="" />
-      </breakpoint>
     </line_breakpoints>
     <breakpoint_any>
       <breakpoint>
@@ -218,10 +202,10 @@
   </component>
   <component name="FileEditorManager">
     <leaf>
-      <file leaf-file-name="AggregationTestCase.java" pinned="false" current="true" current-in-tab="true">
-        <entry file="file://$PROJECT_DIR$/src/test/java/org/jboss/test/sam/samples/aggregation/AggregationTestCase.java">
+      <file leaf-file-name="FalloffTestCase.java" pinned="false" current="true" current-in-tab="true">
+        <entry file="file://$PROJECT_DIR$/src/test/java/org/jboss/test/sam/samples/falloff/FalloffTestCase.java">
           <provider selected="true" editor-type-id="text-editor">
-            <state line="139" column="45" selection-start="4279" selection-end="4279" vertical-scroll-proportion="0.41086188">
+            <state line="77" column="50" selection-start="2447" selection-end="2447" vertical-scroll-proportion="0.3046045">
               <folding>
                 <element signature="imports" expanded="true" />
               </folding>
@@ -584,7 +568,7 @@
           <option name="myItemType" value="com.intellij.ide.projectView.impl.nodes.PsiDirectoryNode" />
         </PATH_ELEMENT>
         <PATH_ELEMENT>
-          <option name="myItemId" value="PsiDirectory:$PROJECT_DIR$/src/test/java/org/jboss/test/sam/samples/filtering" />
+          <option name="myItemId" value="PsiDirectory:$PROJECT_DIR$/src/test/java/org/jboss/test/sam/samples/falloff" />
           <option name="myItemType" value="com.intellij.ide.projectView.impl.nodes.PsiDirectoryNode" />
         </PATH_ELEMENT>
       </PATH>
@@ -606,47 +590,59 @@
           <option name="myItemType" value="com.intellij.ide.projectView.impl.nodes.PsiDirectoryNode" />
         </PATH_ELEMENT>
         <PATH_ELEMENT>
-          <option name="myItemId" value="PsiDirectory:$PROJECT_DIR$/src/main" />
+          <option name="myItemId" value="PsiDirectory:$PROJECT_DIR$/src/test" />
           <option name="myItemType" value="com.intellij.ide.projectView.impl.nodes.PsiDirectoryNode" />
         </PATH_ELEMENT>
-      </PATH>
-      <PATH>
         <PATH_ELEMENT>
-          <option name="myItemId" value="SAM.ipr" />
-          <option name="myItemType" value="com.intellij.ide.projectView.impl.nodes.ProjectViewProjectNode" />
+          <option name="myItemId" value="PsiDirectory:$PROJECT_DIR$/src/test/java" />
+          <option name="myItemType" value="com.intellij.ide.projectView.impl.nodes.PsiDirectoryNode" />
         </PATH_ELEMENT>
         <PATH_ELEMENT>
-          <option name="myItemId" value="sam-trunk" />
-          <option name="myItemType" value="com.intellij.ide.projectView.impl.nodes.ProjectViewModuleNode" />
+          <option name="myItemId" value="PsiDirectory:$PROJECT_DIR$/src/test/java/org" />
+          <option name="myItemType" value="com.intellij.ide.projectView.impl.nodes.PsiDirectoryNode" />
         </PATH_ELEMENT>
         <PATH_ELEMENT>
-          <option name="myItemId" value="PsiDirectory:$PROJECT_DIR$" />
+          <option name="myItemId" value="PsiDirectory:$PROJECT_DIR$/src/test/java/org/jboss" />
           <option name="myItemType" value="com.intellij.ide.projectView.impl.nodes.PsiDirectoryNode" />
         </PATH_ELEMENT>
         <PATH_ELEMENT>
-          <option name="myItemId" value="PsiDirectory:$PROJECT_DIR$/src" />
+          <option name="myItemId" value="PsiDirectory:$PROJECT_DIR$/src/test/java/org/jboss/test" />
           <option name="myItemType" value="com.intellij.ide.projectView.impl.nodes.PsiDirectoryNode" />
         </PATH_ELEMENT>
         <PATH_ELEMENT>
-          <option name="myItemId" value="PsiDirectory:$PROJECT_DIR$/src/main" />
+          <option name="myItemId" value="PsiDirectory:$PROJECT_DIR$/src/test/java/org/jboss/test/sam" />
           <option name="myItemType" value="com.intellij.ide.projectView.impl.nodes.PsiDirectoryNode" />
         </PATH_ELEMENT>
         <PATH_ELEMENT>
-          <option name="myItemId" value="PsiDirectory:$PROJECT_DIR$/src/main/java" />
+          <option name="myItemId" value="PsiDirectory:$PROJECT_DIR$/src/test/java/org/jboss/test/sam/samples" />
           <option name="myItemType" value="com.intellij.ide.projectView.impl.nodes.PsiDirectoryNode" />
         </PATH_ELEMENT>
         <PATH_ELEMENT>
-          <option name="myItemId" value="PsiDirectory:$PROJECT_DIR$/src/main/java/org" />
+          <option name="myItemId" value="PsiDirectory:$PROJECT_DIR$/src/test/java/org/jboss/test/sam/samples/aggregation" />
           <option name="myItemType" value="com.intellij.ide.projectView.impl.nodes.PsiDirectoryNode" />
         </PATH_ELEMENT>
+      </PATH>
+      <PATH>
         <PATH_ELEMENT>
-          <option name="myItemId" value="PsiDirectory:$PROJECT_DIR$/src/main/java/org/jboss" />
+          <option name="myItemId" value="SAM.ipr" />
+          <option name="myItemType" value="com.intellij.ide.projectView.impl.nodes.ProjectViewProjectNode" />
+        </PATH_ELEMENT>
+        <PATH_ELEMENT>
+          <option name="myItemId" value="sam-trunk" />
+          <option name="myItemType" value="com.intellij.ide.projectView.impl.nodes.ProjectViewModuleNode" />
+        </PATH_ELEMENT>
+        <PATH_ELEMENT>
+          <option name="myItemId" value="PsiDirectory:$PROJECT_DIR$" />
           <option name="myItemType" value="com.intellij.ide.projectView.impl.nodes.PsiDirectoryNode" />
         </PATH_ELEMENT>
         <PATH_ELEMENT>
-          <option name="myItemId" value="PsiDirectory:$PROJECT_DIR$/src/main/java/org/jboss/sam" />
+          <option name="myItemId" value="PsiDirectory:$PROJECT_DIR$/src" />
           <option name="myItemType" value="com.intellij.ide.projectView.impl.nodes.PsiDirectoryNode" />
         </PATH_ELEMENT>
+        <PATH_ELEMENT>
+          <option name="myItemId" value="PsiDirectory:$PROJECT_DIR$/src/main" />
+          <option name="myItemType" value="com.intellij.ide.projectView.impl.nodes.PsiDirectoryNode" />
+        </PATH_ELEMENT>
       </PATH>
       <PATH>
         <PATH_ELEMENT>
@@ -685,10 +681,6 @@
           <option name="myItemId" value="PsiDirectory:$PROJECT_DIR$/src/main/java/org/jboss/sam" />
           <option name="myItemType" value="com.intellij.ide.projectView.impl.nodes.PsiDirectoryNode" />
         </PATH_ELEMENT>
-        <PATH_ELEMENT>
-          <option name="myItemId" value="PsiDirectory:$PROJECT_DIR$/src/main/java/org/jboss/sam/simulation" />
-          <option name="myItemType" value="com.intellij.ide.projectView.impl.nodes.PsiDirectoryNode" />
-        </PATH_ELEMENT>
       </PATH>
       <PATH>
         <PATH_ELEMENT>
@@ -796,14 +788,14 @@
     </key>
   </component>
   <component name="RestoreUpdateTree" />
-  <component name="RunManager" selected="JUnit.AggregationTestCase">
-    <tempConfiguration default="false" name="AggregationTestCase" type="JUnit" factoryName="JUnit" enabled="false" merge="false">
-      <pattern value="org.jboss.test.sam.samples.aggregation.*" />
+  <component name="RunManager" selected="JUnit.FalloffTestCase">
+    <tempConfiguration default="false" name="FalloffTestCase" type="JUnit" factoryName="JUnit" enabled="false" merge="false">
+      <pattern value="org.jboss.test.sam.samples.falloff.*" />
       <module name="sam-trunk" />
       <option name="ALTERNATIVE_JRE_PATH_ENABLED" value="false" />
       <option name="ALTERNATIVE_JRE_PATH" />
-      <option name="PACKAGE_NAME" value="org.jboss.test.sam.samples.aggregation" />
-      <option name="MAIN_CLASS_NAME" value="org.jboss.test.sam.samples.aggregation.AggregationTestCase" />
+      <option name="PACKAGE_NAME" value="org.jboss.test.sam.samples.falloff" />
+      <option name="MAIN_CLASS_NAME" value="org.jboss.test.sam.samples.falloff.FalloffTestCase" />
       <option name="METHOD_NAME" />
       <option name="TEST_OBJECT" value="class" />
       <option name="VM_PARAMETERS" />
@@ -814,7 +806,7 @@
         <value defaultName="wholeProject" />
       </option>
       <RunnerSettings RunnerId="Debug">
-        <option name="DEBUG_PORT" value="44090" />
+        <option name="DEBUG_PORT" value="41877" />
         <option name="TRANSPORT" value="0" />
         <option name="LOCAL" value="true" />
       </RunnerSettings>
@@ -1116,20 +1108,6 @@
     <option name="myLastEditedConfigurable" value="IDE Profiles" />
   </component>
   <component name="editorHistoryManager">
-    <entry file="file://$PROJECT_DIR$/src/main/java/org/jboss/sam/internal/esper/EventAdapter.java">
-      <provider selected="true" editor-type-id="text-editor">
-        <state line="101" column="50" selection-start="2690" selection-end="2690" vertical-scroll-proportion="0.6875754">
-          <folding />
-        </state>
-      </provider>
-    </entry>
-    <entry file="file://$PROJECT_DIR$/src/test/java/org/jboss/test/sam/simulation/SensorMessageFactory.java">
-      <provider selected="true" editor-type-id="text-editor">
-        <state line="52" column="4" selection-start="1680" selection-end="1846" vertical-scroll-proportion="0.64173704">
-          <folding />
-        </state>
-      </provider>
-    </entry>
     <entry file="file://$PROJECT_DIR$/src/main/java/org/jboss/sam/internal/esper/EsperRuntimeImpl.java">
       <provider selected="true" editor-type-id="text-editor">
         <state line="109" column="0" selection-start="3486" selection-end="3486" vertical-scroll-proportion="0.02291918">
@@ -1209,20 +1187,36 @@
     </entry>
     <entry file="file://$PROJECT_DIR$/src/test/java/org/jboss/test/sam/samples/filtering/FilteringTestCase.java">
       <provider selected="true" editor-type-id="text-editor">
-        <state line="77" column="39" selection-start="2481" selection-end="2481" vertical-scroll-proportion="0.21487603">
+        <state line="149" column="35" selection-start="1729" selection-end="4767" vertical-scroll-proportion="0.7756789">
           <folding />
         </state>
       </provider>
     </entry>
     <entry file="file://$PROJECT_DIR$/src/test/java/org/jboss/test/sam/samples/aggregation/AggregationTestCase.java">
       <provider selected="true" editor-type-id="text-editor">
-        <state line="139" column="45" selection-start="4279" selection-end="4279" vertical-scroll-proportion="0.41086188">
+        <state line="129" column="0" selection-start="3941" selection-end="3941" vertical-scroll-proportion="0.05785124">
           <folding>
             <element signature="imports" expanded="true" />
           </folding>
         </state>
       </provider>
     </entry>
+    <entry file="file://$PROJECT_DIR$/src/test/java/org/jboss/test/sam/samples/falloff/ProductionEventMessage.java">
+      <provider selected="true" editor-type-id="text-editor">
+        <state line="46" column="0" selection-start="1467" selection-end="1467" vertical-scroll-proportion="0.58323497">
+          <folding />
+        </state>
+      </provider>
+    </entry>
+    <entry file="file://$PROJECT_DIR$/src/test/java/org/jboss/test/sam/samples/falloff/FalloffTestCase.java">
+      <provider selected="true" editor-type-id="text-editor">
+        <state line="77" column="50" selection-start="2447" selection-end="2447" vertical-scroll-proportion="0.3046045">
+          <folding>
+            <element signature="imports" expanded="true" />
+          </folding>
+        </state>
+      </provider>
+    </entry>
   </component>
 </project>
 

Added: sam/trunk/src/test/java/org/jboss/test/sam/samples/falloff/FalloffTestCase.java
===================================================================
--- sam/trunk/src/test/java/org/jboss/test/sam/samples/falloff/FalloffTestCase.java	                        (rev 0)
+++ sam/trunk/src/test/java/org/jboss/test/sam/samples/falloff/FalloffTestCase.java	2008-07-14 19:01:56 UTC (rev 164)
@@ -0,0 +1,141 @@
+/*
+ * JBoss, Home of Professional Open Source.
+ * Copyright 2006, Red Hat Middleware LLC, and individual contributors
+ * as indicated by the @author tags. See the copyright.txt file in the
+ * distribution for a full listing of individual contributors.
+ *
+ * This is free software; you can redistribute it and/or modify it
+ * under the terms of the GNU Lesser General Public License as
+ * published by the Free Software Foundation; either version 2.1 of
+ * the License, or (at your option) any later version.
+ *
+ * This software is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
+ * Lesser General Public License for more details.
+ *
+ * You should have received a copy of the GNU Lesser General Public
+ * License along with this software; if not, write to the Free
+ * Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
+ * 02110-1301 USA, or see the FSF site: http://www.fsf.org.
+ */
+package org.jboss.test.sam.samples.falloff;
+
+import junit.framework.TestCase;
+import org.jboss.sam.EventMessage;
+import org.jboss.sam.simulation.*;
+
+import java.util.*;
+
+/**
+ * A sample that demonstrates falloff detection.
+ *
+ * @author Heiko.Braun <heiko.braun at jboss.com>
+ */
+public class FalloffTestCase extends TestCase
+{
+   EventSimulation simulation;
+   SimulationContext context;
+
+   EventSourceEntity source;
+   EventSinkEntity sink;
+
+   protected void setUp() throws Exception
+   {
+      // config
+      Properties config = new Properties();
+      config.put(EventSimulation.TOTAL_SIM_TIME, 100.00);
+
+      // init
+      simulation = EventSimulation.bootstrap(config);
+
+      // shared between all entities
+      context = simulation.getContext();
+
+      // create an event source and sink
+      source = new EventSourceEntity("FactoryLine", 0.03);
+      sink = new EventSinkEntity("ProductionRateMonitor");
+
+   }
+
+   protected void tearDown() throws Exception
+   {
+      simulation.done();
+   }
+
+   @SuppressWarnings({"unchecked"})
+   public void testEventFiltering()
+   {
+      // associate a source factory
+      source.setEventMessageFactory(
+        new EventMessageFactory()
+        {
+           Calendar c = new GregorianCalendar();
+           int numMessages = 0;
+
+           public Object createEventMessage(SimulationContext context)
+           {
+              context.getMeasurement("dispatched").increment();
+
+              // simulate a falloff after 20 messages. Production goes down 50%...
+              if(numMessages<20)
+                 c.add(Calendar.SECOND, 3);
+              else
+                 c.add(Calendar.SECOND, 6);
+
+              long ts = c.getTimeInMillis();
+
+              ProductionEventMessage productionRate = new ProductionEventMessage("Assembly Line-A", ts);
+              numMessages++;
+              return productionRate;
+           }
+        }
+      );
+
+      // associate a sink handler
+      sink.setEventHandler(
+        new EventSinkHandler()
+        {
+           public void handle(EventMessage[] events, SimulationContext context)
+           {
+              if(null==context.getAttachment(List.class))
+                 context.addAttachment(List.class, new ArrayList<EventMessage>());
+
+              context.getAttachment(List.class).addAll(Arrays.asList(events));
+              context.getMeasurement("processed").increment();
+           }
+        }
+      );
+
+      simulation.addSource(source);
+      simulation.addSink(sink);
+
+      // Filters high value orders with amount>5
+      simulation.createStatement("insert into RatePerTenSeconds " +
+        "select line, count(*) as cnt " +
+        "from org.jboss.test.sam.samples.falloff.ProductionEventMessage" +
+        ".win:ext_timed(timestamp, 10 seconds)");
+
+      // Forward any highvalue order to the monitor
+      simulation.bindStatement("select line, avg(cnt) as avgCnt " +
+        "from RatePerTenSeconds.win:length(6) " +
+        "group by line " +
+        "having cnt < avg(cnt) * 0.75", sink);
+      
+      // start simulation
+      simulation.singleRun();
+
+      // display status
+      context.dump(System.out);
+
+      // evaluate results
+      List<EventMessage> eventMessages = context.getAttachment(List.class);
+      assertNotNull(eventMessages);
+      assertTrue(eventMessages.size()>=1);
+
+      for(EventMessage e : eventMessages)
+      {
+         System.out.println(e.getProperty("line")+": " + e.getProperty("avgCnt"));
+      }
+   }
+}


Property changes on: sam/trunk/src/test/java/org/jboss/test/sam/samples/falloff/FalloffTestCase.java
___________________________________________________________________
Name: svn:keywords
   + Id Revision
Name: svn:eol-style
   + LF

Added: sam/trunk/src/test/java/org/jboss/test/sam/samples/falloff/ProductionEventMessage.java
===================================================================
--- sam/trunk/src/test/java/org/jboss/test/sam/samples/falloff/ProductionEventMessage.java	                        (rev 0)
+++ sam/trunk/src/test/java/org/jboss/test/sam/samples/falloff/ProductionEventMessage.java	2008-07-14 19:01:56 UTC (rev 164)
@@ -0,0 +1,48 @@
+/*
+ * JBoss, Home of Professional Open Source.
+ * Copyright 2006, Red Hat Middleware LLC, and individual contributors
+ * as indicated by the @author tags. See the copyright.txt file in the
+ * distribution for a full listing of individual contributors.
+ *
+ * This is free software; you can redistribute it and/or modify it
+ * under the terms of the GNU Lesser General Public License as
+ * published by the Free Software Foundation; either version 2.1 of
+ * the License, or (at your option) any later version.
+ *
+ * This software is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
+ * Lesser General Public License for more details.
+ *
+ * You should have received a copy of the GNU Lesser General Public
+ * License along with this software; if not, write to the Free
+ * Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
+ * 02110-1301 USA, or see the FSF site: http://www.fsf.org.
+ */
+package org.jboss.test.sam.samples.falloff;
+
+/**
+ * @author Heiko.Braun <heiko.braun at jboss.com>
+ */
+public final class ProductionEventMessage
+{
+   String line;
+   long timestamp;
+
+   public ProductionEventMessage(String line, long timestamp)
+   {
+      this.line = line;
+      this.timestamp = timestamp;
+   }
+
+   public String getLine()
+   {
+      return line;
+   }
+   
+   public long getTimestamp()
+   {
+      return timestamp;
+   }
+
+}


Property changes on: sam/trunk/src/test/java/org/jboss/test/sam/samples/falloff/ProductionEventMessage.java
___________________________________________________________________
Name: svn:keywords
   + Id Revision
Name: svn:eol-style
   + LF




More information about the overlord-commits mailing list