Author: heiko.braun(a)jboss.com Date: 2008-07-03 03:30:56 -0400 (Thu, 03 Jul 2008) New Revision: 106 Added: sam/trunk/src/main/java/org/jboss/sam/ProcessingStatement.java sam/trunk/src/main/java/org/jboss/sam/internal/esper/EsperProcessingStatement.java Removed: sam/trunk/src/main/java/org/jboss/sam/Statement.java sam/trunk/src/main/java/org/jboss/sam/internal/esper/EsperStatement.java Modified: sam/trunk/SAM.iws sam/trunk/src/main/java/org/jboss/sam/EventProcessor.java sam/trunk/src/main/java/org/jboss/sam/internal/esper/EsperRuntimeImpl.java sam/trunk/src/test/java/org/jboss/test/sam/adapter/invm/InVMAdapterTestCase.java sam/trunk/src/test/java/org/jboss/test/sam/database/DatabaseTestCase.java Log: Rename Statement to ProcessingStatement Modified: sam/trunk/SAM.iws =================================================================== --- sam/trunk/SAM.iws 2008-07-03 07:27:35 UTC (rev 105) +++ sam/trunk/SAM.iws 2008-07-03 07:30:56 UTC (rev 106) @@ -172,10 +172,10 @@ </component> <component name="FileEditorManager"> <leaf> - <file leaf-file-name="Statement.java" pinned="false" current="false" current-in-tab="false"> - <entry file="file://$PROJECT_DIR$/src/main/java/org/jboss/sam/Statement.java"> + <file leaf-file-name="ProcessingStatement.java" pinned="false" current="true" current-in-tab="true"> + <entry file="file://$PROJECT_DIR$/src/main/java/org/jboss/sam/ProcessingStatement.java"> <provider selected="true" editor-type-id="text-editor"> - <state line="31" column="23" selection-start="1400" selection-end="1400" vertical-scroll-proportion="0.2413793"> + <state line="31" column="17" selection-start="1394" selection-end="1394" vertical-scroll-proportion="0.252111"> <folding /> </state> </provider> @@ -184,16 +184,16 @@ <file leaf-file-name="EsperRuntimeImpl.java" pinned="false" current="false" current-in-tab="false"> <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="122" column="53" selection-start="4202" selection-end="4202" vertical-scroll-proportion="0.36660618"> + <state line="122" column="53" selection-start="4272" selection-end="4272" vertical-scroll-proportion="0.24366707"> <folding /> </state> </provider> </entry> </file> - <file leaf-file-name="EsperStatement.java" pinned="false" current="true" current-in-tab="true"> - <entry file="file://$PROJECT_DIR$/src/main/java/org/jboss/sam/internal/esper/EsperStatement.java"> + <file leaf-file-name="EsperProcessingStatement.java" pinned="false" current="false" current-in-tab="false"> + <entry file="file://$PROJECT_DIR$/src/main/java/org/jboss/sam/internal/esper/EsperProcessingStatement.java"> <provider selected="true" editor-type-id="text-editor"> - <state line="32" column="0" selection-start="1303" selection-end="1303" vertical-scroll-proportion="0.41379312"> + <state line="32" column="0" selection-start="1333" selection-end="1333" vertical-scroll-proportion="0.27503017"> <folding> <element signature="imports" expanded="true" /> </folding> @@ -201,19 +201,37 @@ </provider> </entry> </file> + <file leaf-file-name="StreamInputCallback.java" pinned="false" current="false" current-in-tab="false"> + <entry file="file://$PROJECT_DIR$/src/main/java/org/jboss/sam/StreamInputCallback.java"> + <provider selected="true" editor-type-id="text-editor"> + <state line="28" column="17" selection-start="1218" selection-end="1218" vertical-scroll-proportion="0.18335344"> + <folding /> + </state> + </provider> + </entry> + </file> <file leaf-file-name="StreamOutput.java" pinned="false" current="false" current-in-tab="false"> <entry file="file://$PROJECT_DIR$/src/main/java/org/jboss/sam/StreamOutput.java"> <provider selected="true" editor-type-id="text-editor"> - <state line="30" column="17" selection-start="1321" selection-end="1321" vertical-scroll-proportion="0.3448276"> + <state line="42" column="20" selection-start="1542" selection-end="1542" vertical-scroll-proportion="0.504222"> <folding /> </state> </provider> </entry> </file> + <file leaf-file-name="EventMessage.java" pinned="false" current="false" current-in-tab="false"> + <entry file="file://$PROJECT_DIR$/src/main/java/org/jboss/sam/EventMessage.java"> + <provider selected="true" editor-type-id="text-editor"> + <state line="46" column="49" selection-start="1593" selection-end="1593" vertical-scroll-proportion="0.5958987"> + <folding /> + </state> + </provider> + </entry> + </file> <file leaf-file-name="EventProcessor.java" pinned="false" current="false" current-in-tab="false"> <entry file="file://$PROJECT_DIR$/src/main/java/org/jboss/sam/EventProcessor.java"> <provider selected="true" editor-type-id="text-editor"> - <state line="31" column="45" selection-start="1436" selection-end="1436" vertical-scroll-proportion="0.03448276"> + <state line="31" column="3" selection-start="1445" selection-end="1445" vertical-scroll-proportion="0.02291918"> <folding /> </state> </provider> @@ -660,7 +678,7 @@ <window_info id="Changes" active="false" anchor="bottom" auto_hide="false" internal_type="DOCKED" type="DOCKED" visible="false" weight="0.33" order="8" /> <window_info id="Palette" active="false" anchor="right" auto_hide="false" internal_type="DOCKED" type="DOCKED" visible="false" weight="0.33" order="3" /> <window_info id="Ant Build" active="false" anchor="right" auto_hide="false" internal_type="DOCKED" type="DOCKED" visible="false" weight="0.25" order="1" /> - <window_info id="Find" active="false" anchor="bottom" auto_hide="false" internal_type="DOCKED" type="DOCKED" visible="true" weight="0.32915717" order="1" /> + <window_info id="Find" active="false" anchor="bottom" auto_hide="false" internal_type="DOCKED" type="DOCKED" visible="false" weight="0.32915717" order="1" /> <window_info id="Debug" active="false" anchor="bottom" auto_hide="false" internal_type="DOCKED" type="DOCKED" visible="false" weight="0.39863327" order="3" /> <window_info id="IDEtalk Messages" active="false" anchor="bottom" auto_hide="false" internal_type="DOCKED" type="DOCKED" visible="false" weight="0.33" order="8" /> <window_info id="IDEtalk" active="false" anchor="right" auto_hide="false" internal_type="DOCKED" type="DOCKED" visible="false" weight="0.33" order="3" /> @@ -764,13 +782,6 @@ <option name="myLastEditedConfigurable" /> </component> <component name="editorHistoryManager"> - <entry file="file://$PROJECT_DIR$/src/main/java/org/jboss/sam/chart/PropertyMapping.java"> - <provider selected="true" editor-type-id="text-editor"> - <state line="36" column="19" selection-start="1386" selection-end="1386" vertical-scroll-proportion="-0.39806998"> - <folding /> - </state> - </provider> - </entry> <entry file="file://$PROJECT_DIR$/src/test/java/org/jboss/test/sam/sim/EventSourceEntity.java"> <provider selected="true" editor-type-id="text-editor"> <state line="34" column="13" selection-start="1418" selection-end="1418" vertical-scroll-proportion="0.1794569"> @@ -792,13 +803,6 @@ </state> </provider> </entry> - <entry file="file://$PROJECT_DIR$/src/main/java/org/jboss/sam/StreamInputCallback.java"> - <provider selected="true" editor-type-id="text-editor"> - <state line="28" column="17" selection-start="1218" selection-end="1218" vertical-scroll-proportion="0.1794569"> - <folding /> - </state> - </provider> - </entry> <entry file="file://$PROJECT_DIR$/src/test/java/org/jboss/test/sam/sim/EventProcessorEntity.java"> <provider selected="true" editor-type-id="text-editor"> <state line="37" column="13" selection-start="1593" selection-end="1593" vertical-scroll-proportion="0.022432113"> @@ -836,41 +840,55 @@ </entry> <entry file="file://$PROJECT_DIR$/src/main/java/org/jboss/sam/EventProcessor.java"> <provider selected="true" editor-type-id="text-editor"> - <state line="31" column="45" selection-start="1436" selection-end="1436" vertical-scroll-proportion="0.03448276"> + <state line="31" column="3" selection-start="1445" selection-end="1445" vertical-scroll-proportion="0.02291918"> <folding /> </state> </provider> </entry> - <entry file="file://$PROJECT_DIR$/src/main/java/org/jboss/sam/StreamOutput.java"> + <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="30" column="17" selection-start="1321" selection-end="1321" vertical-scroll-proportion="0.3448276"> + <state line="122" column="53" selection-start="4272" selection-end="4272" vertical-scroll-proportion="0.24366707"> <folding /> </state> </provider> </entry> - <entry file="file://$PROJECT_DIR$/src/main/java/org/jboss/sam/internal/esper/EsperRuntimeImpl.java"> + <entry file="file://$PROJECT_DIR$/src/main/java/org/jboss/sam/internal/esper/EsperProcessingStatement.java"> <provider selected="true" editor-type-id="text-editor"> - <state line="122" column="53" selection-start="4202" selection-end="4202" vertical-scroll-proportion="0.36660618"> + <state line="32" column="0" selection-start="1333" selection-end="1333" vertical-scroll-proportion="0.27503017"> + <folding> + <element signature="imports" expanded="true" /> + </folding> + </state> + </provider> + </entry> + <entry file="file://$PROJECT_DIR$/src/main/java/org/jboss/sam/StreamInputCallback.java"> + <provider selected="true" editor-type-id="text-editor"> + <state line="28" column="17" selection-start="1218" selection-end="1218" vertical-scroll-proportion="0.18335344"> <folding /> </state> </provider> </entry> - <entry file="file://$PROJECT_DIR$/src/main/java/org/jboss/sam/Statement.java"> + <entry file="file://$PROJECT_DIR$/src/main/java/org/jboss/sam/StreamOutput.java"> <provider selected="true" editor-type-id="text-editor"> - <state line="31" column="23" selection-start="1400" selection-end="1400" vertical-scroll-proportion="0.2413793"> + <state line="42" column="20" selection-start="1542" selection-end="1542" vertical-scroll-proportion="0.504222"> <folding /> </state> </provider> </entry> - <entry file="file://$PROJECT_DIR$/src/main/java/org/jboss/sam/internal/esper/EsperStatement.java"> + <entry file="file://$PROJECT_DIR$/src/main/java/org/jboss/sam/EventMessage.java"> <provider selected="true" editor-type-id="text-editor"> - <state line="32" column="0" selection-start="1303" selection-end="1303" vertical-scroll-proportion="0.41379312"> - <folding> - <element signature="imports" expanded="true" /> - </folding> + <state line="46" column="49" selection-start="1593" selection-end="1593" vertical-scroll-proportion="0.5958987"> + <folding /> </state> </provider> </entry> + <entry file="file://$PROJECT_DIR$/src/main/java/org/jboss/sam/ProcessingStatement.java"> + <provider selected="true" editor-type-id="text-editor"> + <state line="31" column="17" selection-start="1394" selection-end="1394" vertical-scroll-proportion="0.252111"> + <folding /> + </state> + </provider> + </entry> </component> </project> Modified: sam/trunk/src/main/java/org/jboss/sam/EventProcessor.java =================================================================== --- sam/trunk/src/main/java/org/jboss/sam/EventProcessor.java 2008-07-03 07:27:35 UTC (rev 105) +++ sam/trunk/src/main/java/org/jboss/sam/EventProcessor.java 2008-07-03 07:30:56 UTC (rev 106) @@ -25,7 +25,7 @@ /** * An event processor glues together {@link org.jboss.sam.StreamInput} and {@link org.jboss.sam.StreamOutput} - * and provides a way to register {@link org.jboss.sam.Statement}'s, + * and provides a way to register {@link org.jboss.sam.ProcessingStatement}'s, * both bound (event forwarding) and unbound (event aggregation and filtering). * <p> * Instances are created through {@link org.jboss.sam.EventProcessorFactory} @@ -77,7 +77,7 @@ * @param epl * @return */ - Statement registerStatement(String statementName, String epl); + ProcessingStatement registerStatement(String statementName, String epl); /** * Creates a statement and binds it to an output stream. @@ -87,7 +87,7 @@ * @param epl * @return */ - Statement registerBoundStatement(String streamOutputName, String statementName, String epl); + ProcessingStatement registerBoundStatement(String streamOutputName, String statementName, String epl); /** * Cleanup a statement and remove it Added: sam/trunk/src/main/java/org/jboss/sam/ProcessingStatement.java =================================================================== --- sam/trunk/src/main/java/org/jboss/sam/ProcessingStatement.java (rev 0) +++ sam/trunk/src/main/java/org/jboss/sam/ProcessingStatement.java 2008-07-03 07:30:56 UTC (rev 106) @@ -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.sam; + +/** + * Represents an EPL (event processing languge) statement. + * Statements are associated with a {@link org.jboss.sam.EventProcessor} + * and can be bound to a {@link org.jboss.sam.StreamOutput} to forward events, + * or used unbound to aggregate and filter events. + * + * @author Heiko.Braun <heiko.braun(a)jboss.com&gt; + */ +public interface ProcessingStatement<T> +{ + /** + * Statements are managed by name + * @return + */ + String getName(); + + /** + * Get the EPL expression this statement was created from + * @return + */ + String getExpression(); + + /** + * Check wether the statement is bound to a {@link org.jboss.sam.StreamOutput} + * @return + */ + boolean isBound(); + + /** + * Access the underlying implementation + * @return + */ + T getUnderlying(); +} Property changes on: sam/trunk/src/main/java/org/jboss/sam/ProcessingStatement.java ___________________________________________________________________ Name: svn:keywords + Id Revision Name: svn:eol-style + LF Deleted: sam/trunk/src/main/java/org/jboss/sam/Statement.java =================================================================== --- sam/trunk/src/main/java/org/jboss/sam/Statement.java 2008-07-03 07:27:35 UTC (rev 105) +++ sam/trunk/src/main/java/org/jboss/sam/Statement.java 2008-07-03 07:30:56 UTC (rev 106) @@ -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.sam; - -/** - * Represents an EPL (event processing languge) statement. - * Statements are associated with a {@link org.jboss.sam.EventProcessor} - * and can be bound to a {@link org.jboss.sam.StreamOutput} to forward events, - * or used unbound to aggregate and filter events. - * - * @author Heiko.Braun <heiko.braun(a)jboss.com&gt; - */ -public interface Statement<T> -{ - /** - * Statements are managed by name - * @return - */ - String getName(); - - /** - * Get the EPL expression this statement was created from - * @return - */ - String getExpression(); - - /** - * Check wether the statement is bound to a {@link org.jboss.sam.StreamOutput} - * @return - */ - boolean isBound(); - - /** - * Access the underlying implementation - * @return - */ - T getUnderlying(); -} Added: sam/trunk/src/main/java/org/jboss/sam/internal/esper/EsperProcessingStatement.java =================================================================== --- sam/trunk/src/main/java/org/jboss/sam/internal/esper/EsperProcessingStatement.java (rev 0) +++ sam/trunk/src/main/java/org/jboss/sam/internal/esper/EsperProcessingStatement.java 2008-07-03 07:30:56 UTC (rev 106) @@ -0,0 +1,69 @@ +/* + * 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.sam.internal.esper; + +import com.espertech.esper.client.EPStatement; +import org.jboss.sam.ProcessingStatement; + +/** + * @author Heiko.Braun <heiko.braun(a)jboss.com&gt; + */ +public class EsperProcessingStatement implements ProcessingStatement<EPStatement> +{ + private EPStatement delegate; + + protected String name; + + private boolean bound; + + public EsperProcessingStatement(EPStatement delegate) + { + this(delegate, false); + } + + public EsperProcessingStatement(EPStatement delegate, boolean isBound) + { + this.bound = isBound; + this.delegate = delegate; + } + + public String getName() + { + return this.name; + } + + public boolean isBound() + { + return this.bound; + } + + public String getExpression() + { + return delegate.getText(); + } + + public EPStatement getUnderlying() + { + return delegate; + } + +} Property changes on: sam/trunk/src/main/java/org/jboss/sam/internal/esper/EsperProcessingStatement.java ___________________________________________________________________ Name: svn:keywords + Id Revision Name: svn:eol-style + LF Modified: sam/trunk/src/main/java/org/jboss/sam/internal/esper/EsperRuntimeImpl.java =================================================================== --- sam/trunk/src/main/java/org/jboss/sam/internal/esper/EsperRuntimeImpl.java 2008-07-03 07:27:35 UTC (rev 105) +++ sam/trunk/src/main/java/org/jboss/sam/internal/esper/EsperRuntimeImpl.java 2008-07-03 07:30:56 UTC (rev 106) @@ -44,7 +44,7 @@ private Map<String, StreamInput> inputStreams = new ConcurrentHashMap<String, StreamInput>(); private Map<String, StreamOutput> outputStreams = new ConcurrentHashMap<String, StreamOutput>(); - private Map<String, Statement> statements = new ConcurrentHashMap<String, Statement>(); + private Map<String, ProcessingStatement> statements = new ConcurrentHashMap<String, ProcessingStatement>(); public EsperRuntimeImpl(String name, URL config) { @@ -105,20 +105,20 @@ epService.getEPRuntime().sendEvent(args); } - public Statement registerStatement(String statementName, String epl) + public ProcessingStatement registerStatement(String statementName, String epl) { EPStatement epStatement = epService.getEPAdministrator().createEPL(epl, statementName); - return new EsperStatement(epStatement); + return new EsperProcessingStatement(epStatement); } - public Statement registerBoundStatement(String outputStreamName, String statementName, String epl) + public ProcessingStatement registerBoundStatement(String outputStreamName, String statementName, String epl) { StreamOutput streamOutput = this.outputStreams.get(outputStreamName); if(null == streamOutput) throw new IllegalArgumentException("No such output stream: " + outputStreamName); EPStatement epStatement = epService.getEPAdministrator().createEPL(epl, statementName); - EsperStatement statement = new EsperStatement(epStatement); + EsperProcessingStatement statement = new EsperProcessingStatement(epStatement); StreamOutputAdapter adapter = new StreamOutputAdapter(streamOutput); statement.getUnderlying().addListener(adapter); return statement; @@ -132,7 +132,7 @@ public void clearStatement(String statementName) { - Statement stmt = statements.get(statementName); + ProcessingStatement stmt = statements.get(statementName); if(null==stmt) throw new IllegalArgumentException("No such statement: " + statementName); Deleted: sam/trunk/src/main/java/org/jboss/sam/internal/esper/EsperStatement.java =================================================================== --- sam/trunk/src/main/java/org/jboss/sam/internal/esper/EsperStatement.java 2008-07-03 07:27:35 UTC (rev 105) +++ sam/trunk/src/main/java/org/jboss/sam/internal/esper/EsperStatement.java 2008-07-03 07:30:56 UTC (rev 106) @@ -1,69 +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.sam.internal.esper; - -import com.espertech.esper.client.EPStatement; -import org.jboss.sam.Statement; - -/** - * @author Heiko.Braun <heiko.braun(a)jboss.com&gt; - */ -public class EsperStatement implements Statement<EPStatement> -{ - private EPStatement delegate; - - protected String name; - - private boolean bound; - - public EsperStatement(EPStatement delegate) - { - this(delegate, false); - } - - public EsperStatement(EPStatement delegate, boolean isBound) - { - this.bound = isBound; - this.delegate = delegate; - } - - public String getName() - { - return this.name; - } - - public boolean isBound() - { - return this.bound; - } - - public String getExpression() - { - return delegate.getText(); - } - - public EPStatement getUnderlying() - { - return delegate; - } - -} Modified: sam/trunk/src/test/java/org/jboss/test/sam/adapter/invm/InVMAdapterTestCase.java =================================================================== --- sam/trunk/src/test/java/org/jboss/test/sam/adapter/invm/InVMAdapterTestCase.java 2008-07-03 07:27:35 UTC (rev 105) +++ sam/trunk/src/test/java/org/jboss/test/sam/adapter/invm/InVMAdapterTestCase.java 2008-07-03 07:30:56 UTC (rev 106) @@ -21,7 +21,7 @@ */ package org.jboss.test.sam.adapter.invm; -import org.jboss.sam.Statement; +import org.jboss.sam.ProcessingStatement; import org.jboss.test.sam.SamTestSetup; /** @@ -38,7 +38,7 @@ { // setup String stmt = "select * from Alert.win:length(1)"; - Statement view = eventProcessor.registerBoundStatement("InVM","AlertTest", stmt); + ProcessingStatement view = eventProcessor.registerBoundStatement("InVM","AlertTest", stmt); // fire event generateInVMEvent( new Alert("sensor1", "Threshold exceeded") ); Modified: sam/trunk/src/test/java/org/jboss/test/sam/database/DatabaseTestCase.java =================================================================== --- sam/trunk/src/test/java/org/jboss/test/sam/database/DatabaseTestCase.java 2008-07-03 07:27:35 UTC (rev 105) +++ sam/trunk/src/test/java/org/jboss/test/sam/database/DatabaseTestCase.java 2008-07-03 07:30:56 UTC (rev 106) @@ -25,7 +25,7 @@ import com.espertech.esper.client.EPStatement; import com.espertech.esper.client.StatementAwareUpdateListener; import com.espertech.esper.event.EventBean; -import org.jboss.sam.Statement; +import org.jboss.sam.ProcessingStatement; import org.jboss.sam.EventMessage; import org.jboss.test.sam.SamTestSetup; import org.jboss.test.sam.InMemoryDatabase; @@ -87,7 +87,7 @@ String epl = "select symbol, price from Query.win:length(1) as query," + " sql:SamTestDB ['SELECT symbol, price FROM quotes WHERE symbol like (${query.criteria})']"; - Statement view = eventProcessor.registerBoundStatement("InVM","TriggerSQL", epl); + ProcessingStatement view = eventProcessor.registerBoundStatement("InVM","TriggerSQL", epl); // trigger generateInVMEvent( new Query("%") );