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>
+ */
+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>
+ */
+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