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

Author: heiko.braun(a)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(a)jboss.com&gt; + */ +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(a)jboss.com&gt; + */ +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