topic Re: Mule Integration in Alfresco Archive

Mule Integration

brianrook — Tue, 19 Jul 2011 14:51:28 GMT

Hello, I'm working on a project where I intend to call Mule from inside of an Activiti process. I have downloaded and installed Activiti 5.6 and I've got the database setup.From my bpmn20.xml file: <process id="createInboundDocument"> <startEvent id="start" /> <sequenceFl

Re: Mule Integration

trademak — Wed, 20 Jul 2011 06:39:22 GMT

Hi,

Did you look at my blog post article and the corresponding source code?
http://bpmn20inaction.blogspot.com/2011/05/supersize-activiti-with-mule-esb-and.html

Best regards,

Re: Mule Integration

brianrook — Wed, 20 Jul 2011 14:33:03 GMT

I did see your post.

I think my bpmn sequence element is correct and I'm using the activiti-mule.jar. Is there something else I need to be doing?

Re: Mule Integration

trademak — Thu, 21 Jul 2011 07:27:14 GMT

You should really provide more information about your problem.
Are you using the remote or the embedded version of the Activiti Mule integration?
Did you include the following lines in the ProcessEngineConfiguration:

<property name="beans">
                        <map>
                                <entry key="muleContext" value-ref="_muleContext" />
                        </map>
                </property>

Best regards,

Re: Mule Integration

mathiasd — Mon, 26 Sep 2011 09:29:33 GMT

Hi,
I try to make my own "Hello world" activiti-mule sample. I try to understand your code https://code.google.com/p/activiti-esb-blog/ but it is a little bit complicated for a newbie :s
Is it the shortest "hello world" possible using activiti and mule ?

What I would like to do is interact with this mule :


<simple-service name="hello" address="http://localhost:8080/hello">
        <script:component>
            <script:script engine="groovy">
                <script:text>return "Hello World"</script:text>
            </script:script>
        </script:component>
    </simple-service>

Is it possible ?

Re: Mule Integration

trademak — Mon, 26 Sep 2011 11:03:49 GMT

Sure. But if you find the blog post contains not enough information, a better way to learn it is to read chapter 11 of the Activiti in Action book, which is already available in the MEAP program.
There's an example in there that does almost the same thing as you describe.

Best regards,

Re: Mule Integration

mathiasd — Mon, 26 Sep 2011 12:07:12 GMT

Ok, thanks

Re: Mule Integration

mathiasd — Mon, 26 Sep 2011 13:58:15 GMT

Could I ask you something else ?

In your sample, you define the processEngineConfiguration as :

<bean id="processEngineConfiguration" class="org.activiti.spring.SpringProcessEngineConfiguration">
  <property name="databaseType" value="h2" />
  <property name="dataSource" ref="dataSource" />
  <property name="transactionManager" ref="transactionManager" />
  <property name="databaseSchemaUpdate" value="true" />
  <property name="beans">
   <map>
    <entry key="muleContext" value-ref="_muleContext" />
   </map>
  </property>
 </bean>

I don't understand where the "_muleContext" comes from. I was expecting to find something like :


<bean id="_muleContext" …>
…
</bean>

But I didn't find anything like that. When I tried to run my own helloWorld, i have :

Caused by: org.springframework.beans.factory.NoSuchBeanDefinitionException: No bean named '_muleContext' is defined
…
…

Could you explain me how to instantiate this _muleContext variable ?

Thanks

Re: Mule Integration

trademak — Mon, 26 Sep 2011 15:15:58 GMT

Sure. I can understand that, it's a bit low-level.
The _muleContext variable is created within the Mule framework when starting an embedded Mule container.
So when you use the activiti-embedded connector of Mule this variable is available.
When you use the remote equivalent this is not possible.
So you can only invoke Mule flows directly when using the embedded approach.
When you would want to use the remote approach, the default way to invoke flows is to use a web service task.

Best regards,

Re: Mule Integration

mathiasd — Mon, 26 Sep 2011 16:27:39 GMT

Ok, but I added this :


<bean id="_muleContext" factory-bean="muleFactory" factory-method="createMuleContext">
  <constructor-arg type="java.lang.String" value="src/main/resources/application-context.xml"/>
</bean>

And it works.
The problem I have now is that the http mule sends back a "ReleasingInputStream" which is not serializable and so Activiti throw an exception when I try to put this into a resultVariable.
But I guess this is more a Mule problem than an Activiti one and I have some ideas to fix this.

Thanks for your help !

Mathias

Re: Mule Integration

mathiasd — Wed, 28 Sep 2011 08:07:06 GMT

I'm back ! Not sure actually that the problem is a Mule problem. Is it possible to do some transformation on the response of the Mule ?
I would like to do something like :


<sendTask id="sendMule" activiti:type="mule">
   <extensionElements>
    <activiti:field name="endpointUrl">
     <activiti:string>http://localhost:8080/hello/</activiti:string>
    </activiti:field>
    <activiti:field name="language">
     <activiti:string>juel</activiti:string>
    </activiti:field>
    <activiti:field name="payloadExpression">
     <activiti:expression>${message}</activiti:expression>
    </activiti:field>
    <activiti:field name="resultVariable" > 
     <activiti:expression>${var1 = result.getContent().toString()}</activiti:expression>
    </activiti:field>
        </extensionElements>
</sendTask>

Is it possible ?

Thanks

Re: Mule Integration

trademak — Wed, 28 Sep 2011 13:04:05 GMT

Hi,

Great to have you back!
No transformation is actually something you would want to do in the Mule container. Mule is very well capable of doing all kinds of transformations.
The resultVariableName is only a string value that's used to set the result in the execution.

Best regards,

Re: Mule Integration

mathiasd — Wed, 28 Sep 2011 14:07:50 GMT

Thanks but I think a HTTP mule will always returns a http-response. So the decoding should be done by the client (here the client is the workflow). Plus, the Mule forum is a real nightmare 😕

But don't worry, I will find something

Re: Mule Integration

mask87 — Wed, 11 Jan 2012 10:20:02 GMT

I'm a new adapter of activiti et a will be integrete with mule
but this syntax doesn't work when a deploye in activiti-explorer

<sendTask id="create_workitem" activiti:type="mule">
         <extensionElements>
            <activiti:field name="endpointUrl"
               expression="vm://createWorkItem.in?connector=vmSync" />
            <activiti:field name="language">
               <activiti:string>juel</activiti:string>
            </activiti:field>
            <activiti:field name="payloadExpression">
               <activiti:string>#{createWorkItemAction}</activiti:string>
            </activiti:field>
            <activiti:field name="resultVariable">
               <activiti:string>workItemCollection</activiti:string>
            </activiti:field>
         </extensionElements>
      </sendTask>

I use Activiti 5.8

Re: Mule Integration

mask87 — Wed, 11 Jan 2012 10:49:38 GMT

Hello, I'm working on a project where I intend to call Mule from inside of an Activiti process. I have downloaded and installed Activiti 5.6

From my bpmn20.xml file:

 <serviceTask id="servicetask1" activiti:type="mule">
    <extensionElements>
       <activiti:field name="endpointUrl">
         <activiti:string>vm://in</activiti:string>
       </activiti:field>
       <activiti:field name="language">
         <activiti:string>juel</activiti:string>
       </activiti:field>
       <activiti:field name="payloadExpression">
         <activiti:expression>${processVariable1}</activiti:expression>
       </activiti:field>
       <activiti:field name="resultVariable">
         <activiti:string>processVariable2</activiti:string>
       </activiti:field>
      </extensionElements>
    </serviceTask>

but The type can't be understanding by activti
the error is
cvc-attribute.3: The value 'mule' of attribute 'activiti:type' on element 'serviceTask' is not valid with respect to
its type, 'null'.

where is the problem of this synthax??

Re: Mule Integration

trademak — Wed, 11 Jan 2012 12:49:24 GMT

Hi,

That's because you should use a sendTask instead of a serviceTask.

Best regards,

Re: Mule Integration

mask87 — Wed, 11 Jan 2012 13:38:46 GMT

Hi,

I use both a sendTask and serviceTask and I have the same problem.

Re: Mule Integration

georgegao — Tue, 18 Mar 2014 06:10:22 GMT

hello,I am from China, About your configuration, I want to know
<bean id="_muleContext" factory-bean="muleFactory" factory-method="createMuleContext">
<constructor-arg type="java.lang.String" value="src/main/resources/application-context.xml"/>
</bean>

what the content about application-context.xml??

or can you give a complete example about activiti+mule?

I am not good at english, sorry!

Re: Mule Integration

pksahoo — Sun, 28 Jun 2015 00:40:15 GMT

Hi I got following error while integrate activiti 5.17 with Mule

any thought??

org.springframework.beans.factory.NoSuchBeanDefinitionException: No bean named 'muleContext' is defined
at org.springframework.beans.factory.support.DefaultListableBeanFactory.getBeanDefinition(DefaultListableBeanFactory.java:529)
at org.springframework.beans.factory.support.AbstractBeanFactory.getMergedLocalBeanDefinition(AbstractBeanFactory.java:1095)
at org.springframework.beans.factory.support.AbstractBeanFactory.doGetBean(AbstractBeanFactory.java:277)
at org.springframework.beans.factory.support.AbstractBeanFactory.getBean(AbstractBeanFactory.java:193)
at org.springframework.context.support.AbstractApplicationContext.getBean(AbstractApplicationContext.java:1093)
at org.activiti.engine.impl.cfg.SpringBeanFactoryProxyMap.get(SpringBeanFactoryProxyMap.java:39)
at org.activiti.mule.MuleSendActivitiBehavior.getMuleContext(MuleSendActivitiBehavior.java:138)
at org.activiti.mule.MuleSendActivitiBehavior.execute(MuleSendActivitiBehavior.java:71)
at org.activiti.engine.impl.pvm.runtime.AtomicOperationActivityExecute.execute(AtomicOperationActivityExecute.java:60)
at org.activiti.engine.impl.interceptor.CommandContext.performOperation(CommandContext.java:96)
at org.activiti.engine.impl.persistence.entity.ExecutionEntity.performOperationSync(ExecutionEntity.java:631)
at org.activiti.engine.impl.persistence.entity.ExecutionEntity.performOperation(ExecutionEntity.java:626)
at org.activiti.engine.impl.pvm.runtime.AtomicOperationTransitionNotifyListenerStart.eventNotificationsCompleted(AtomicOperationTransitionNotifyListenerStart.java:52)
at org.activiti.engine.impl.pvm.runtime.AbstractEventAtomicOperation.execute(AbstractEventAtomicOperation.java:56)
at org.activiti.engine.impl.interceptor.CommandContext.performOperation(CommandContext.java:96)
at org.activiti.engine.impl.persistence.entity.ExecutionEntity.performOperationSync(ExecutionEntity.java:631)
at org.activiti.engine.impl.persistence.entity.ExecutionEntity.performOperation(ExecutionEntity.java:626)
at org.activiti.engine.impl.pvm.runtime.AbstractEventAtomicOperation.execute(AbstractEventAtomicOperation.java:49)
at org.activiti.engine.impl.interceptor.CommandContext.performOperation(CommandContext.java:96)
at org.activiti.engine.impl.persistence.entity.ExecutionEntity.performOperationSync(ExecutionEntity.java:631)
at org.activiti.engine.impl.persistence.entity.ExecutionEntity.performOperation(ExecutionEntity.java:626)
at org.activiti.engine.impl.pvm.runtime.AtomicOperationTransitionCreateScope.execute(AtomicOperationTransitionCreateScope.java:49)
at org.activiti.engine.impl.interceptor.CommandContext.performOperation(CommandContext.java:96)
at org.activiti.engine.impl.persistence.entity.ExecutionEntity.performOperationSync(ExecutionEntity.java:631)
at org.activiti.engine.impl.persistence.entity.ExecutionEntity.performOperation(ExecutionEntity.java:626)
at org.activiti.engine.impl.pvm.runtime.AtomicOperationTransitionNotifyListenerTake.execute(AtomicOperationTransitionNotifyListenerTake.java:80)
at org.activiti.engine.impl.interceptor.CommandContext.performOperation(CommandContext.java:96)
at org.activiti.engine.impl.persistence.entity.ExecutionEntity.performOperationSync(ExecutionEntity.java:631)
at org.activiti.engine.impl.persistence.entity.ExecutionEntity.performOperation(ExecutionEntity.java:626)
at org.activiti.engine.impl.pvm.runtime.AtomicOperationTransitionDestroyScope.execute(AtomicOperationTransitionDestroyScope.java:116)
at org.activiti.engine.impl.interceptor.CommandContext.performOperation(CommandContext.java:96)
at org.activiti.engine.impl.persistence.entity.ExecutionEntity.performOperationSync(ExecutionEntity.java:631)
at org.activiti.engine.impl.persistence.entity.ExecutionEntity.performOperation(ExecutionEntity.java:626)
at org.activiti.engine.impl.pvm.runtime.AtomicOperationTransitionNotifyListenerEnd.eventNotificationsCompleted(AtomicOperationTransitionNotifyListenerEnd.java:35)
at org.activiti.engine.impl.pvm.runtime.AbstractEventAtomicOperation.execute(AbstractEventAtomicOperation.java:56)
at org.activiti.engine.impl.interceptor.CommandContext.performOperation(CommandContext.java:96)
at org.activiti.engine.impl.persistence.entity.ExecutionEntity.performOperationSync(ExecutionEntity.java:631)
at org.activiti.engine.impl.persistence.entity.ExecutionEntity.performOperation(ExecutionEntity.java:626)
at org.activiti.engine.impl.pvm.runtime.AbstractEventAtomicOperation.execute(AbstractEventAtomicOperation.java:49)
at org.activiti.engine.impl.interceptor.CommandContext.performOperation(CommandContext.java:96)
at org.activiti.engine.impl.persistence.entity.ExecutionEntity.performOperationSync(ExecutionEntity.java:631)
at org.activiti.engine.impl.persistence.entity.ExecutionEntity.performOperation(ExecutionEntity.java:626)
at org.activiti.engine.impl.persistence.entity.ExecutionEntity.take(ExecutionEntity.java:450)
at org.activiti.engine.impl.persistence.entity.ExecutionEntity.take(ExecutionEntity.java:428)
at org.activiti.engine.impl.bpmn.behavior.BpmnActivityBehavior.performOutgoingBehavior(BpmnActivityBehavior.java:140)
at org.activiti.engine.impl.bpmn.behavior.BpmnActivityBehavior.performDefaultOutgoingBehavior(BpmnActivityBehavior.java:66)
at org.activiti.engine.impl.bpmn.behavior.FlowNodeActivityBehavior.leave(FlowNodeActivityBehavior.java:44)
at org.activiti.engine.impl.bpmn.behavior.FlowNodeActivityBehavior.execute(FlowNodeActivityBehavior.java:36)
at org.activiti.engine.impl.pvm.runtime.AtomicOperationActivityExecute.execute(AtomicOperationActivityExecute.java:60)
at org.activiti.engine.impl.interceptor.CommandContext.performOperation(CommandContext.java:96)
at org.activiti.engine.impl.persistence.entity.ExecutionEntity.performOperationSync(ExecutionEntity.java:631)
at org.activiti.engine.impl.persistence.entity.ExecutionEntity.performOperation(ExecutionEntity.java:626)
at org.activiti.engine.impl.pvm.runtime.AtomicOperationProcessStartInitial.eventNotificationsCompleted(AtomicOperationProcessStartInitial.java:45)
at org.activiti.engine.impl.pvm.runtime.AbstractEventAtomicOperation.execute(AbstractEventAtomicOperation.java:56)
at org.activiti.engine.impl.interceptor.CommandContext.performOperation(CommandContext.java:96)
at org.activiti.engine.impl.persistence.entity.ExecutionEntity.performOperationSync(ExecutionEntity.java:631)
at org.activiti.engine.impl.persistence.entity.ExecutionEntity.performOperation(ExecutionEntity.java:626)
at org.activiti.engine.impl.pvm.runtime.AtomicOperationProcessStart.eventNotificationsCompleted(AtomicOperationProcessStart.java:62)
at org.activiti.engine.impl.pvm.runtime.AbstractEventAtomicOperation.execute(AbstractEventAtomicOperation.java:56)
at org.activiti.engine.impl.interceptor.CommandContext.performOperation(CommandContext.java:96)
at org.activiti.engine.impl.persistence.entity.ExecutionEntity.performOperationSync(ExecutionEntity.java:631)
at org.activiti.engine.impl.persistence.entity.ExecutionEntity.performOperation(ExecutionEntity.java:626)
at org.activiti.engine.impl.persistence.entity.ExecutionEntity.start(ExecutionEntity.java:378)
at org.activiti.engine.impl.cmd.StartProcessInstanceCmd.execute(StartProcessInstanceCmd.java:111)
at org.activiti.engine.impl.cmd.StartProcessInstanceCmd.execute(StartProcessInstanceCmd.java:37)
at org.activiti.engine.impl.interceptor.CommandInvoker.execute(CommandInvoker.java:24)
at org.activiti.engine.impl.interceptor.CommandContextInterceptor.execute(CommandContextInterceptor.java:57)
at org.activiti.spring.SpringTransactionInterceptor$1.doInTransaction(SpringTransactionInterceptor.java:47)
at org.springframework.transaction.support.TransactionTemplate.execute(TransactionTemplate.java:130)
at org.activiti.spring.SpringTransactionInterceptor.execute(SpringTransactionInterceptor.java:45)
at org.activiti.engine.impl.interceptor.LogInterceptor.execute(LogInterceptor.java:31)
at org.activiti.engine.impl.cfg.CommandExecutorImpl.execute(CommandExecutorImpl.java:40)
at org.activiti.engine.impl.cfg.CommandExecutorImpl.execute(CommandExecutorImpl.java:35)
at org.activiti.engine.impl.RuntimeServiceImpl.startProcessInstanceByKey(RuntimeServiceImpl.java:81)
at com.bofa.cps.bpm.util.BPMUtil.startProcessInstance(BPMUtil.java:62)
at test.CPSFileProcessTest.testStartMuleProcessInstance(CPSFileProcessTest.java:39)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:60)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:37)
at java.lang.reflect.Method.invoke(Method.java:611)
at org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:44)
at org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:15)
at org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:41)
at org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:20)
at org.junit.internal.runners.statements.RunBefores.evaluate(RunBefores.java:28)
at org.junit.runners.BlockJUnit4ClassRunner.runNotIgnored(BlockJUnit4ClassRunner.java:79)
at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:71)
at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:49)
at org.junit.runners.ParentRunner$3.run(ParentRunner.java:193)
at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:52)
at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:191)
at org.junit.runners.ParentRunner.access$000(ParentRunner.java:42)
at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:184)
at org.junit.runners.ParentRunner.run(ParentRunner.java:236)
at org.eclipse.jdt.internal.junit4.runner.JUnit4TestReference.run(JUnit4TestReference.java:50)
at org.eclipse.jdt.internal.junit.runner.TestExecution.run(TestExecution.java:38)
at org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.runTests(RemoteTestRunner.java:459)
at org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.runTests(RemoteTestRunner.java:675)
at org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.run(RemoteTestRunner.java:382)
at org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.main(RemoteTestRunner.java:192)