Camel and Osgi

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.

rvi

Hi,

I want deploy a process with some camel servicetasks in a osgi container.

I get this problem:
the osgi engine bundle looks for JavaDelegate services,
but CamelBehavior implements ActivityBehavior.

It seems to work if we expose the CamelBehavior as a JavaDelegate with this implementation:

public class CamelDelegate extends CamelBehaviour implements JavaDelegate {

   public CamelDelegate(Collection<ContextProvider> camelContext) {
      super(camelContext);
   }

   public void execute(DelegateExecution execution) throws Exception {
      if(execution instanceof ActivityExecution) {
         super.execute((ActivityExecution)execution);
      } else {
         throw new UnsupportedOperationException("cannot execute execution of type "+execution.getClass().getName()+" , "+execution.getEventName() );
      }
   }

}‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍

is it correct ? what is the difference between a JavaDelegate and and ActivityBehavior ?

would it be possible to better support camel with a osgi container in the activiti code:
- CamelBehavior implements directly JavaDelegate
- or BlueprintELResolver looks for ActivitiBehavior
?

thanks for help
Richard

rvi

is it correct ? what is the difference between a JavaDelegate and and ActivityBehavior ?

would it be possible to better support camel with a osgi container in the activiti code:
- CamelBehavior implements directly JavaDelegate
- or BlueprintELResolver looks for ActivitiBehavior
?

actually this solution DOESN'T work. (it executes twice the outgoing relations..)

The only solution is to extend the BlueprintELResolver so it accepts ActivitiBehavior.
I've tested that with an extended ELresolver:
<br>public class ExtendedELResolver extends BlueprintELResolver {<br><br>&nbsp;&nbsp;&nbsp; private static final Logger LOGGER = Logger.getLogger(ExtendedELResolver.class.getName());<br>&nbsp;&nbsp;&nbsp; private Map<String, ActivityBehavior> behaviorMap = 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 : behaviorMap.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 behaviorMap.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;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; return super.getValue(context,base,property);<br>&nbsp;&nbsp;&nbsp; }<br><br>&nbsp;&nbsp;&nbsp; public void bindService(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; behaviorMap.put(name, delegate);<br>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; LOGGER.info("added Activiti service to behavior cache " + name);<br>&nbsp;&nbsp;&nbsp; }<br><br>&nbsp;&nbsp;&nbsp; public void unbindService(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(behaviorMap.containsKey(name)) {<br>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; behaviorMap.remove(name);<br>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; }<br>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; LOGGER.info("removed Activiti service from behavior cache " + name);<br>&nbsp;&nbsp;&nbsp; }<br>}and adding a reference-listener in the blueprint context of the osgi:
<br>&nbsp;&nbsp;&nbsp; <reference-list id="activityBehaviorProviders" availability="optional"<br>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; interface=[b]"org.activiti.engine.impl.pvm.delegate.ActivityBehavior"[/b]<br>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; activation="eager"><br>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; <reference-listener ref="blueprintELResolver" bind-method="bindService" unbind-method="unbindService"/><br>&nbsp;&nbsp;&nbsp; </reference-list><br>&nbsp;&nbsp;&nbsp; <bean id="blueprintELResolver" [b]class="test.ExtendedBlueprintELResolver"[/b] /><br>
of course it would be better to directly modify the BlueprintELResolver so it accepts the ActivitiBehavior. Should I open a JIRA ?

thanks,
Richard