cloudevents-multi + quarkus-events-smallrye

313 views
Skip to first unread message

Mark Jayson Gonzaga

unread,
Jul 20, 2021, 12:00:09 PM7/20/21
to kogito-de...@googlegroups.com
Hi Team,

Wondering If anyone has tried the below.
<dependency>
<groupId>org.kie.kogito</groupId>
<artifactId>kogito-addons-quarkus-cloudevents-multi</artifactId>
</dependency>
<dependency>
<groupId>org.kie.kogito</groupId>
<artifactId>kogito-addons-quarkus-events-smallrye</artifactId>
</dependency>
In my end. It is throwing this exception.
2021-07-20 23:58:56,360 ERROR [io.qua.run.Application] (Quarkus Main Thread) Failed to start application (with profile dev): javax.enterprise.inject.spi.DefinitionException: SRMSG00019: Unable to connect an emitter with the channel `kogito-processinstances-events`
at io.smallrye.reactive.messaging.extension.ChannelProducer.getEmitter(ChannelProducer.java:179)
at io.smallrye.reactive.messaging.extension.ChannelProducer.produceEmitter(ChannelProducer.java:124)
at io.smallrye.reactive.messaging.extension.ChannelProducer_Subclass.produceEmitter$$superforward1(ChannelProducer_Subclass.zig:565)
at io.smallrye.reactive.messaging.extension.ChannelProducer_Subclass$$function$$10.apply(ChannelProducer_Subclass$$function$$10.zig:33)


However, When using just the cloudevents (w/o the multi)
.<dependency>
  <groupId>org.kie.kogito</groupId>
<artifactId>kogito-addons-quarkus-cloudevents</artifactId>
</dependency>
It seems to work.

I can only use the cloudevents-multi addons because I have several incoming and outgoing.

Is this kind of the limitation of the cloudevent-multi addon? That I can't use the events-smallrye together with it?



Francisco Javier Tirado Sarti

unread,
Jul 22, 2021, 5:17:38 AM7/22/21
to Kogito development mailing list

Hi Mark,

It should be working, but somehow it not. Working in a fix.

Mark Jayson Gonzaga

unread,
Jul 22, 2021, 5:53:08 AM7/22/21
to kogito-de...@googlegroups.com
Hi thanks for the response. Will wait for that

--
You received this message because you are subscribed to the Google Groups "Kogito development mailing list" group.
To unsubscribe from this group and stop receiving emails from it, send an email to kogito-developm...@googlegroups.com.
To view this discussion on the web visit https://groups.google.com/d/msgid/kogito-development/4ebf5012-6a1c-453e-a87d-d2ed3002a8den%40googlegroups.com.

Francisco Javier Tirado Sarti

unread,
Jul 22, 2021, 12:47:37 PM7/22/21
to Kogito development mailing list

Francisco Javier Tirado Sarti

unread,
Jul 26, 2021, 9:56:53 AM7/26/21
to Kogito development mailing list
Mi Mark, Fix available in main branch. Please try and let us know.

Mark Jayson Gonzaga

unread,
Jul 26, 2021, 9:59:37 AM7/26/21
to kogito-de...@googlegroups.com
Hi Francisco,

Will do.. thanks

Mark Jayson Gonzaga

unread,
Jul 26, 2021, 10:07:53 AM7/26/21
to kogito-de...@googlegroups.com
Hi Francisco,

Is the below valid?
<dependencies>
<dependency>
<groupId>io.quarkus</groupId>
<artifactId>quarkus-smallrye-reactive-messaging-amqp</artifactId>
  </dependency>
<dependency>
<groupId>org.kie.kogito</groupId>
<artifactId>kogito-addons-quarkus-cloudevents-multi</artifactId>
</dependency>
<dependency>
<groupId>org.kie.kogito</groupId>
    <artifactId>kogito-quarkus</artifactId>
</dependency>
<dependency>
<groupId>io.quarkus</groupId>
<artifactId>quarkus-smallrye-openapi</artifactId>
  </dependency>
<dependency>
<groupId>org.kie.kogito</groupId>
    <artifactId>kogito-api</artifactId>
  </dependency>
<dependency>
<groupId>org.kie.kogito</groupId>
<artifactId>kogito-addons-quarkus-events-smallrye</artifactId>
</dependency>
  <dependency>
<groupId>org.projectlombok</groupId>
<artifactId>lombok</artifactId>
<version>1.18.20</version>
<scope>provided</scope>
</dependency>
and 

mp.messaging.outgoing.kogito-processinstances-events.connector=smallrye-amqp
mp.messaging.outgoing.kogito-processinstances-events.address=kogito-processinstances-events

mp.messaging.outgoing.kogito-usertaskinstances-events.connector=smallrye-amqp
mp.messaging.outgoing.kogito-usertaskinstances-events.address=kogito-usertaskinstances-events

mp.messaging.outgoing.kogito-variables-events.connector=smallrye-amqp
mp.messaging.outgoing.kogito-variables-events.address=kogito-variables-events
but still getting
Failed to start application (with profile dev): javax.enterprise.inject.spi.DefinitionException: SRMSG00019: Unable to connect an emitter with the channel `kogito-processinstances-events`
at io.smallrye.reactive.messaging.extension.ChannelProducer.getEmitter(ChannelProducer.java:179)
at io.smallrye.reactive.messaging.extension.ChannelProducer.produceEmitter(ChannelProducer.java:124)

Message has been deleted

Francisco Javier Tirado Sarti

unread,
Jul 27, 2021, 7:03:05 AM7/27/21
to Kogito development mailing list
Hi Mark,
Yes, it is valid configuration
This example https://github.com/kiegroup/kogito-examples/blob/main/process-kafka-multi-quarkus/pom.xml#L25-L32 is using the same combination you have in your pom.xml. It failed before the latest changes, so I think you are not using last version from main branch.
Please notice the fix is not part of any develiverd release yet, it was merged to main branch in repo yesterday. You need to checkout it from the repo in order to test with your example.

Mark Jayson Gonzaga

unread,
Jul 27, 2021, 11:08:50 AM7/27/21
to kogito-de...@googlegroups.com
I see, Exactly what I thought, Do we have like a plan release date on this?

Francisco Javier Tirado Sarti

unread,
Jul 29, 2021, 8:49:11 AM7/29/21
to Kogito development mailing list
Hi Mark,
Since the PR that fix this is already merged in main branch, it should be there in next release, which delivery date should around 1-2 weeks since release cutoff (which will happen end of this week)

Mark Jayson Gonzaga

unread,
Aug 1, 2021, 6:29:35 AM8/1/21
to kogito-de...@googlegroups.com
Thanks, It works, will just wait for the official release :) 

Mark Jayson Gonzaga

unread,
Aug 2, 2021, 4:34:28 AM8/2/21
to kogito-de...@googlegroups.com
Hi Francisco,

I tried using the latest 1.9.0 Kogito version but The error is still there, Could you please help confirm if the fix has been released on that version? or do we have a separate release for the fix?

Ricardo Zanini

unread,
Aug 30, 2021, 9:41:50 AM8/30/21
to Kogito development mailing list
Hi Mark! Can you try with 1.10.0?

--
Zanini


Mark Jayson Gonzaga

unread,
Aug 31, 2021, 9:00:45 AM8/31/21
to kogito-de...@googlegroups.com
Reply all
Reply to author
Forward
0 new messages