[overlord-commits] Overlord SVN: r157 - 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 11:48:05 EDT 2008
Author: heiko.braun at jboss.com
Date: 2008-07-14 11:48:05 -0400 (Mon, 14 Jul 2008)
New Revision: 157
Added:
sam/trunk/src/test/java/org/jboss/test/sam/samples/filtering/
sam/trunk/src/test/java/org/jboss/test/sam/samples/filtering/FilteringTestCase.java
sam/trunk/src/test/java/org/jboss/test/sam/samples/filtering/OrderEventMessage.java
Removed:
sam/trunk/src/test/java/org/jboss/test/sam/samples/aggregation/
sam/trunk/src/test/java/org/jboss/test/sam/samples/filtering/AggregationTestCase.java
sam/trunk/src/test/java/org/jboss/test/sam/samples/filtering/OrderEventMessage.java
Modified:
sam/trunk/SAM.iws
Log:
The aggregation sample was actually a filter sample
Modified: sam/trunk/SAM.iws
===================================================================
--- sam/trunk/SAM.iws 2008-07-14 15:45:24 UTC (rev 156)
+++ sam/trunk/SAM.iws 2008-07-14 15:48:05 UTC (rev 157)
@@ -22,17 +22,19 @@
<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="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/pattern/PatternTestCase.java" afterPath="$PROJECT_DIR$/src/test/java/org/jboss/test/sam/samples/pattern/PatternTestCase.java" />
- <change type="MODIFICATION" beforePath="$PROJECT_DIR$/src/test/java/org/jboss/test/sam/samples/aggregation/AggregationTestCase.java" afterPath="$PROJECT_DIR$/src/test/java/org/jboss/test/sam/samples/aggregation/AggregationTestCase.java" />
- <change type="MODIFICATION" beforePath="$PROJECT_DIR$/src/main/java/org/jboss/sam/simulation/EventSimulation.java" afterPath="$PROJECT_DIR$/src/main/java/org/jboss/sam/simulation/EventSimulation.java" />
+ <change type="DELETED" beforePath="$PROJECT_DIR$/src/test/java/org/jboss/test/sam/samples/aggregation/OrderEventMessage.java" afterPath="" />
+ <change type="DELETED" beforePath="$PROJECT_DIR$/src/test/java/org/jboss/test/sam/samples/aggregation" afterPath="" />
+ <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" />
- <change type="MODIFICATION" beforePath="$PROJECT_DIR$/src/test/java/org/jboss/test/sam/simulation/SimulationTestCase.java" afterPath="$PROJECT_DIR$/src/test/java/org/jboss/test/sam/simulation/SimulationTestCase.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="NEW" beforePath="" afterPath="/home/hbraun/dev/prj/javasim/JavaSim/trunk/src/main/java/org/javasim/util/ThreadUtil.java" />
<change type="MODIFICATION" beforePath="$PROJECT_DIR$/SAM.iws" afterPath="$PROJECT_DIR$/SAM.iws" />
<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="DELETED" beforePath="$PROJECT_DIR$/src/test/java/org/jboss/test/sam/samples/filtering/AggregationTestCase.java" afterPath="" />
+ <change type="NEW" beforePath="" afterPath="$PROJECT_DIR$/src/test/java/org/jboss/test/sam/samples/filtering" />
+ <change type="DELETED" beforePath="$PROJECT_DIR$/src/test/java/org/jboss/test/sam/samples/aggregation/AggregationTestCase.java" afterPath="" />
<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/filtering/FilteringTestCase.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>
@@ -190,10 +192,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="FilteringTestCase.java" pinned="false" current="true" current-in-tab="true">
+ <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="125" column="45" selection-start="3958" selection-end="3958" vertical-scroll-proportion="2.153483">
+ <state line="129" column="16" selection-start="4033" selection-end="4033" vertical-scroll-proportion="0.76269186">
<folding />
</state>
</provider>
@@ -640,7 +642,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/aggregation" />
+ <option name="myItemId" value="PsiDirectory:$PROJECT_DIR$/src/test/java/org/jboss/test/sam/samples/filtering" />
<option name="myItemType" value="com.intellij.ide.projectView.impl.nodes.PsiDirectoryNode" />
</PATH_ELEMENT>
</PATH>
@@ -665,6 +667,30 @@
<option name="myItemId" value="PsiDirectory:$PROJECT_DIR$/src/test" />
<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" />
+ <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" />
+ <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" />
+ <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" />
+ <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" />
+ <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" />
+ <option name="myItemType" value="com.intellij.ide.projectView.impl.nodes.PsiDirectoryNode" />
+ </PATH_ELEMENT>
</PATH>
<PATH>
<PATH_ELEMENT>
@@ -684,6 +710,28 @@
<option name="myItemType" value="com.intellij.ide.projectView.impl.nodes.PsiDirectoryNode" />
</PATH_ELEMENT>
<PATH_ELEMENT>
+ <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" />
+ </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" />
+ <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>
@@ -1228,13 +1276,6 @@
</state>
</provider>
</entry>
- <entry file="file://$PROJECT_DIR$/src/test/java/org/jboss/test/sam/samples/aggregation/OrderEventMessage.java">
- <provider selected="true" editor-type-id="text-editor">
- <state line="26" column="19" selection-start="1155" selection-end="1155" vertical-scroll-proportion="0.13751508">
- <folding />
- </state>
- </provider>
- </entry>
<entry file="file://$PROJECT_DIR$/src/main/java/org/jboss/sam/EventProcessorFactory.java">
<provider selected="true" editor-type-id="text-editor">
<state line="41" column="34" selection-start="1429" selection-end="1429" vertical-scroll-proportion="0.4354644">
@@ -1270,9 +1311,9 @@
</state>
</provider>
</entry>
- <entry file="file://$PROJECT_DIR$/src/test/java/org/jboss/test/sam/samples/aggregation/AggregationTestCase.java">
+ <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="125" column="45" selection-start="3958" selection-end="3958" vertical-scroll-proportion="2.153483">
+ <state line="129" column="16" selection-start="4033" selection-end="4033" vertical-scroll-proportion="0.76269186">
<folding />
</state>
</provider>
Copied: sam/trunk/src/test/java/org/jboss/test/sam/samples/filtering (from rev 154, sam/trunk/src/test/java/org/jboss/test/sam/samples/aggregation)
Deleted: sam/trunk/src/test/java/org/jboss/test/sam/samples/filtering/AggregationTestCase.java
===================================================================
--- sam/trunk/src/test/java/org/jboss/test/sam/samples/aggregation/AggregationTestCase.java 2008-07-14 14:21:06 UTC (rev 154)
+++ sam/trunk/src/test/java/org/jboss/test/sam/samples/filtering/AggregationTestCase.java 2008-07-14 15:48:05 UTC (rev 157)
@@ -1,155 +0,0 @@
-/*
- * 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.aggregation;
-
-import junit.framework.TestCase;
-import org.jboss.sam.EventMessage;
-import org.jboss.sam.simulation.*;
-import org.javasim.streams.UniformStream;
-
-import java.util.ArrayList;
-import java.util.Arrays;
-import java.util.List;
-import java.util.Properties;
-import java.io.IOException;
-
-/**
- * A simple aggregation sample that uses two statments:
- * <ul>
- * <li>One to aggregate high value orders (unbound)
- * <li>Anotherone that forwards the aggregated results to a monitor (bound)
- * </ul>
- *
- * @author Heiko.Braun <heiko.braun at jboss.com>
- */
-public class AggregationTestCase 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, 75.00);
-
- // init
- simulation = EventSimulation.bootstrap(config);
-
- // shared between all entities
- context = simulation.getContext();
-
- // create an event source and sink
- source = new EventSourceEntity("OrderEventSource", 0.10);
- sink = new EventSinkEntity("HighValueMonitor");
-
- }
-
- protected void tearDown() throws Exception
- {
- simulation.done();
- }
-
- public void testEventAggregation()
- {
- // associate a source factory
- source.setEventMessageFactory(
- new EventMessageFactory()
- {
- boolean singleMatchEnforced;
- UniformStream unitStream = new UniformStream(1,10);
-
- public Object createEventMessage(SimulationContext context)
- {
- context.getMeasurement("dispatched").increment();
-
- // we need at least a single match for the test case
- long amount = singleMatchEnforced ? calcAmount() : 10;
- if(!singleMatchEnforced) singleMatchEnforced = true;
-
- OrderEventMessage order = new OrderEventMessage("Stereo", amount);
- return order;
- }
-
- public long calcAmount()
- {
- try
- {
- double value = Math.floor(unitStream.getNumber());
- return new Double(value).longValue();
- }
- catch (IOException e)
- {
- return 1;
- }
- }
-
- }
- );
-
- // 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);
-
- // Aggregates high value orders with amount>5
- simulation.createStatement("insert into HighValueOrders " +
- "select * from org.jboss.test.sam.samples.aggregation.OrderEventMessage as o " +
- "where o.amount>5");
-
- // Forward any highvalue order to the HighValueMonitor
- simulation.bindStatement("select * from HighValueOrders", sink);
-
- // start simulation
- simulation.singleRun();
-
- // display status
- printStatus();
-
- // evaluate results
- List<EventMessage> aggregatedMessages = context.getAttachment(List.class);
- assertNotNull(aggregatedMessages);
- assertTrue(aggregatedMessages.size()>=1);
- }
-
- private void printStatus()
- {
- System.out.println("Dispatched: "+context.getMeasurement("dispatched"));
- System.out.println("Processed: "+context.getMeasurement("processed"));
- }
-}
Added: sam/trunk/src/test/java/org/jboss/test/sam/samples/filtering/FilteringTestCase.java
===================================================================
--- sam/trunk/src/test/java/org/jboss/test/sam/samples/filtering/FilteringTestCase.java (rev 0)
+++ sam/trunk/src/test/java/org/jboss/test/sam/samples/filtering/FilteringTestCase.java 2008-07-14 15:48:05 UTC (rev 157)
@@ -0,0 +1,155 @@
+/*
+ * 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.aggregation;
+
+import junit.framework.TestCase;
+import org.javasim.streams.UniformStream;
+import org.jboss.sam.EventMessage;
+import org.jboss.sam.simulation.*;
+
+import java.io.IOException;
+import java.util.ArrayList;
+import java.util.Arrays;
+import java.util.List;
+import java.util.Properties;
+
+/**
+ * A simple filter sample that uses two statements:
+ * <ul>
+ * <li>One statement to filter high value orders (unbound)
+ * <li>Anotherone that forwards the results to a monitor (bound)
+ * </ul>
+ *
+ * @author Heiko.Braun <heiko.braun at jboss.com>
+ */
+public class FilteringTestCase 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, 75.00);
+
+ // init
+ simulation = EventSimulation.bootstrap(config);
+
+ // shared between all entities
+ context = simulation.getContext();
+
+ // create an event source and sink
+ source = new EventSourceEntity("OrderEventSource", 0.10);
+ sink = new EventSinkEntity("HighValueMonitor");
+
+ }
+
+ protected void tearDown() throws Exception
+ {
+ simulation.done();
+ }
+
+ public void testEventAggregation()
+ {
+ // associate a source factory
+ source.setEventMessageFactory(
+ new EventMessageFactory()
+ {
+ boolean singleMatchEnforced;
+ UniformStream unitStream = new UniformStream(1,10);
+
+ public Object createEventMessage(SimulationContext context)
+ {
+ context.getMeasurement("dispatched").increment();
+
+ // we need at least a single match for the test case
+ long amount = singleMatchEnforced ? calcAmount() : 10;
+ if(!singleMatchEnforced) singleMatchEnforced = true;
+
+ OrderEventMessage order = new OrderEventMessage("Stereo", amount);
+ return order;
+ }
+
+ public long calcAmount()
+ {
+ try
+ {
+ double value = Math.floor(unitStream.getNumber());
+ return new Double(value).longValue();
+ }
+ catch (IOException e)
+ {
+ return 1;
+ }
+ }
+
+ }
+ );
+
+ // 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 HighValueOrders " +
+ "select * from org.jboss.test.sam.samples.aggregation.OrderEventMessage as o " +
+ "where o.amount>5");
+
+ // Forward any highvalue order to the HighValueMonitor
+ simulation.bindStatement("select * from HighValueOrders", sink);
+
+ // start simulation
+ simulation.singleRun();
+
+ // display status
+ printStatus();
+
+ // evaluate results
+ List<EventMessage> aggregatedMessages = context.getAttachment(List.class);
+ assertNotNull(aggregatedMessages);
+ assertTrue(aggregatedMessages.size()>=1);
+ }
+
+ private void printStatus()
+ {
+ System.out.println("Dispatched: "+context.getMeasurement("dispatched"));
+ System.out.println("Processed: "+context.getMeasurement("processed"));
+ }
+}
Property changes on: sam/trunk/src/test/java/org/jboss/test/sam/samples/filtering/FilteringTestCase.java
___________________________________________________________________
Name: svn:keywords
+ Id Revision
Name: svn:eol-style
+ LF
Deleted: sam/trunk/src/test/java/org/jboss/test/sam/samples/filtering/OrderEventMessage.java
===================================================================
--- sam/trunk/src/test/java/org/jboss/test/sam/samples/aggregation/OrderEventMessage.java 2008-07-14 14:21:06 UTC (rev 154)
+++ sam/trunk/src/test/java/org/jboss/test/sam/samples/filtering/OrderEventMessage.java 2008-07-14 15:48:05 UTC (rev 157)
@@ -1,57 +0,0 @@
-/*
- * 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.aggregation;
-
-/**
- * @author Heiko.Braun <heiko.braun at jboss.com>
- */
-public final class OrderEventMessage
-{
- private String product;
- private long amount;
-
- public OrderEventMessage(String product, long amount)
- {
- this.product = product;
- this.amount = amount;
- }
-
- public String getProduct()
- {
- return product;
- }
-
- public void setProduct(String product)
- {
- this.product = product;
- }
-
- public long getAmount()
- {
- return amount;
- }
-
- public void setAmount(long amount)
- {
- this.amount = amount;
- }
-}
Copied: sam/trunk/src/test/java/org/jboss/test/sam/samples/filtering/OrderEventMessage.java (from rev 156, sam/trunk/src/test/java/org/jboss/test/sam/samples/aggregation/OrderEventMessage.java)
===================================================================
--- sam/trunk/src/test/java/org/jboss/test/sam/samples/filtering/OrderEventMessage.java (rev 0)
+++ sam/trunk/src/test/java/org/jboss/test/sam/samples/filtering/OrderEventMessage.java 2008-07-14 15:48:05 UTC (rev 157)
@@ -0,0 +1,57 @@
+/*
+ * 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.aggregation;
+
+/**
+ * @author Heiko.Braun <heiko.braun at jboss.com>
+ */
+public final class OrderEventMessage
+{
+ private String product;
+ private long amount;
+
+ public OrderEventMessage(String product, long amount)
+ {
+ this.product = product;
+ this.amount = amount;
+ }
+
+ public String getProduct()
+ {
+ return product;
+ }
+
+ public void setProduct(String product)
+ {
+ this.product = product;
+ }
+
+ public long getAmount()
+ {
+ return amount;
+ }
+
+ public void setAmount(long amount)
+ {
+ this.amount = amount;
+ }
+}
More information about the overlord-commits
mailing list