Author: tsurdilovic Date: 2010-09-12 12:15:25 -0400 (Sun, 12 Sep 2010) New Revision: 13736 Added: modules/drools/trunk/api/src/main/java/org/jboss/seam/drools/qualifiers/Channel.java modules/drools/trunk/api/src/main/java/org/jboss/seam/drools/qualifiers/SessionReport.java modules/drools/trunk/impl/src/main/java/org/jboss/seam/drools/SessionReportProducer.java modules/drools/trunk/impl/src/test/java/org/jboss/seam/drools/test/channel/ modules/drools/trunk/impl/src/test/java/org/jboss/seam/drools/test/channel/ChannelBean.java modules/drools/trunk/impl/src/test/java/org/jboss/seam/drools/test/channel/ChannelTest.java modules/drools/trunk/impl/src/test/java/org/jboss/seam/drools/test/channel/Person.java modules/drools/trunk/impl/src/test/resources/org/jboss/seam/drools/test/channel/ modules/drools/trunk/impl/src/test/resources/org/jboss/seam/drools/test/channel/ChannelTest-beans.xml modules/drools/trunk/impl/src/test/resources/org/jboss/seam/drools/test/channel/channeltest.drl Modified: modules/drools/trunk/api/pom.xml modules/drools/trunk/api/src/main/java/org/jboss/seam/drools/qualifiers/Query.java modules/drools/trunk/impl/pom.xml modules/drools/trunk/impl/src/main/java/org/jboss/seam/drools/KnowledgeSessionProducer.java modules/drools/trunk/impl/src/main/java/org/jboss/seam/drools/StatefulKnowledgeSessionWrapper.java modules/drools/trunk/impl/src/main/java/org/jboss/seam/drools/bootstrap/DroolsExtension.java modules/drools/trunk/impl/src/test/java/org/jboss/seam/drools/test/customoperator/CustomOperatorTest.java modules/drools/trunk/pom.xml Log: SEAMDROOLS-7 - Add support for Channel registration and integration Modified: modules/drools/trunk/api/pom.xml =================================================================== --- modules/drools/trunk/api/pom.xml 2010-09-11 05:48:19 UTC (rev 13735) +++ modules/drools/trunk/api/pom.xml 2010-09-12 16:15:25 UTC (rev 13736) @@ -36,30 +36,37 @@ <dependency> <groupId>org.drools</groupId> <artifactId>drools-core</artifactId> + <version>${drools.version}</version> </dependency> <dependency> <groupId>org.drools</groupId> <artifactId>drools-compiler</artifactId> + <version>${drools.version}</version> </dependency> <dependency> <groupId>org.drools</groupId> <artifactId>drools-api</artifactId> + <version>${drools.version}</version> </dependency> <dependency> <groupId>org.drools</groupId> <artifactId>drools-templates</artifactId> + <version>${drools.version}</version> </dependency> <dependency> <groupId>org.drools</groupId> <artifactId>drools-decisiontables</artifactId> + <version>${drools.version}</version> </dependency> <dependency> <groupId>org.drools</groupId> <artifactId>drools-workitems</artifactId> + <version>${drools.version}</version> </dependency> <dependency> <groupId>org.drools</groupId> - <artifactId>drools-transformer-xstream</artifactId> + <artifactId>drools-pipeline</artifactId> + <version>${drools.version}</version> </dependency> <dependency> <groupId>org.jboss.weld</groupId> Added: modules/drools/trunk/api/src/main/java/org/jboss/seam/drools/qualifiers/Channel.java =================================================================== --- modules/drools/trunk/api/src/main/java/org/jboss/seam/drools/qualifiers/Channel.java (rev 0) +++ modules/drools/trunk/api/src/main/java/org/jboss/seam/drools/qualifiers/Channel.java 2010-09-12 16:15:25 UTC (rev 13736) @@ -0,0 +1,50 @@ +/* + * JBoss, Home of Professional Open Source + * Copyright ${year}, Red Hat, Inc., and individual contributors + * by the @authors tag. See the copyright.txt 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.seam.drools.qualifiers; + +import static java.lang.annotation.ElementType.FIELD; +import static java.lang.annotation.ElementType.METHOD; +import static java.lang.annotation.ElementType.PARAMETER; +import static java.lang.annotation.ElementType.TYPE; +import static java.lang.annotation.RetentionPolicy.RUNTIME; + +import java.lang.annotation.Documented; +import java.lang.annotation.Inherited; +import java.lang.annotation.Retention; +import java.lang.annotation.Target; + +import javax.enterprise.util.Nonbinding; +import javax.inject.Qualifier; + +/** + * + * @author Tihomir Surdilovic + */ +@Qualifier +@Target( { TYPE, METHOD, FIELD, PARAMETER }) +@Documented +@Retention(RUNTIME) +@Inherited +public @interface Channel +{ + @Nonbinding String value() default ""; +} Property changes on: modules/drools/trunk/api/src/main/java/org/jboss/seam/drools/qualifiers/Channel.java ___________________________________________________________________ Name: svn:mime-type + text/plain Modified: modules/drools/trunk/api/src/main/java/org/jboss/seam/drools/qualifiers/Query.java =================================================================== --- modules/drools/trunk/api/src/main/java/org/jboss/seam/drools/qualifiers/Query.java 2010-09-11 05:48:19 UTC (rev 13735) +++ modules/drools/trunk/api/src/main/java/org/jboss/seam/drools/qualifiers/Query.java 2010-09-12 16:15:25 UTC (rev 13736) @@ -18,7 +18,7 @@ * 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.seam.drools.qualifiers; import static java.lang.annotation.ElementType.FIELD; @@ -40,10 +40,12 @@ * @author Tihomir Surdilovic */ @Qualifier -@Target( { TYPE, METHOD, FIELD, PARAMETER }) +@Target({ TYPE, METHOD, FIELD, PARAMETER }) @Documented @Retention(RUNTIME) @Inherited -public @interface Query { - @Nonbinding String value() default ""; +public @interface Query +{ + @Nonbinding + String value() default ""; } Added: modules/drools/trunk/api/src/main/java/org/jboss/seam/drools/qualifiers/SessionReport.java =================================================================== --- modules/drools/trunk/api/src/main/java/org/jboss/seam/drools/qualifiers/SessionReport.java (rev 0) +++ modules/drools/trunk/api/src/main/java/org/jboss/seam/drools/qualifiers/SessionReport.java 2010-09-12 16:15:25 UTC (rev 13736) @@ -0,0 +1,51 @@ +/* + * JBoss, Home of Professional Open Source + * Copyright ${year}, Red Hat, Inc., and individual contributors + * by the @authors tag. See the copyright.txt 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.seam.drools.qualifiers; + +import static java.lang.annotation.ElementType.FIELD; +import static java.lang.annotation.ElementType.METHOD; +import static java.lang.annotation.ElementType.PARAMETER; +import static java.lang.annotation.ElementType.TYPE; +import static java.lang.annotation.RetentionPolicy.RUNTIME; + +import java.lang.annotation.Documented; +import java.lang.annotation.Inherited; +import java.lang.annotation.Retention; +import java.lang.annotation.Target; + +import javax.enterprise.util.Nonbinding; +import javax.inject.Qualifier; + +/** + * + * @author Tihomir Surdilovic + */ +@Qualifier +@Target({ TYPE, METHOD, FIELD, PARAMETER }) +@Documented +@Retention(RUNTIME) +@Inherited +public @interface SessionReport +{ + @Nonbinding + String value() default ""; +} Property changes on: modules/drools/trunk/api/src/main/java/org/jboss/seam/drools/qualifiers/SessionReport.java ___________________________________________________________________ Name: svn:mime-type + text/plain Modified: modules/drools/trunk/impl/pom.xml =================================================================== --- modules/drools/trunk/impl/pom.xml 2010-09-11 05:48:19 UTC (rev 13735) +++ modules/drools/trunk/impl/pom.xml 2010-09-12 16:15:25 UTC (rev 13736) @@ -40,26 +40,32 @@ <dependency> <groupId>org.drools</groupId> <artifactId>drools-core</artifactId> + <version>${drools.version}</version> </dependency> <dependency> <groupId>org.drools</groupId> <artifactId>drools-compiler</artifactId> + <version>${drools.version}</version> </dependency> <dependency> <groupId>org.drools</groupId> <artifactId>drools-api</artifactId> + <version>${drools.version}</version> </dependency> <dependency> <groupId>org.drools</groupId> <artifactId>drools-templates</artifactId> + <version>${drools.version}</version> </dependency> <dependency> <groupId>org.drools</groupId> <artifactId>drools-decisiontables</artifactId> + <version>${drools.version}</version> </dependency> <dependency> <groupId>org.drools</groupId> <artifactId>drools-workitems</artifactId> + <version>${drools.version}</version> </dependency> <dependency> <groupId>org.jboss.weld</groupId> Modified: modules/drools/trunk/impl/src/main/java/org/jboss/seam/drools/KnowledgeSessionProducer.java =================================================================== --- modules/drools/trunk/impl/src/main/java/org/jboss/seam/drools/KnowledgeSessionProducer.java 2010-09-11 05:48:19 UTC (rev 13735) +++ modules/drools/trunk/impl/src/main/java/org/jboss/seam/drools/KnowledgeSessionProducer.java 2010-09-12 16:15:25 UTC (rev 13736) @@ -28,7 +28,6 @@ import javax.enterprise.context.RequestScoped; import javax.enterprise.context.SessionScoped; import javax.enterprise.inject.Disposes; -import javax.enterprise.inject.New; import javax.enterprise.inject.Produces; import javax.enterprise.inject.spi.BeanManager; import javax.inject.Inject; @@ -67,7 +66,7 @@ @Inject SeamDelegate delegate; - + @Produces @RequestScoped public StatefulKnowledgeSession produceStatefulSession(KnowledgeBase kbase,DroolsConfig config) throws Exception @@ -79,6 +78,7 @@ addEventListeners(ksession); addWorkItemHandlers(ksession); addFactProviders(ksession); + addChannels(ksession); return ksession; } @@ -95,6 +95,7 @@ addEventListeners(ksession); addWorkItemHandlers(ksession); addFactProviders(ksession); + addChannels(ksession); return ksession; } @@ -179,6 +180,15 @@ } } + private void addChannels(StatefulKnowledgeSession ksession) { + Iterator<String> iter = droolsExtension.getChannels().keySet().iterator(); + while(iter.hasNext()) + { + String channelName = iter.next(); + ksession.registerChannel(channelName, droolsExtension.getChannels().get(channelName)); + } + } + private void addFactProviders(StatefulKnowledgeSession ksession) { Iterator<FactProvider> iter = droolsExtension.getFactProviderSet().iterator(); while(iter.hasNext()) Added: modules/drools/trunk/impl/src/main/java/org/jboss/seam/drools/SessionReportProducer.java =================================================================== --- modules/drools/trunk/impl/src/main/java/org/jboss/seam/drools/SessionReportProducer.java (rev 0) +++ modules/drools/trunk/impl/src/main/java/org/jboss/seam/drools/SessionReportProducer.java 2010-09-12 16:15:25 UTC (rev 13736) @@ -0,0 +1,38 @@ +/* + * JBoss, Home of Professional Open Source + * Copyright ${year}, Red Hat, Inc., and individual contributors + * by the @authors tag. See the copyright.txt 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.seam.drools; + +import javax.enterprise.context.SessionScoped; + +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; + +/** + * + * @author Tihomir Surdilovic + */ +@SessionScoped +public class SessionReportProducer +{ + private static final Logger log = LoggerFactory.getLogger(SessionReportProducer.class); + +} Property changes on: modules/drools/trunk/impl/src/main/java/org/jboss/seam/drools/SessionReportProducer.java ___________________________________________________________________ Name: svn:mime-type + text/plain Modified: modules/drools/trunk/impl/src/main/java/org/jboss/seam/drools/StatefulKnowledgeSessionWrapper.java =================================================================== --- modules/drools/trunk/impl/src/main/java/org/jboss/seam/drools/StatefulKnowledgeSessionWrapper.java 2010-09-11 05:48:19 UTC (rev 13735) +++ modules/drools/trunk/impl/src/main/java/org/jboss/seam/drools/StatefulKnowledgeSessionWrapper.java 2010-09-12 16:15:25 UTC (rev 13736) @@ -39,6 +39,8 @@ import org.drools.marshalling.MarshallerFactory; import org.drools.marshalling.ObjectMarshallingStrategy; import org.drools.marshalling.ObjectMarshallingStrategyAcceptor; +import org.drools.runtime.Calendars; +import org.drools.runtime.Channel; import org.drools.runtime.Environment; import org.drools.runtime.ExecutionResults; import org.drools.runtime.ExitPoint; @@ -50,7 +52,9 @@ import org.drools.runtime.rule.Agenda; import org.drools.runtime.rule.AgendaFilter; import org.drools.runtime.rule.FactHandle; +import org.drools.runtime.rule.LiveQuery; import org.drools.runtime.rule.QueryResults; +import org.drools.runtime.rule.ViewChangedEventListener; import org.drools.runtime.rule.WorkingMemoryEntryPoint; import org.drools.time.SessionClock; @@ -281,7 +285,7 @@ @SuppressWarnings("unchecked") public ExecutionResults execute(Command command) { - return ksession.execute(command); + return (ExecutionResults) ksession.execute(command); } public void addEventListener(AgendaEventListener listener) @@ -333,7 +337,50 @@ { return ksession.getWorkingMemoryEntryPoint(name); } + + + public Calendars getCalendars() + { + return ksession.getCalendars(); + } + + public Map<String, Channel> getChannels() + { + return ksession.getChannels(); + } + + public void registerChannel(String arg0, Channel arg1) + { + ksession.registerChannel(arg0, arg1); + + } + + public void unregisterChannel(String arg0) + { + ksession.unregisterChannel(arg0); + } + + public void signalEvent(String arg0, Object arg1, long arg2) + { + ksession.signalEvent(arg0, arg1, arg2); + } + + public LiveQuery openLiveQuery(String arg0, Object[] arg1, ViewChangedEventListener arg2) + { + return ksession.openLiveQuery(arg0, arg1, arg2); + } + + public String getEntryPointId() + { + return ksession.getEntryPointId(); + } + + public long getFactCount() + { + return ksession.getFactCount(); + } + public Collection<? extends WorkingMemoryEntryPoint> getWorkingMemoryEntryPoints() { return ksession.getWorkingMemoryEntryPoints(); Modified: modules/drools/trunk/impl/src/main/java/org/jboss/seam/drools/bootstrap/DroolsExtension.java =================================================================== --- modules/drools/trunk/impl/src/main/java/org/jboss/seam/drools/bootstrap/DroolsExtension.java 2010-09-11 05:48:19 UTC (rev 13735) +++ modules/drools/trunk/impl/src/main/java/org/jboss/seam/drools/bootstrap/DroolsExtension.java 2010-09-12 16:15:25 UTC (rev 13736) @@ -36,6 +36,7 @@ import javax.enterprise.inject.spi.Extension; import javax.enterprise.util.AnnotationLiteral; +import org.drools.runtime.Channel; import org.drools.base.evaluators.EvaluatorDefinition; import org.drools.event.knowledgebase.KnowledgeBaseEventListener; import org.drools.runtime.process.WorkItemHandler; @@ -58,6 +59,7 @@ private Map<String, TemplateDataProvider> templateDataProviders = new HashMap<String, TemplateDataProvider>(); private Set<FactProvider> factProviderSet = new HashSet<FactProvider>(); private Map<String, EvaluatorDefinition> evaluatorDefinitions = new HashMap<String, EvaluatorDefinition>(); + private Map<String, Channel> channels = new HashMap<String, Channel>(); @SuppressWarnings("serial") void afterBeanDiscovery(@Observes AfterBeanDiscovery abd, BeanManager bm) { @@ -130,7 +132,28 @@ } log.info("End creating [" + ( allEvaluatorDefinitions== null ? 0 : allEvaluatorDefinitions.size())+ "] evaluator definitions"); + // Channels + log.info("Start creating channel definitions"); + Set<Bean<?>> allChannels = bm.getBeans(org.drools.runtime.Channel.class, new AnnotationLiteral<Any>(){}); + if(allChannels != null) { + Iterator<Bean<?>> iter = allChannels.iterator(); + while (iter.hasNext()) + { + Bean<?> channel = iter.next(); + org.jboss.seam.drools.qualifiers.Channel evaluatorAnnotation = channel.getBeanClass().getAnnotation(org.jboss.seam.drools.qualifiers.Channel.class); + String channelName = evaluatorAnnotation.value(); + if(channelName.length() > 0) { + CreationalContext<?> context = bm.createCreationalContext(channel); + org.drools.runtime.Channel channelInstance = (org.drools.runtime.Channel) bm.getReference(channel, org.drools.runtime.Channel.class, context); + channels.put(channelName, channelInstance); + } else { + throw new IllegalStateException("Channel name cannot be empty in class: " + channel.getBeanClass().getName()); + } + } + } + log.info("End creating [" + ( allChannels== null ? 0 : allChannels.size())+ "] channel definitions"); + //Template Data Providers log.info("Start creating template providers"); Set<Bean<?>> allTemplateProviders = bm.getBeans(TemplateDataProvider.class, new AnnotationLiteral<Any>(){}); @@ -194,5 +217,15 @@ public Map<String, EvaluatorDefinition> getEvaluatorDefinitions() { return evaluatorDefinitions; + } + + public static Logger getLog() + { + return log; + } + + public Map<String, Channel> getChannels() + { + return channels; } } Added: modules/drools/trunk/impl/src/test/java/org/jboss/seam/drools/test/channel/ChannelBean.java =================================================================== --- modules/drools/trunk/impl/src/test/java/org/jboss/seam/drools/test/channel/ChannelBean.java (rev 0) +++ modules/drools/trunk/impl/src/test/java/org/jboss/seam/drools/test/channel/ChannelBean.java 2010-09-12 16:15:25 UTC (rev 13736) @@ -0,0 +1,37 @@ +package org.jboss.seam.drools.test.channel; + +import java.util.ArrayList; +import java.util.List; + +import org.jboss.seam.drools.qualifiers.Channel; + +@Channel("testChannel") +public class ChannelBean implements org.drools.runtime.Channel +{ + private int numOfSentObjects = 0; + private List<Person> eligiblesList = new ArrayList<Person>(); + private List<Person> notEligiblesList = new ArrayList<Person>(); + + public void send(Object personObject) + { + Person p = (Person) personObject; + if(p.isEligible()) { + eligiblesList.add(p); + } else { + notEligiblesList.add(p); + } + numOfSentObjects++; + } + + public int getNumOfSentObjects() { + return numOfSentObjects; + } + + public List<Person> getEligiblesList() { + return eligiblesList; + } + + public List<Person> getNotEligiblesList() { + return notEligiblesList; + } +} Property changes on: modules/drools/trunk/impl/src/test/java/org/jboss/seam/drools/test/channel/ChannelBean.java ___________________________________________________________________ Name: svn:mime-type + text/plain Added: modules/drools/trunk/impl/src/test/java/org/jboss/seam/drools/test/channel/ChannelTest.java =================================================================== --- modules/drools/trunk/impl/src/test/java/org/jboss/seam/drools/test/channel/ChannelTest.java (rev 0) +++ modules/drools/trunk/impl/src/test/java/org/jboss/seam/drools/test/channel/ChannelTest.java 2010-09-12 16:15:25 UTC (rev 13736) @@ -0,0 +1,117 @@ +/* + * JBoss, Home of Professional Open Source + * Copyright 2010, Red Hat, Inc., and individual contributors + * by the @authors tag. See the copyright.txt 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.seam.drools.test.channel; + +import static org.junit.Assert.assertNotNull; +import static org.junit.Assert.assertTrue; + +import javax.enterprise.inject.Default; +import javax.inject.Inject; + +import org.drools.runtime.StatefulKnowledgeSession; +import org.jboss.arquillian.api.Deployment; +import org.jboss.arquillian.junit.Arquillian; +import org.jboss.seam.drools.KnowledgeBaseProducer; +import org.jboss.seam.drools.qualifiers.config.DefaultConfig; +import org.jboss.seam.drools.test.DroolsModuleFilter; +import org.jboss.shrinkwrap.api.ArchivePaths; +import org.jboss.shrinkwrap.api.ShrinkWrap; +import org.jboss.shrinkwrap.api.spec.JavaArchive; +import org.jboss.weld.extensions.resourceLoader.ResourceProvider; +import org.junit.Test; +import org.junit.runner.RunWith; + +(a)RunWith(Arquillian.class) +public class ChannelTest +{ + @Deployment + public static JavaArchive createTestArchive() + { + String pkgPath = ChannelTest.class.getPackage().getName().replaceAll("\\.", "/"); + JavaArchive archive = ShrinkWrap.create("test.jar", JavaArchive.class) + .addPackages(true, new DroolsModuleFilter("channel"), KnowledgeBaseProducer.class.getPackage()) + .addPackages(true, ResourceProvider.class.getPackage()) + .addClass(ChannelBean.class) + .addClass(Person.class) + .addResource(pkgPath + "/channeltest.drl", ArchivePaths.create("channeltest.drl")) + // .addResource(pkgPath + "/kbuilderconfig.properties", + // ArchivePaths.create("kbuilderconfig.properties")) + // .addResource(pkgPath + "/kbaseconfig.properties", + // ArchivePaths.create("kbaseconfig.properties")) + .addManifestResource(pkgPath + "/ChannelTest-beans.xml", ArchivePaths.create("beans.xml")); + // System.out.println(archive.toString(Formatters.VERBOSE)); + return archive; + } + + @Inject + @Default + @DefaultConfig + StatefulKnowledgeSession ksession; + + @Inject ChannelBean channelBean; + + @Test + public void testChannel() + { + assertNotNull(ksession); + assertNotNull(channelBean); + + Person p1 = new Person(); + p1.setAge(12); + + Person p2 = new Person(); + p2.setAge(20); + + Person p3 = new Person(); + p3.setAge(4); + + Person p4 = new Person(); + p4.setAge(19); + + Person p5 = new Person(); + p5.setAge(33); + + Person p6 = new Person(); + p6.setAge(55); + + Person p7 = new Person(); + p7.setAge(15); + + Person p8 = new Person(); + p8.setAge(69); + + ksession.insert(p1); + ksession.insert(p2); + ksession.insert(p3); + ksession.insert(p4); + ksession.insert(p5); + ksession.insert(p6); + ksession.insert(p7); + ksession.insert(p8); + + ksession.fireAllRules(); + + assertTrue(channelBean.getEligiblesList().size() == 5); + assertTrue(channelBean.getNotEligiblesList().size() == 3); + + } +} Property changes on: modules/drools/trunk/impl/src/test/java/org/jboss/seam/drools/test/channel/ChannelTest.java ___________________________________________________________________ Name: svn:mime-type + text/plain Added: modules/drools/trunk/impl/src/test/java/org/jboss/seam/drools/test/channel/Person.java =================================================================== --- modules/drools/trunk/impl/src/test/java/org/jboss/seam/drools/test/channel/Person.java (rev 0) +++ modules/drools/trunk/impl/src/test/java/org/jboss/seam/drools/test/channel/Person.java 2010-09-12 16:15:25 UTC (rev 13736) @@ -0,0 +1,27 @@ +package org.jboss.seam.drools.test.channel; + +public class Person +{ + private int age; + private boolean eligible = false; + + public int getAge() { + return age; + } + + public void setAge(int age) { + this.age = age; + } + + public boolean isEligible() + { + return eligible; + } + + public void setEligible(boolean eligible) + { + this.eligible = eligible; + } + + +} Property changes on: modules/drools/trunk/impl/src/test/java/org/jboss/seam/drools/test/channel/Person.java ___________________________________________________________________ Name: svn:mime-type + text/plain Modified: modules/drools/trunk/impl/src/test/java/org/jboss/seam/drools/test/customoperator/CustomOperatorTest.java =================================================================== --- modules/drools/trunk/impl/src/test/java/org/jboss/seam/drools/test/customoperator/CustomOperatorTest.java 2010-09-11 05:48:19 UTC (rev 13735) +++ modules/drools/trunk/impl/src/test/java/org/jboss/seam/drools/test/customoperator/CustomOperatorTest.java 2010-09-12 16:15:25 UTC (rev 13736) @@ -47,12 +47,18 @@ public static JavaArchive createTestArchive() { String pkgPath = CustomOperatorTest.class.getPackage().getName().replaceAll("\\.", "/"); - JavaArchive archive = ShrinkWrap.create("test.jar", JavaArchive.class).addPackages(true, new DroolsModuleFilter("customoperator"), KnowledgeBaseProducer.class.getPackage()).addPackages(true, ResourceProvider.class.getPackage()).addClass(MessageBean.class).addClass(StrEvaluator.class).addClass(StrEvaluatorDefinition.class).addResource(pkgPath + "/customoperatortest.drl", ArchivePaths.create("customoperatortest.drl")) + JavaArchive archive = ShrinkWrap.create("test.jar", JavaArchive.class) + .addPackages(true, new DroolsModuleFilter("customoperator"), KnowledgeBaseProducer.class.getPackage()) + .addPackages(true, ResourceProvider.class.getPackage()) + .addClass(MessageBean.class) + .addClass(StrEvaluator.class) + .addClass(StrEvaluatorDefinition.class) + .addResource(pkgPath + "/customoperatortest.drl", ArchivePaths.create("customoperatortest.drl")) // .addResource(pkgPath + "/kbuilderconfig.properties", // ArchivePaths.create("kbuilderconfig.properties")) // .addResource(pkgPath + "/kbaseconfig.properties", // ArchivePaths.create("kbaseconfig.properties")) - .addManifestResource(pkgPath + "/CustomOperatorTest-beans.xml", ArchivePaths.create("beans.xml")); + .addManifestResource(pkgPath + "/CustomOperatorTest-beans.xml", ArchivePaths.create("beans.xml")); // System.out.println(archive.toString(Formatters.VERBOSE)); return archive; } Added: modules/drools/trunk/impl/src/test/resources/org/jboss/seam/drools/test/channel/ChannelTest-beans.xml =================================================================== --- modules/drools/trunk/impl/src/test/resources/org/jboss/seam/drools/test/channel/ChannelTest-beans.xml (rev 0) +++ modules/drools/trunk/impl/src/test/resources/org/jboss/seam/drools/test/channel/ChannelTest-beans.xml 2010-09-12 16:15:25 UTC (rev 13736) @@ -0,0 +1,35 @@ +<!-- +JBoss, Home of Professional Open Source +Copyright ${year}, Red Hat, Inc., and individual contributors +by the @authors tag. See the copyright.txt 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. +--> +<beans xmlns="http://java.sun.com/xml/ns/javaee" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" + xmlns:s="urn:java:ee" + xmlns:d="urn:java:org.jboss.seam.drools:org.jboss.seam.drools.config" + xmlns:test="urn:java:org.jboss.seam.drools.test.ksession"> + + <d:DefaultRuleResources> + <s:modifies/> + <s:Exact>org.jboss.seam.drools.config.DefaultRuleResources</s:Exact> + <d:resources> + <s:value>classpath;channeltest.drl;DRL</s:value> + </d:resources> + </d:DefaultRuleResources> + +</beans> Property changes on: modules/drools/trunk/impl/src/test/resources/org/jboss/seam/drools/test/channel/ChannelTest-beans.xml ___________________________________________________________________ Name: svn:mime-type + text/plain Added: modules/drools/trunk/impl/src/test/resources/org/jboss/seam/drools/test/channel/channeltest.drl =================================================================== --- modules/drools/trunk/impl/src/test/resources/org/jboss/seam/drools/test/channel/channeltest.drl (rev 0) +++ modules/drools/trunk/impl/src/test/resources/org/jboss/seam/drools/test/channel/channeltest.drl 2010-09-12 16:15:25 UTC (rev 13736) @@ -0,0 +1,19 @@ +package org.jboss.seam.drools.test.channel + +import org.jboss.seam.drools.test.channel.Person; + +rule eligiblePerson + when + $p : Person( age <= 18 ) + then + $p.setEligible(true); + channels["testChannel"].send( $p ); +end + +rule notElibiglePerson + when + $p : Person( age > 18 ) + then + $p.setEligible(false); + channels["testChannel"].send( $p ); +end \ No newline at end of file Modified: modules/drools/trunk/pom.xml =================================================================== --- modules/drools/trunk/pom.xml 2010-09-11 05:48:19 UTC (rev 13735) +++ modules/drools/trunk/pom.xml 2010-09-12 16:15:25 UTC (rev 13736) @@ -7,7 +7,7 @@ <artifactId>seam-parent</artifactId> <version>3</version> </parent> - + <artifactId>seam-drools-parent</artifactId> <groupId>org.jboss.seam.drools</groupId> <version>3.0.0-SNAPSHOT</version> @@ -47,6 +47,7 @@ </developers> <properties> + <drools.version>5.1.1</drools.version> <seam.version>3.0.0.b01</seam.version> <weld-extensions.version>1.0.0-SNAPSHOT</weld-extensions.version> </properties>