[jboss-svn-commits] JBL Code SVN: r31159 - in labs/jbossrules/branches/salaboy_grid-rio/drools-grid-rio/src: main/java/org/drools/vsm/rio/service and 2 other directories.
jboss-svn-commits at lists.jboss.org
jboss-svn-commits at lists.jboss.org
Wed Jan 20 09:37:36 EST 2010
Author: salaboy21
Date: 2010-01-20 09:37:36 -0500 (Wed, 20 Jan 2010)
New Revision: 31159
Removed:
labs/jbossrules/branches/salaboy_grid-rio/drools-grid-rio/src/main/java/org/drools/vsm/rio/RioConnector.java
Modified:
labs/jbossrules/branches/salaboy_grid-rio/drools-grid-rio/src/main/java/org/drools/vsm/rio/service/RegistryServiceImpl.java
labs/jbossrules/branches/salaboy_grid-rio/drools-grid-rio/src/main/java/org/drools/vsm/rio/service/SessionServiceImpl.java
labs/jbossrules/branches/salaboy_grid-rio/drools-grid-rio/src/test/java/org/drools/vms/ITServiceManagerRioRemoteTest.java
labs/jbossrules/branches/salaboy_grid-rio/drools-grid-rio/src/test/java/org/drools/vms/ServiceManagerTestBaseGrid.java
labs/jbossrules/branches/salaboy_grid-rio/drools-grid-rio/src/test/resources/org/drools/sessionService.groovy
Log:
test to use two session services switching the current one, using associations in RegistryService
Deleted: labs/jbossrules/branches/salaboy_grid-rio/drools-grid-rio/src/main/java/org/drools/vsm/rio/RioConnector.java
===================================================================
--- labs/jbossrules/branches/salaboy_grid-rio/drools-grid-rio/src/main/java/org/drools/vsm/rio/RioConnector.java 2010-01-20 14:36:19 UTC (rev 31158)
+++ labs/jbossrules/branches/salaboy_grid-rio/drools-grid-rio/src/main/java/org/drools/vsm/rio/RioConnector.java 2010-01-20 14:37:36 UTC (rev 31159)
@@ -1,115 +0,0 @@
-package org.drools.vsm.rio;
-
-import org.drools.vsm.grid.SessionService;
-import java.rmi.RemoteException;
-import java.util.logging.Level;
-import java.util.logging.Logger;
-import java.net.SocketAddress;
-import java.util.concurrent.atomic.AtomicInteger;
-
-import org.drools.SystemEventListener;
-import org.drools.vsm.GenericConnector;
-import org.drools.vsm.Message;
-import org.drools.vsm.MessageResponseHandler;
-import org.drools.vsm.grid.RegistryService;
-
-public class RioConnector
- implements
- GenericConnector {
-
- protected final String name;
- protected AtomicInteger counter;
- protected SessionService sessionService;
- protected SocketAddress address;
- protected SystemEventListener eventListener;
-
- public RioConnector(String name,
- SystemEventListener eventListener
- ) {
- if ( name == null ) {
- throw new IllegalArgumentException( "Name can not be null" );
- }
- this.name = name;
- this.counter = new AtomicInteger();
- this.eventListener = eventListener;
-
- }
-
- public RioConnector(String name,
- SystemEventListener eventListener,
- SessionService sessionService
- ) {
- if ( name == null ) {
- throw new IllegalArgumentException( "Name can not be null" );
- }
- this.name = name;
- this.counter = new AtomicInteger();
- this.eventListener = eventListener;
- this.sessionService = sessionService;
-
- }
-
- /* (non-Javadoc)
- * @see org.drools.vsm.mina.Messenger#connect()
- */
- public boolean connect() {
-
- return true;
- }
-
- /* (non-Javadoc)
- * @see org.drools.vsm.mina.Messenger#disconnect()
- */
- public void disconnect() {
- //I don't need to be disconected
- }
-
- public Message write(Message msg) {
- if ( sessionService != null ) {
- try {
-
- Message returnMessage = this.sessionService.write( msg );
- return returnMessage;
- // ioHandler.messageReceived( sessionService ,
- // returnMessage );
-
- } catch ( RemoteException ex ) {
- Logger.getLogger( RioConnector.class.getName() ).log( Level.SEVERE,
- null,
- ex );
- } catch ( Exception ex ) {
- Logger.getLogger( RioConnector.class.getName() ).log( Level.SEVERE,
- null,
- ex );
- }
- }
- throw new IllegalStateException( "sessionService should not be null" );
- }
-
- public void write(Message msg,
- MessageResponseHandler responseHandler) {
- throw new UnsupportedOperationException();
- }
-
-
- public String getId() {
- try {
- return sessionService.getId();
- } catch (RemoteException ex) {
- Logger.getLogger(RioConnector.class.getName()).log(Level.SEVERE, null, ex);
- }
- return null;
- }
-
- public SessionService getSessionService() {
- return sessionService;
- }
-
-
- public void setSession(Object object) {
- this.sessionService = (SessionService) object;
- }
-
-
-
-}
Modified: labs/jbossrules/branches/salaboy_grid-rio/drools-grid-rio/src/main/java/org/drools/vsm/rio/service/RegistryServiceImpl.java
===================================================================
--- labs/jbossrules/branches/salaboy_grid-rio/drools-grid-rio/src/main/java/org/drools/vsm/rio/service/RegistryServiceImpl.java 2010-01-20 14:36:19 UTC (rev 31158)
+++ labs/jbossrules/branches/salaboy_grid-rio/drools-grid-rio/src/main/java/org/drools/vsm/rio/service/RegistryServiceImpl.java 2010-01-20 14:37:36 UTC (rev 31159)
@@ -5,21 +5,11 @@
package org.drools.vsm.rio.service;
-import java.io.IOException;
import java.rmi.RemoteException;
import java.util.HashMap;
import java.util.Map;
-import java.util.logging.Level;
-import java.util.logging.Logger;
-import net.jini.core.entry.Entry;
-import net.jini.core.lookup.ServiceItem;
-import net.jini.core.lookup.ServiceTemplate;
-import net.jini.discovery.LookupDiscoveryManager;
-import net.jini.lease.LeaseRenewalManager;
-import net.jini.lookup.ServiceDiscoveryManager;
import org.drools.vsm.grid.RegistryService;
import org.drools.vsm.grid.SessionService;
-import org.drools.vsm.rio.utils.IDEntry;
/**
*
@@ -29,6 +19,11 @@
private Map<String, String> registry = new HashMap<String, String>();
+ public RegistryServiceImpl() {
+ }
+
+
+ private Iterable<SessionService> sessionServices;
@Override
public void register(String sessionId, String sessionServiceId) throws RemoteException {
System.out.println("Registering: "+ sessionId + " -- "+sessionServiceId);
@@ -40,54 +35,20 @@
SessionService sessionService = null;
String sessionServiceId = (String)registry.get(sessionId);
System.out.println("Registry = "+ registry.toString());
-
- Class[] classes = new Class[]{org.drools.vsm.grid.SessionService.class};
-
-
- ServiceTemplate tmpl = new ServiceTemplate(null, classes,new Entry[]{new IDEntry(sessionServiceId)});
-
- LookupDiscoveryManager lookupDiscovery = null;
- try {
- lookupDiscovery = new LookupDiscoveryManager(LookupDiscoveryManager.ALL_GROUPS, null, null);
- } catch (IOException ex) {
- Logger.getLogger(RegistryServiceImpl.class.getName()).log(Level.SEVERE, null, ex);
- }
-
- System.out.println("Discovering Manager service ...");
-
- ServiceDiscoveryManager serviceDiscovery = null;
- try {
- serviceDiscovery = new ServiceDiscoveryManager(lookupDiscovery, new LeaseRenewalManager());
- } catch (IOException ex) {
- Logger.getLogger(RegistryServiceImpl.class.getName()).log(Level.SEVERE, null, ex);
- }
-
-
- /* Wait no more then 10 seconds to discover the service */
- ServiceItem item = null;
- try {
- item = serviceDiscovery.lookup(tmpl, null, 1000);
- } catch (InterruptedException ex) {
- Logger.getLogger(RegistryServiceImpl.class.getName()).log(Level.SEVERE, null, ex);
- }
- serviceDiscovery.terminate();
-
- if(item != null) {
- System.out.println("Discovered Session service");
- if(item.service instanceof SessionService){
- sessionService = (SessionService)item.service;
-
+ System.out.println("Session Services = "+sessionServices);
+ for(SessionService ss : sessionServices){
+ System.out.println("Session Service id = "+ss.getId() + "needs to match with ="+sessionServiceId);
+ if(ss.getId().equals(sessionServiceId)){
+ sessionService = ss;
}
+ }
+ return sessionService;
+ }
- } else {
- System.out.println("Session service not discovered, make sure the"+
- "service is deployed");
- }
-
-
- return sessionService;
+ public void setSessionServices(Iterable<SessionService> sessionServices) {
+ this.sessionServices = sessionServices;
}
}
Modified: labs/jbossrules/branches/salaboy_grid-rio/drools-grid-rio/src/main/java/org/drools/vsm/rio/service/SessionServiceImpl.java
===================================================================
--- labs/jbossrules/branches/salaboy_grid-rio/drools-grid-rio/src/main/java/org/drools/vsm/rio/service/SessionServiceImpl.java 2010-01-20 14:36:19 UTC (rev 31158)
+++ labs/jbossrules/branches/salaboy_grid-rio/drools-grid-rio/src/main/java/org/drools/vsm/rio/service/SessionServiceImpl.java 2010-01-20 14:37:36 UTC (rev 31159)
@@ -55,6 +55,7 @@
try {
handler.messageReceived(blockingWriter, msg);
} catch (Exception e) {
+ e.printStackTrace();
throw new RemoteException(e.getMessage());
}
Modified: labs/jbossrules/branches/salaboy_grid-rio/drools-grid-rio/src/test/java/org/drools/vms/ITServiceManagerRioRemoteTest.java
===================================================================
--- labs/jbossrules/branches/salaboy_grid-rio/drools-grid-rio/src/test/java/org/drools/vms/ITServiceManagerRioRemoteTest.java 2010-01-20 14:36:19 UTC (rev 31158)
+++ labs/jbossrules/branches/salaboy_grid-rio/drools-grid-rio/src/test/java/org/drools/vms/ITServiceManagerRioRemoteTest.java 2010-01-20 14:37:36 UTC (rev 31159)
@@ -1,17 +1,18 @@
package org.drools.vms;
+import java.util.ArrayList;
import java.util.List;
import junit.framework.Assert;
+
import net.jini.core.lookup.ServiceItem;
import org.drools.SystemEventListenerFactory;
import org.drools.vsm.AcceptorService;
import org.drools.vsm.ServiceManagerData;
import org.drools.vsm.grid.RegistryService;
import org.drools.vsm.grid.ServiceManagerGridClient;
-import org.drools.vsm.remote.ServiceManagerRemoteClient;
+import org.drools.vsm.grid.SessionService;
import org.drools.vsm.rio.RioConnector;
-import org.drools.vsm.grid.SessionService;
-import org.junit.After;
+
import org.junit.Before;
import org.junit.runner.RunWith;
import org.rioproject.test.RioTestRunner;
@@ -29,23 +30,34 @@
ServiceManagerData serverData = new ServiceManagerData();
Assert.assertNotNull(testManager);
//setup Server
- SessionService sessionService = (SessionService) testManager.waitForService(SessionService.class);
- //ServiceItem[] sessionServiceItems = testManager.getServiceItems(SessionService.class);
- Assert.assertNotNull(sessionService);
+ //SessionService sessionService = (SessionService) testManager.waitForService(SessionService.class);
+ ServiceItem[] sessionServiceItems = testManager.getServiceItems(SessionService.class);
+ List<SessionService> sessionServices = new ArrayList<SessionService>();
+ System.out.println("Session Service Items ="+sessionServiceItems.length);
+ for(int i=0; i < sessionServiceItems.length; i ++){
+ if(sessionServiceItems[i].service instanceof SessionService){
+ sessionServices.add((SessionService)sessionServiceItems[i].service);
+ }
+ }
+
+ Assert.assertNotNull(sessionServices);
RegistryService registryService = (RegistryService) testManager.waitForService(RegistryService.class);
- Assert.assertNotNull(registryService);
+ Assert.assertNotNull(registryService);
RioConnector connector = new RioConnector( "client 1",
SystemEventListenerFactory.getSystemEventListener(),
- sessionService
+ sessionServices
);
// setup Client
this.client = new ServiceManagerGridClient( "client 1",
connector );
+
((ServiceManagerGridClient)this.client).setRegistryService(registryService);
+ ((ServiceManagerGridClient)this.client).setCurrentSessionService((SessionService)sessionServiceItems[0].service);
+
((ServiceManagerGridClient)this.client).connect();
}
@@ -56,4 +68,5 @@
// //this.server.stop();
// }
+
}
Modified: labs/jbossrules/branches/salaboy_grid-rio/drools-grid-rio/src/test/java/org/drools/vms/ServiceManagerTestBaseGrid.java
===================================================================
--- labs/jbossrules/branches/salaboy_grid-rio/drools-grid-rio/src/test/java/org/drools/vms/ServiceManagerTestBaseGrid.java 2010-01-20 14:36:19 UTC (rev 31158)
+++ labs/jbossrules/branches/salaboy_grid-rio/drools-grid-rio/src/test/java/org/drools/vms/ServiceManagerTestBaseGrid.java 2010-01-20 14:37:36 UTC (rev 31159)
@@ -9,10 +9,15 @@
import org.drools.builder.KnowledgeBuilderProvider;
import org.drools.builder.ResourceType;
import org.drools.command.runtime.rule.FireAllRulesCommand;
+import org.drools.impl.KnowledgeBaseProviderImpl;
import org.drools.io.ResourceFactory;
import org.drools.runtime.ExecutionResults;
import org.drools.runtime.StatefulKnowledgeSession;
import org.drools.vsm.ServiceManager;
+import org.drools.vsm.grid.KnowledgeBaseGridClient;
+import org.drools.vsm.grid.KnowledgeBaseProviderGridClient;
+import org.drools.vsm.grid.ServiceManagerGridClient;
+import org.drools.vsm.grid.SessionService;
import org.junit.Test;
@@ -22,83 +27,83 @@
protected ServiceManager client;
-// @Test
-// public void testFireAllRules() throws Exception {
-// String str = "";
-// str += "package org.drools \n";
-// str += "global java.util.List list \n";
-// str += "rule rule1 \n";
-// str += " dialect \"java\" \n";
-// str += "when \n";
-// str += "then \n";
-// str += " System.out.println( \"hello1!!!\" ); \n";
-// str += "end \n";
-// str += "rule rule2 \n";
-// str += " dialect \"java\" \n";
-// str += "when \n";
-// str += "then \n";
-// str += " System.out.println( \"hello2!!!\" ); \n";
-// str += "end \n";
-//
-// KnowledgeBuilderProvider kbuilderFactory = this.client.getKnowledgeBuilderFactory();
-// KnowledgeBuilder kbuilder = kbuilderFactory.newKnowledgeBuilder();
-// kbuilder.add( ResourceFactory.newByteArrayResource( str.getBytes() ),
-// ResourceType.DRL );
-//
-// if ( kbuilder.hasErrors() ) {
-// System.out.println( "Errors: " + kbuilder.getErrors() );
-// }
-//
-// KnowledgeBaseProvider kbaseFactory = this.client.getKnowledgeBaseFactory();
-// KnowledgeBase kbase = kbaseFactory.newKnowledgeBase();
-//
-// kbase.addKnowledgePackages( kbuilder.getKnowledgePackages() );
-//
-// StatefulKnowledgeSession ksession = kbase.newStatefulKnowledgeSession();
-// int fired = ksession.fireAllRules();
-// Assert.assertEquals( 2,
-// fired );
-//
-// }
-// @Test
-// public void testExecute() throws Exception {
-// String str = "";
-// str += "package org.drools \n";
-// str += "global java.util.List list \n";
-// str += "rule rule1 \n";
-// str += " dialect \"java\" \n";
-// str += "when \n";
-// str += "then \n";
-// str += " System.out.println( \"hello1!!!\" ); \n";
-// str += "end \n";
-// str += "rule rule2 \n";
-// str += " dialect \"java\" \n";
-// str += "when \n";
-// str += "then \n";
-// str += " System.out.println( \"hello2!!!\" ); \n";
-// str += "end \n";
-//
-// KnowledgeBuilderProvider kbuilderFactory = this.client.getKnowledgeBuilderFactory();
-// KnowledgeBuilder kbuilder = kbuilderFactory.newKnowledgeBuilder();
-// kbuilder.add( ResourceFactory.newByteArrayResource( str.getBytes() ),
-// ResourceType.DRL );
-//
-// if ( kbuilder.hasErrors() ) {
-// System.out.println( "Errors: " + kbuilder.getErrors() );
-// }
-//
-// KnowledgeBaseProvider kbaseFactory = this.client.getKnowledgeBaseFactory();
-// KnowledgeBase kbase = kbaseFactory.newKnowledgeBase();
-//
-// kbase.addKnowledgePackages( kbuilder.getKnowledgePackages() );
-//
-// StatefulKnowledgeSession ksession = kbase.newStatefulKnowledgeSession();
-//
-// ExecutionResults results = ksession.execute( new FireAllRulesCommand( "fired" ) );
-//
-// Assert.assertEquals( 2,
-// (int) (Integer) results.getValue( "fired" ) );
-// }
+ @Test
+ public void testFireAllRules() throws Exception {
+ String str = "";
+ str += "package org.drools \n";
+ str += "global java.util.List list \n";
+ str += "rule rule1 \n";
+ str += " dialect \"java\" \n";
+ str += "when \n";
+ str += "then \n";
+ str += " System.out.println( \"hello1!!!\" ); \n";
+ str += "end \n";
+ str += "rule rule2 \n";
+ str += " dialect \"java\" \n";
+ str += "when \n";
+ str += "then \n";
+ str += " System.out.println( \"hello2!!!\" ); \n";
+ str += "end \n";
+
+ KnowledgeBuilderProvider kbuilderFactory = this.client.getKnowledgeBuilderFactory();
+ KnowledgeBuilder kbuilder = kbuilderFactory.newKnowledgeBuilder();
+ kbuilder.add( ResourceFactory.newByteArrayResource( str.getBytes() ),
+ ResourceType.DRL );
+
+ if ( kbuilder.hasErrors() ) {
+ System.out.println( "Errors: " + kbuilder.getErrors() );
+ }
+
+ KnowledgeBaseProvider kbaseFactory = this.client.getKnowledgeBaseFactory();
+ KnowledgeBase kbase = kbaseFactory.newKnowledgeBase();
+
+ kbase.addKnowledgePackages( kbuilder.getKnowledgePackages() );
+
+ StatefulKnowledgeSession ksession = kbase.newStatefulKnowledgeSession();
+ int fired = ksession.fireAllRules();
+ Assert.assertEquals( 2,
+ fired );
+
+ }
+ @Test
+ public void testExecute() throws Exception {
+ String str = "";
+ str += "package org.drools \n";
+ str += "global java.util.List list \n";
+ str += "rule rule1 \n";
+ str += " dialect \"java\" \n";
+ str += "when \n";
+ str += "then \n";
+ str += " System.out.println( \"hello1!!!\" ); \n";
+ str += "end \n";
+ str += "rule rule2 \n";
+ str += " dialect \"java\" \n";
+ str += "when \n";
+ str += "then \n";
+ str += " System.out.println( \"hello2!!!\" ); \n";
+ str += "end \n";
+
+ KnowledgeBuilderProvider kbuilderFactory = this.client.getKnowledgeBuilderFactory();
+ KnowledgeBuilder kbuilder = kbuilderFactory.newKnowledgeBuilder();
+ kbuilder.add( ResourceFactory.newByteArrayResource( str.getBytes() ),
+ ResourceType.DRL );
+
+ if ( kbuilder.hasErrors() ) {
+ System.out.println( "Errors: " + kbuilder.getErrors() );
+ }
+
+ KnowledgeBaseProvider kbaseFactory = this.client.getKnowledgeBaseFactory();
+ KnowledgeBase kbase = kbaseFactory.newKnowledgeBase();
+
+ kbase.addKnowledgePackages( kbuilder.getKnowledgePackages() );
+
+ StatefulKnowledgeSession ksession = kbase.newStatefulKnowledgeSession();
+
+ ExecutionResults results = ksession.execute( new FireAllRulesCommand( "fired" ) );
+
+ Assert.assertEquals( 2,
+ (int) (Integer) results.getValue( "fired" ) );
+ }
@Test
public void testVsmPipeline() throws Exception {
@@ -185,5 +190,76 @@
(int) (Integer) results.getValue( "fired" ) );
System.out.println("TEst ENDED =========>");
}
-
+ @Test
+ public void twoSessionsIntoDifferentSessionServices(){
+
+ String str = "";
+ str += "package org.drools \n";
+ str += "global java.util.List list \n";
+ str += "rule rule1 \n";
+ str += " dialect \"java\" \n";
+ str += "when \n";
+ str += "then \n";
+ str += " System.out.println( \"hello1!!!\" ); \n";
+ str += "end \n";
+ str += "rule rule2 \n";
+ str += " dialect \"java\" \n";
+ str += "when \n";
+ str += "then \n";
+ str += " System.out.println( \"hello2!!!\" ); \n";
+ str += "end \n";
+
+ KnowledgeBuilderProvider kbuilderFactory = this.client.getKnowledgeBuilderFactory();
+ KnowledgeBuilder kbuilder = kbuilderFactory.newKnowledgeBuilder();
+ kbuilder.add( ResourceFactory.newByteArrayResource( str.getBytes() ),
+ ResourceType.DRL );
+
+ if ( kbuilder.hasErrors() ) {
+ System.out.println( "Errors: " + kbuilder.getErrors() );
+ }
+
+ KnowledgeBaseProvider kbaseFactory = this.client.getKnowledgeBaseFactory();
+ KnowledgeBase kbase = kbaseFactory.newKnowledgeBase();
+
+ kbase.addKnowledgePackages( kbuilder.getKnowledgePackages() );
+ ((ServiceManagerGridClient)this.client).setCurrentSessionService((SessionService)((ServiceManagerGridClient)this.client).getSessionServices().get(0));
+ StatefulKnowledgeSession ksession1 = kbase.newStatefulKnowledgeSession();
+ System.out.println("registering ksession1!");
+ this.client.register( "ksession1", ksession1 );
+
+ System.out.println("Let's go for the Second ksession");
+ ((ServiceManagerGridClient)this.client).setCurrentSessionService((SessionService)((ServiceManagerGridClient)this.client).getSessionServices().get(1));
+ //If I do this here.. and I don't create a new Kbase. the context got nothing and cannot find the kbase in the new session service.. of course
+
+ KnowledgeBuilderProvider kbuilderFactory2 = this.client.getKnowledgeBuilderFactory();
+ KnowledgeBuilder kbuilder2 = kbuilderFactory2.newKnowledgeBuilder();
+ kbuilder2.add( ResourceFactory.newByteArrayResource( str.getBytes() ),
+ ResourceType.DRL );
+
+ if ( kbuilder2.hasErrors() ) {
+ System.out.println( "Errors: " + kbuilder2.getErrors() );
+ }
+
+ KnowledgeBaseProvider kbaseFactory2 = this.client.getKnowledgeBaseFactory();
+ KnowledgeBase kbase2 = kbaseFactory2.newKnowledgeBase();
+
+ kbase2.addKnowledgePackages( kbuilder2.getKnowledgePackages() );
+
+ StatefulKnowledgeSession ksession2 = kbase2.newStatefulKnowledgeSession();
+ System.out.println("registering ksession2!");
+ this.client.register( "ksession2", ksession2 );
+
+ System.out.println("Lookuping up ksession1 !");
+ ExecutionResults results1 = this.client.lookup( "ksession1" ).execute( new FireAllRulesCommand( "fired" ) );
+
+ Assert.assertEquals( 2,
+ (int) (Integer) results1.getValue( "fired" ) );
+
+ System.out.println("Lookuping up ksession2 !");
+ ExecutionResults results2 = this.client.lookup( "ksession2" ).execute( new FireAllRulesCommand( "fired" ) );
+
+ Assert.assertEquals( 2,
+ (int) (Integer) results2.getValue( "fired" ) );
+
+ }
}
Modified: labs/jbossrules/branches/salaboy_grid-rio/drools-grid-rio/src/test/resources/org/drools/sessionService.groovy
===================================================================
--- labs/jbossrules/branches/salaboy_grid-rio/drools-grid-rio/src/test/resources/org/drools/sessionService.groovy 2010-01-20 14:36:19 UTC (rev 31158)
+++ labs/jbossrules/branches/salaboy_grid-rio/drools-grid-rio/src/test/resources/org/drools/sessionService.groovy 2010-01-20 14:37:36 UTC (rev 31159)
@@ -24,7 +24,7 @@
implementation(class:'org.drools.vsm.rio.service.SessionServiceImpl') {
artifact ref:'service'
}
- maintain 1
+ maintain 2
}
service(name: 'RegistryService') {
interfaces {
@@ -34,6 +34,9 @@
implementation(class:'org.drools.vsm.rio.service.RegistryServiceImpl') {
artifact ref:'service'
}
+
+ association (name:'SessionService', type:'uses', property:'sessionServices')
+
maintain 1
}
}
\ No newline at end of file
More information about the jboss-svn-commits
mailing list