Funq not sending CloudEvent / CloudEvent not received by broker

[gabriel-farache]

Describe the bug

I have a pod that is triggering the execution of the knative function I created using FunQ and then it waits until it receives an event. This event is sent by the knative function.

The pod is stateful, so if it gets deleted once it's running again it will resume waiting for the event.

But when the pod is restarted, it never receives any event from the knative function despite the fact that the function sent it, and the pod was ready to receive it.
When I send the event manually using curl, the pod is receiving the event and continuing its execution.

If I do not delete the pod, everything works fine, the issue only appears when the pod is deleted/restarted.

I failed to gather any log related to the firing of the event from the knative function.

Same for the knative-eventing resources (ingress,...) I see nothing in the logs so I am even wondering if the cloudevent is sent to the broker or to the pod directly...

I am using an in-memory broker.

Expected behavior

The restarted pod should receive the event from the broker.

Actual behavior

No event seems to be received by the in-memory broker when the origin pod is restarted.

How to Reproduce?

No response

Output of uname -a or ver

No response

Output of java -version

No response

Quarkus version or git rev

No response

Build tool (ie. output of mvnw --version or gradlew --version)

No response

Additional information

No response

[quarkus-bot]

/cc @geoand (knative), @iocanel (knative)

[geoand]

cc @patriot1burke