Event registry - HTTP

Flowable Engine
1

I already implemented event registry for Kafka - which works perfectly.

According to this blog, there is a also a possibility to receive events through HTTP.
https://blog.flowable.org/2020/02/08/introducing-the-flowable-event-registry/

However, I don’t see example how to implement this.

Is there any tutorial/examples?

Cheers,

2

This is the endpoint you’re looking for: flowable-engine/EventInstanceCollectionResource.java at master · flowable/flowable-engine · GitHub

3

Hi @mykeul , as you said, you have already implemented event registry for Kafka and its working. Could you please guide me how can I implement it and how can I verify in my code when the message is received from kafka topic.

@joram , I am using Micronaut framework, is there any implementation available with this framework for receiving kafka topic message.

4

Hi Harish,

There are several examples on how to implement event registry for Kafka.
For my part, I used this one:
https://blog.flowable.org/2020/02/08/introducing-the-flowable-event-registry/

Hope it helps.

Michel

5

Thanks @mykeul , it worked for spring boot and now trying with micronaut.

6

Hi @joram, I am trying to implement same in Micronaut and its not working. I do not get any error but the control is not coming to my delegate. Although , I am able to do the same with spring boot. Below are the configurations I have added:

 implementation 'io.micronaut.kafka:micronaut-kafka:3.3.3'
    implementation "org.flowable:flowable-engine:6.6.0"

My Bean:

@Bean
    @Singleton
    public ProcessEngine processEngine() {

        ProcessEngineConfiguration cfg = ProcessEngineConfiguration.createStandaloneProcessEngineConfiguration()
                .setJdbcUrl("dbUrl")
                .setJdbcUsername("username")
                .setJdbcPassword("password")
                .setJdbcDriver("driver class name")
                .setAsyncExecutorActivate(true)                .setDatabaseSchemaUpdate(AbstractEngineConfiguration.DB_SCHEMA_UPDATE_TRUE);

        List<VariableType> customTypes = new ArrayList<>();
        ((StandaloneProcessEngineConfiguration) cfg).setCustomPreVariableTypes(customTypes);

        ProcessEngine processEngine = cfg.buildProcessEngine();

         processEngine.getRepositoryService().createDeployment()
                    .addClasspathResource("test.bpmn20.xml")
                    .addClasspathResource("eventregistry/event-idvCompleteEvent.event")
                    .addClasspathResource("eventregistry/channel-idvCompleteChannel.channel")
                    .deploy();

        return processEngine;
    }

My delegate:

public class MyDelegate implements JavaDelegate {

    @Override
    public void execute(DelegateExecution execution) {

        String field = execution.getVariable("fieldNamePassingFromKafkaTopicMessage", String.class);
    }
}

Could you please suggest me what’s wrong in my implementation or any dependency that I am missing ?

Thanks
Harish

7

Hey @harish,

There is no need to ping anyone and you already asked this question in a different topic (Flowable with kafka). I’ve already provided you with an answer.

Please be patient and do not cross post questions.

Cheers,
Filip

8

Thanks Joram.
Is there a sample on how to implement it?
I would like to have a process that has a blocking event waiting for an external rest (endpoint defined in Flowable).
Once the rest is called/received, the process instance continues
Does it fit our requirements or is there another construct?
Thanks,