You are viewing a plain text version of this content. The canonical link for it is here.
Posted to users@camel.apache.org by Łukasz Dywicki <lu...@code-house.org> on 2012/01/11 00:36:49 UTC

More complicated scenario for camel-bam

Hey everyone,
I tried yo use camel-bam and it works for very basic example shown in documentation. It works well for correlating the files without any middle processing steps.

The process I try to monitor looks following

- receive incoming JMS message - split - multicast (queue1, queue2)

So I've build a following configuration for the process:
ValueBuilder correlation = header("JMSCorrelationID");
ActivityBuilder incoming = activity("activemq:incoming").correlate(correlation).name("incoming");

ActivityBuilder sys1 = activity("amq2:queue1").correlate(correlation).name("system1");
ActivityBuilder sys2 = activity("amq2:queue2").correlate(correlation).name("system2");

sys1.starts().after(incoming.starts());
sys2.starts().after(incoming.starts());

But after receiving messages and initializing a process instance nothing happens. Er it happens, the activity is created. I can not reuse a incoming.getEndpoint to create an from statement and process message. Multiple consumers on same destination are not allowed.

Issues I've discovered:
- Lack of support for parallel activities.
- No support for processing received message. Usually a incoming message is only a entry point for a process.
- No support for a custom process names. Not everyone are happy with Proces-N name. A ProcessBuilder extensions can't change a naming schema.
- Activity definition is not put into the database as long as it is not called by flow. Process is created and the activities are known, but they're not persisted before processing. So whole definitions are useless if we would like display process definitions somewhere else.
- Hard coded dependency to JPA, can't be replaced by alternative way of storing process definitions eg like in IdempotentRepository.

These issues makes a camel-bam useless in my case. Should I use an alternative tool like activiti-camel integration? It's fine but I don't need whole BPMN, diagraming. I want to track a flow between systems in an easy way, there is no human tasks, only service calls and camel logic.

Łukasz Dywicki
--
Code-House
Krasiczyńska 3/80
03-379 Warszawa

Re: More complicated scenario for camel-bam

Posted by Łukasz Dywicki <lu...@code-house.org>.
Time is the best teacher. :)

I've found a way to do a processing message after activity receives it - with interceptors. There some exceptions, but both persistence and processing works.

Solutions looks next:
interceptFrom("activemq:incoming")
    .split(body())
        .multicast()
            .to(sys1.getEndpoint())
            .to(sys2.getEndpoint())
        .end()
     .end();


Łukasz Dywicki
--
Code-House
http://code-house.org



Wiadomość napisana przez Łukasz Dywicki w dniu 2012-01-11, o godz. 11:48:

> Hey Hadrian,
> I started investigating the camel-bam code and one from statements I wrote is not true. The Process name can be set by calling the ProcessBuilder constructor. The Process-N name is a default behaviour.
> 
> Also, if it makes a sense to support delaying the activity? Eg making an activity suspended? I don't see use of it in my case so far, but that's might be required by other processes.
> 
> Łukasz Dywicki
> --
> Code-House
> http://code-house.org
> 
> 
> Wiadomość napisana przez Hadrian Zbarcea w dniu 2012-01-11, o godz. 03:29:
> 
>> Lukasz, do you mind opening a jira with your findings?
>> Thanks, Hadrian
>> 
>> On 01/10/2012 06:36 PM, Łukasz Dywicki wrote:
>>> Hey everyone,
>>> I tried yo use camel-bam and it works for very basic example shown in documentation. It works well for correlating the files without any middle processing steps.
>>> 
>>> The process I try to monitor looks following
>>> 
>>> - receive incoming JMS message - split - multicast (queue1, queue2)
>>> 
>>> So I've build a following configuration for the process:
>>> ValueBuilder correlation = header("JMSCorrelationID");
>>> ActivityBuilder incoming = activity("activemq:incoming").correlate(correlation).name("incoming");
>>> 
>>> ActivityBuilder sys1 = activity("amq2:queue1").correlate(correlation).name("system1");
>>> ActivityBuilder sys2 = activity("amq2:queue2").correlate(correlation).name("system2");
>>> 
>>> sys1.starts().after(incoming.starts());
>>> sys2.starts().after(incoming.starts());
>>> 
>>> But after receiving messages and initializing a process instance nothing happens. Er it happens, the activity is created. I can not reuse a incoming.getEndpoint to create an from statement and process message. Multiple consumers on same destination are not allowed.
>>> 
>>> Issues I've discovered:
>>> - Lack of support for parallel activities.
>>> - No support for processing received message. Usually a incoming message is only a entry point for a process.
>>> - No support for a custom process names. Not everyone are happy with Proces-N name. A ProcessBuilder extensions can't change a naming schema.
>>> - Activity definition is not put into the database as long as it is not called by flow. Process is created and the activities are known, but they're not persisted before processing. So whole definitions are useless if we would like display process definitions somewhere else.
>>> - Hard coded dependency to JPA, can't be replaced by alternative way of storing process definitions eg like in IdempotentRepository.
>>> 
>>> These issues makes a camel-bam useless in my case. Should I use an alternative tool like activiti-camel integration? It's fine but I don't need whole BPMN, diagraming. I want to track a flow between systems in an easy way, there is no human tasks, only service calls and camel logic.
>>> 
>>> Łukasz Dywicki
>>> --
>>> Code-House
>>> Krasiczyńska 3/80
>>> 03-379 Warszawa
>>> 
>>> 
>>> 
>> 
>> -- 
>> Hadrian Zbarcea
>> Principal Software Architect
>> Talend, Inc
>> http://coders.talend.com/
>> http://camelbot.blogspot.com/
>

Re: More complicated scenario for camel-bam

Posted by Łukasz Dywicki <lu...@code-house.org>.
Hey Hadrian,
I started investigating the camel-bam code and one from statements I wrote is not true. The Process name can be set by calling the ProcessBuilder constructor. The Process-N name is a default behaviour.

Also, if it makes a sense to support delaying the activity? Eg making an activity suspended? I don't see use of it in my case so far, but that's might be required by other processes.

Łukasz Dywicki
--
Code-House
http://code-house.org


Wiadomość napisana przez Hadrian Zbarcea w dniu 2012-01-11, o godz. 03:29:

> Lukasz, do you mind opening a jira with your findings?
> Thanks, Hadrian
> 
> On 01/10/2012 06:36 PM, Łukasz Dywicki wrote:
>> Hey everyone,
>> I tried yo use camel-bam and it works for very basic example shown in documentation. It works well for correlating the files without any middle processing steps.
>> 
>> The process I try to monitor looks following
>> 
>> - receive incoming JMS message - split - multicast (queue1, queue2)
>> 
>> So I've build a following configuration for the process:
>> ValueBuilder correlation = header("JMSCorrelationID");
>> ActivityBuilder incoming = activity("activemq:incoming").correlate(correlation).name("incoming");
>> 
>> ActivityBuilder sys1 = activity("amq2:queue1").correlate(correlation).name("system1");
>> ActivityBuilder sys2 = activity("amq2:queue2").correlate(correlation).name("system2");
>> 
>> sys1.starts().after(incoming.starts());
>> sys2.starts().after(incoming.starts());
>> 
>> But after receiving messages and initializing a process instance nothing happens. Er it happens, the activity is created. I can not reuse a incoming.getEndpoint to create an from statement and process message. Multiple consumers on same destination are not allowed.
>> 
>> Issues I've discovered:
>> - Lack of support for parallel activities.
>> - No support for processing received message. Usually a incoming message is only a entry point for a process.
>> - No support for a custom process names. Not everyone are happy with Proces-N name. A ProcessBuilder extensions can't change a naming schema.
>> - Activity definition is not put into the database as long as it is not called by flow. Process is created and the activities are known, but they're not persisted before processing. So whole definitions are useless if we would like display process definitions somewhere else.
>> - Hard coded dependency to JPA, can't be replaced by alternative way of storing process definitions eg like in IdempotentRepository.
>> 
>> These issues makes a camel-bam useless in my case. Should I use an alternative tool like activiti-camel integration? It's fine but I don't need whole BPMN, diagraming. I want to track a flow between systems in an easy way, there is no human tasks, only service calls and camel logic.
>> 
>> Łukasz Dywicki
>> --
>> Code-House
>> Krasiczyńska 3/80
>> 03-379 Warszawa
>> 
>> 
>> 
> 
> -- 
> Hadrian Zbarcea
> Principal Software Architect
> Talend, Inc
> http://coders.talend.com/
> http://camelbot.blogspot.com/

Re: More complicated scenario for camel-bam

Posted by Hadrian Zbarcea <hz...@gmail.com>.
Lukasz, do you mind opening a jira with your findings?
Thanks, Hadrian

On 01/10/2012 06:36 PM, Łukasz Dywicki wrote:
> Hey everyone,
> I tried yo use camel-bam and it works for very basic example shown in documentation. It works well for correlating the files without any middle processing steps.
>
> The process I try to monitor looks following
>
> - receive incoming JMS message - split - multicast (queue1, queue2)
>
> So I've build a following configuration for the process:
> ValueBuilder correlation = header("JMSCorrelationID");
> ActivityBuilder incoming = activity("activemq:incoming").correlate(correlation).name("incoming");
>
> ActivityBuilder sys1 = activity("amq2:queue1").correlate(correlation).name("system1");
> ActivityBuilder sys2 = activity("amq2:queue2").correlate(correlation).name("system2");
>
> sys1.starts().after(incoming.starts());
> sys2.starts().after(incoming.starts());
>
> But after receiving messages and initializing a process instance nothing happens. Er it happens, the activity is created. I can not reuse a incoming.getEndpoint to create an from statement and process message. Multiple consumers on same destination are not allowed.
>
> Issues I've discovered:
> - Lack of support for parallel activities.
> - No support for processing received message. Usually a incoming message is only a entry point for a process.
> - No support for a custom process names. Not everyone are happy with Proces-N name. A ProcessBuilder extensions can't change a naming schema.
> - Activity definition is not put into the database as long as it is not called by flow. Process is created and the activities are known, but they're not persisted before processing. So whole definitions are useless if we would like display process definitions somewhere else.
> - Hard coded dependency to JPA, can't be replaced by alternative way of storing process definitions eg like in IdempotentRepository.
>
> These issues makes a camel-bam useless in my case. Should I use an alternative tool like activiti-camel integration? It's fine but I don't need whole BPMN, diagraming. I want to track a flow between systems in an easy way, there is no human tasks, only service calls and camel logic.
>
> Łukasz Dywicki
> --
> Code-House
> Krasiczyńska 3/80
> 03-379 Warszawa
>
>
>

-- 
Hadrian Zbarcea
Principal Software Architect
Talend, Inc
http://coders.talend.com/
http://camelbot.blogspot.com/