[jboss-svn-commits] JBL Code SVN: r29861 - in labs/jbossrules/trunk/drools-vsm: src/main/java/org/drools/vsm/remote and 2 other directories.
jboss-svn-commits at lists.jboss.org
jboss-svn-commits at lists.jboss.org
Wed Oct 28 17:06:33 EDT 2009
Author: mark.proctor at jboss.com
Date: 2009-10-28 17:06:33 -0400 (Wed, 28 Oct 2009)
New Revision: 29861
Modified:
labs/jbossrules/trunk/drools-vsm/.classpath
labs/jbossrules/trunk/drools-vsm/src/main/java/org/drools/vsm/remote/StatefulKnowledgeSessionRemoteClient.java
labs/jbossrules/trunk/drools-vsm/src/main/java/org/drools/vsm/rio/RioConnector.java
labs/jbossrules/trunk/drools-vsm/src/main/java/org/drools/vsm/rio/service/SessionServiceImpl.java
Log:
JBRULES-2269 Virtual Service Manager
-rio now uses GenericIoWriter
Modified: labs/jbossrules/trunk/drools-vsm/.classpath
===================================================================
--- labs/jbossrules/trunk/drools-vsm/.classpath 2009-10-28 20:54:22 UTC (rev 29860)
+++ labs/jbossrules/trunk/drools-vsm/.classpath 2009-10-28 21:06:33 UTC (rev 29861)
@@ -5,22 +5,34 @@
<classpathentry kind="src" path="src/test/resources" output="target/test-classes" including="**" excluding="**/*.java"/>
<classpathentry kind="output" path="target/classes"/>
<classpathentry kind="con" path="org.eclipse.jdt.launching.JRE_CONTAINER"/>
+ <classpathentry kind="var" path="M2_REPO/org/apache/ant/ant/1.7.1/ant-1.7.1.jar"/>
+ <classpathentry kind="var" path="M2_REPO/org/apache/ant/ant-launcher/1.7.1/ant-launcher-1.7.1.jar"/>
<classpathentry kind="var" path="M2_REPO/org/antlr/antlr-runtime/3.1.1/antlr-runtime-3.1.1.jar"/>
+ <classpathentry kind="var" path="M2_REPO/org/rioproject/boot/4.0-M3-SNAPSHOT/boot-4.0-M3-SNAPSHOT.jar"/>
<classpathentry kind="var" path="M2_REPO/cglib/cglib-nodep/2.1_3/cglib-nodep-2.1_3.jar"/>
+ <classpathentry kind="var" path="M2_REPO/org/rioproject/tools/cli/4.0-M3-SNAPSHOT/cli-4.0-M3-SNAPSHOT.jar"/>
<classpathentry kind="var" path="M2_REPO/org/eclipse/jdt/core/3.4.2.v_883_R34x/core-3.4.2.v_883_R34x.jar"/>
+ <classpathentry kind="var" path="M2_REPO/org/rioproject/cybernode/4.0-M3-SNAPSHOT/cybernode-4.0-M3-SNAPSHOT.jar"/>
<classpathentry kind="src" path="/drools-api"/>
<classpathentry kind="src" path="/drools-compiler"/>
<classpathentry kind="src" path="/drools-core"/>
+ <classpathentry kind="var" path="M2_REPO/org/codehaus/groovy/groovy-all/1.6.2/groovy-all-1.6.2.jar"/>
<classpathentry kind="var" path="M2_REPO/org/hamcrest/hamcrest-core/1.1/hamcrest-core-1.1.jar"/>
<classpathentry kind="var" path="M2_REPO/org/hamcrest/hamcrest-library/1.1/hamcrest-library-1.1.jar"/>
<classpathentry kind="var" path="M2_REPO/janino/janino/2.5.15/janino-2.5.15.jar"/>
+ <classpathentry kind="var" path="M2_REPO/jline/jline/0.9.94/jline-0.9.94.jar"/>
<classpathentry kind="var" path="M2_REPO/org/jmock/jmock/2.5.1/jmock-2.5.1.jar"/>
<classpathentry kind="var" path="M2_REPO/org/jmock/jmock-legacy/2.5.1/jmock-legacy-2.5.1.jar"/>
<classpathentry kind="var" path="M2_REPO/joda-time/joda-time/1.6/joda-time-1.6.jar"/>
+ <classpathentry kind="var" path="M2_REPO/net/jini/jsk-lib/2.1/jsk-lib-2.1.jar"/>
+ <classpathentry kind="var" path="M2_REPO/net/jini/jsk-platform/2.1/jsk-platform-2.1.jar"/>
<classpathentry kind="var" path="M2_REPO/junit/junit/4.6/junit-4.6.jar"/>
<classpathentry kind="var" path="M2_REPO/org/apache/mina/mina-core/2.0.0-M6/mina-core-2.0.0-M6.jar"/>
+ <classpathentry kind="var" path="M2_REPO/org/rioproject/monitor/4.0-M3-SNAPSHOT/monitor-4.0-M3-SNAPSHOT.jar"/>
<classpathentry kind="var" path="M2_REPO/org/mvel/mvel2/2.0.12/mvel2-2.0.12.jar"/>
<classpathentry kind="var" path="M2_REPO/org/objenesis/objenesis/1.0/objenesis-1.0.jar"/>
+ <classpathentry kind="var" path="M2_REPO/org/rioproject/rio/4.0-M3-SNAPSHOT/rio-4.0-M3-SNAPSHOT.jar"/>
<classpathentry kind="var" path="M2_REPO/org/slf4j/slf4j-api/1.5.2/slf4j-api-1.5.2.jar"/>
<classpathentry kind="var" path="M2_REPO/org/slf4j/slf4j-jdk14/1.5.2/slf4j-jdk14-1.5.2.jar"/>
+ <classpathentry kind="var" path="M2_REPO/com/sun/jini/tools/2.1/tools-2.1.jar"/>
</classpath>
\ No newline at end of file
Modified: labs/jbossrules/trunk/drools-vsm/src/main/java/org/drools/vsm/remote/StatefulKnowledgeSessionRemoteClient.java
===================================================================
--- labs/jbossrules/trunk/drools-vsm/src/main/java/org/drools/vsm/remote/StatefulKnowledgeSessionRemoteClient.java 2009-10-28 20:54:22 UTC (rev 29860)
+++ labs/jbossrules/trunk/drools-vsm/src/main/java/org/drools/vsm/remote/StatefulKnowledgeSessionRemoteClient.java 2009-10-28 21:06:33 UTC (rev 29861)
@@ -357,4 +357,11 @@
return 0;
}
+ public void signalEvent(String type,
+ Object event,
+ long processInstanceId) {
+ // TODO Auto-generated method stub
+
+ }
+
}
Modified: labs/jbossrules/trunk/drools-vsm/src/main/java/org/drools/vsm/rio/RioConnector.java
===================================================================
--- labs/jbossrules/trunk/drools-vsm/src/main/java/org/drools/vsm/rio/RioConnector.java 2009-10-28 20:54:22 UTC (rev 29860)
+++ labs/jbossrules/trunk/drools-vsm/src/main/java/org/drools/vsm/rio/RioConnector.java 2009-10-28 21:06:33 UTC (rev 29861)
@@ -108,10 +108,7 @@
public void write(Message msg) {
if (sessionService != null) {
try {
-
ioHandler.messageReceived(sessionService, this.sessionService.write(msg));
-
-
} catch (RemoteException ex) {
Logger.getLogger(RioConnector.class.getName()).log(Level.SEVERE, null, ex);
} catch (Exception ex) {
Modified: labs/jbossrules/trunk/drools-vsm/src/main/java/org/drools/vsm/rio/service/SessionServiceImpl.java
===================================================================
--- labs/jbossrules/trunk/drools-vsm/src/main/java/org/drools/vsm/rio/service/SessionServiceImpl.java 2009-10-28 20:54:22 UTC (rev 29860)
+++ labs/jbossrules/trunk/drools-vsm/src/main/java/org/drools/vsm/rio/service/SessionServiceImpl.java 2009-10-28 21:06:33 UTC (rev 29861)
@@ -28,6 +28,7 @@
import org.drools.runtime.impl.ExecutionResultImpl;
import org.drools.vsm.GenericIoWriter;
import org.drools.vsm.GenericMessageHandler;
+import org.drools.vsm.GenericMessageHandlerImpl;
import org.drools.vsm.Message;
import org.drools.vsm.ServiceManagerData;
import org.drools.vsm.rio.SessionService;
@@ -36,26 +37,21 @@
*
* @author salaboy
*/
-public class SessionServiceImpl implements SessionService{
- private SystemEventListener systemEventListener;
+public class SessionServiceImpl implements SessionService{
+ private GenericMessageHandler handler;
- private ServiceManagerData data;
-
- public SessionServiceImpl() {
- this.systemEventListener = SystemEventListenerFactory.getSystemEventListener();
- this.data = new ServiceManagerData();
+ public SessionServiceImpl() {
+ handler = new GenericMessageHandlerImpl(new ServiceManagerData(), SystemEventListenerFactory.getSystemEventListener());
}
public SessionServiceImpl(ServiceManagerData data,
SystemEventListener systemEventListener) {
- this.systemEventListener = systemEventListener;
- this.data = data;
+ handler = new GenericMessageHandlerImpl( data, systemEventListener );
}
- public Message write(Message msg) throws RemoteException {
- GenericMessageHandler handler = null;
+ public Message write(Message msg) throws RemoteException {
BlockingGenericIoWriter blockingWriter = new BlockingGenericIoWriter();
try {
handler.messageReceived( blockingWriter, msg );
More information about the jboss-svn-commits
mailing list