[RHDM-1461] allow to define an AgendaFilter when starting a process (#…

…2265)

* [RHDM-1461] allow to define an AgendaFilter when starting a process

* wip

kie-aries-blueprint/src/main/java/org/kie/aries/blueprint/factorybeans/KieImportSessionResolver.java

@@ -209,6 +209,16 @@ public ProcessInstance startProcess( String s, Map<String, Object> map ) {
         return kieSession.startProcess( s, map );
     }
 
+    @Override
+    public ProcessInstance startProcess( String s, AgendaFilter agendaFilter ) {
+        return kieSession.startProcess( s, agendaFilter );
+    }
+
+    @Override
+    public ProcessInstance startProcess( String s, Map<String, Object> map, AgendaFilter agendaFilter ) {
+        return kieSession.startProcess( s, map, agendaFilter );
+    }
+
     @Override
     public ProcessInstance createProcessInstance( String s, Map<String, Object> map ) {
         return kieSession.createProcessInstance( s, map );

kie-aries-blueprint/src/main/java/org/kie/aries/blueprint/factorybeans/KieSessionResolver.java

@@ -346,6 +346,16 @@ public ProcessInstance startProcess(String processId, Map<String, Object> parame
         return getKieSession().startProcess(processId, parameters);
     }
 
+    @Override
+    public ProcessInstance startProcess(String processId, AgendaFilter agendaFilter) {
+        return getKieSession().startProcess(processId, agendaFilter);
+    }
+
+    @Override
+    public ProcessInstance startProcess(String processId, Map<String, Object> parameters, AgendaFilter agendaFilter) {
+        return getKieSession().startProcess(processId, parameters, agendaFilter);
+    }
+
     @Override
     public ProcessInstance createProcessInstance(String processId, Map<String, Object> parameters) {
         return getKieSession().createProcessInstance(processId, parameters);

kie-spring/src/test/java/org/kie/spring/timer/MyDroolsBean.java

@@ -16,14 +16,14 @@
 
 package org.kie.spring.timer;
 
-import static org.junit.Assert.*;
 import java.util.concurrent.BrokenBarrierException;
 import java.util.concurrent.CyclicBarrier;
-import java.util.concurrent.Semaphore;
 import java.util.concurrent.TimeUnit;
 import java.util.concurrent.TimeoutException;
 import java.util.concurrent.atomic.AtomicInteger;
 
+import javax.persistence.EntityManager;
+import javax.persistence.EntityManagerFactory;
 import org.drools.core.base.MapGlobalResolver;
 import org.kie.api.KieBase;
 import org.kie.api.KieServices;
@@ -35,8 +35,8 @@
 import org.slf4j.LoggerFactory;
 import org.springframework.orm.jpa.JpaTransactionManager;
 
-import javax.persistence.EntityManager;
-import javax.persistence.EntityManagerFactory;
+import static org.junit.Assert.assertTrue;
+import static org.junit.Assert.fail;
 
 public class MyDroolsBean {
 
@@ -65,7 +65,7 @@ public void initStartDisposeAndLoadSession() {
 
             ksession.getWorkItemManager().registerWorkItemHandler("testWorkItemHandler", workItemHandler);
 
-            ksession.startProcess("timer-flow", null);
+            ksession.startProcess("timer-flow");
 
             // wait for process to start and for first timer to finish
             waitForOtherThread();