[overlord-commits] Overlord SVN: r106 - in sam/trunk: src/main/java/org/jboss/sam and 3 other directories.
overlord-commits at lists.jboss.org
overlord-commits at lists.jboss.org
Thu Jul 3 03:30:56 EDT 2008
Author: heiko.braun at 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 at jboss.com>
+ */
+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 at jboss.com>
- */
-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 at jboss.com>
+ */
+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 at jboss.com>
- */
-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("%") );
More information about the overlord-commits
mailing list