nav[aria-label="Primary Navigation"] { padding: 0; & ul { list-style: none; width: 100%; display: flex; flex-direction: row; justify-content: start; align-items: start; gap: 30px; padding: 0; & li { margin: 0; } & ul li { list-style: none; } } }

As we transition to the new Hyland Community, some post links may be temporarily disrupted as we finalize redirects. We apologize for the inconvenience and are working to resolve this as quickly as possible. Details.

how to call TaskListener in osgi

minikiller

I run activiti in OSGI environment using blueprint file,I also want to use TaskListener. But I can not find a way to call TaskListener,because my TaskListener class can not be found by Activiti engine. How can help me to solve this problem.thanks.

Find more posts tagged with

Comments

pelorousjack

I am trying to do the same thing - use TaskListeners in an OSGI environment. I cannot get them to work. I believe I have found the problem in the Activiti code.

The BlueprintELResolver class has a bind and unbind method that accepts a JavaDelegate. Therefore when I define a service in my blueprint file that implements the JavaDelegate interface, I can see that the bind method is called, and my JavaDelegate class works.

When I define a service in my blueprint file that implements TaskListener or ExecutionListener interfaces, they are not found because there is no bind method to call that accepts them.

I think the BlueprintELResolver class could be updated to include bind methods for all the different interfaces, and then TaskListeners and ExecutionListeners would work in OSGI. Can someone open a JIRA ticket for this? I could not log in to the Activiti JIRA.

Thanks.

jbarrez

My osgi is really limited … but would this recent pull req solve your problem: https://github.com/alien11689/Activiti/commit/a5a80265c169aa5eb40f2edd99914cb9fabebbc4 ?

mikuc

Does this solve the problem?

<br>package org.activiti.osgi.blueprint;<br><br>import java.beans.FeatureDescriptor;<br>import java.util.HashMap;<br>import java.util.Iterator;<br>import java.util.Map;<br><br>import org.activiti.engine.delegate.JavaDelegate;<br>import org.activiti.engine.delegate.TaskListener;<br>import org.activiti.engine.impl.javax.el.ELContext;<br>import org.activiti.engine.impl.javax.el.ELResolver;<br>import org.activiti.engine.impl.pvm.delegate.ActivityBehavior;<br>import org.slf4j.Logger;<br>import org.slf4j.LoggerFactory;<br><br>/**<br> * @see org.activiti.spring.ApplicationContextElResolver<br> */<br>public class BlueprintELResolver extends ELResolver {<br> <br>&nbsp; private static final Logger LOGGER = LoggerFactory.getLogger(BlueprintELResolver.class);<br> private Map<String, JavaDelegate> delegateMap = new HashMap<String, JavaDelegate>();<br> private Map<String, TaskListener> taskListenerMap = new HashMap<String, TaskListener>();<br>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; private Map<String, ActivityBehavior> activityBehaviourMap = new HashMap<String, ActivityBehavior>();<br><br>&nbsp;&nbsp;&nbsp; public Object getValue(ELContext context, Object base, Object property) {<br>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; if (base == null) {<br>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; // according to javadoc, can only be a String<br>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; String key = (String) property;<br>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; for (String name : delegateMap.keySet()) {<br>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; if (name.equalsIgnoreCase(key)) {<br>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; context.setPropertyResolved(true);<br>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; return delegateMap.get(name);<br>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; }<br>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; }<br>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; for (String name : taskListenerMap.keySet()) {<br>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; if (name.equalsIgnoreCase(key)) {<br>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; context.setPropertyResolved(true);<br>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; return taskListenerMap.get(name);<br>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; }<br>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; }<br>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; for (String name : activityBehaviourMap.keySet()) {<br>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; if (name.equalsIgnoreCase(key)) {<br>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; context.setPropertyResolved(true);<br>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; return activityBehaviourMap.get(name);<br>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; }<br>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; }<br>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; }<br><br>&nbsp; return null;<br> }<br> <br> @SuppressWarnings("rawtypes")<br> public void bindService(JavaDelegate delegate, Map props) {<br>&nbsp;&nbsp;&nbsp; String name = (String) props.get("osgi.service.blueprint.compname");<br>&nbsp;&nbsp;&nbsp; delegateMap.put(name, delegate);<br>&nbsp;&nbsp;&nbsp; LOGGER.info("added Activiti service to delegate cache {}", name);<br> }<br><br> @SuppressWarnings("rawtypes")<br> public void unbindService(JavaDelegate delegate, Map props) {<br>&nbsp; String name = (String) props.get("osgi.service.blueprint.compname");<br>&nbsp;&nbsp;&nbsp; if(delegateMap.containsKey(name)) {<br>&nbsp;&nbsp;&nbsp;&nbsp; delegateMap.remove(name);<br>&nbsp;&nbsp;&nbsp; }<br>&nbsp;&nbsp;&nbsp; LOGGER.info("removed Activiti service from delegate cache {}", name);<br> }<br><br> <br> @SuppressWarnings("rawtypes")<br> public void bindTaskListenerService(TaskListener delegate, Map props) {<br>&nbsp;&nbsp;&nbsp; String name = (String) props.get("osgi.service.blueprint.compname");<br>&nbsp;&nbsp;&nbsp; taskListenerMap.put(name, delegate);<br>&nbsp;&nbsp;&nbsp; LOGGER.info("added Activiti service to delegate cache {}", name);<br> }<br> <br> @SuppressWarnings("rawtypes")<br> public void unbindTaskListenerService(TaskListener delegate, Map props) {<br>&nbsp; String name = (String) props.get("osgi.service.blueprint.compname");<br>&nbsp;&nbsp;&nbsp; if(taskListenerMap.containsKey(name)) {<br>&nbsp;&nbsp;&nbsp;&nbsp; taskListenerMap.remove(name);<br>&nbsp;&nbsp;&nbsp; }<br>&nbsp;&nbsp;&nbsp; LOGGER.info("removed Activiti service from delegate cache {}", name);<br> }<br> <br>&nbsp;&nbsp;&nbsp; @SuppressWarnings("rawtypes")<br>&nbsp;&nbsp;&nbsp; public void bindActivityBehaviourService(ActivityBehavior delegate, Map props) {<br>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; String name = (String) props.get("osgi.service.blueprint.compname");<br>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; activityBehaviourMap.put(name, delegate);<br>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; LOGGER.info("added Activiti service to activity behaviour cache {}", name);<br>&nbsp;&nbsp;&nbsp; }<br><br>&nbsp;&nbsp;&nbsp; @SuppressWarnings("rawtypes")<br>&nbsp;&nbsp;&nbsp; public void unbindActivityBehaviourService(ActivityBehavior delegate, Map props) {<br>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; String name = (String) props.get("osgi.service.blueprint.compname");<br>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; if(activityBehaviourMap.containsKey(name)) {<br>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; activityBehaviourMap.remove(name);<br>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; }<br>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; LOGGER.info("removed Activiti service from activity behaviour cache {}", name);<br>&nbsp;&nbsp;&nbsp; }<br><br> public boolean isReadOnly(ELContext context, Object base, Object property) {<br>&nbsp; return true;<br> }<br><br> public void setValue(ELContext context, Object base, Object property,<br>&nbsp;&nbsp;&nbsp;&nbsp; Object value) {<br> }<br><br> public Class<?> getCommonPropertyType(ELContext context, Object arg) {<br>&nbsp; return Object.class;<br> }<br><br> public Iterator<FeatureDescriptor> getFeatureDescriptors(ELContext context,<br>&nbsp;&nbsp;&nbsp;&nbsp; Object arg) {<br>&nbsp; return null;<br> }<br><br> public Class<?> getType(ELContext context, Object arg1, Object arg2) {<br>&nbsp; return Object.class;<br> }<br>}<br>