How to configure fetchAndLock long poll? (asyncResponseTimeout has no effect) #353

datakurre · 2021-11-28T14:18:22Z

I have followed README to configure a Micronaut Camunda application with jetty because of webapps support.

Unfortunately, asyncResponseTimeout for REST API external-task/fetchAndLock seem to have no effect. Response is always instantly returned:

$ curl -X POST http://localhost:8080/engine-rest/external-task/fetchAndLock -H "Content-Type: application/json" -d'{"maxTasks": 1, "workerId": "aWorkerId", "asyncResponseTimeout": 2000, "topics": [{"topicName": "aTopicName", "lockDuration": 3000}]}'

The same command works as expected with the default Camunda Docker images.

The text was updated successfully, but these errors were encountered:

datakurre · 2021-11-28T17:54:57Z

The project seems to depend on org.camunda.bpm:camunda-engine-rest

https://github.com/camunda-community-hub/micronaut-camunda-bpm/blob/910c0badab9c710d22d1504bf3b15fec294a0e47/micronaut-camunda-bpm-feature/build.gradle#L47

when asyncResponseTimeout is feature of

org.camunda.bpm:camunda-engine-rest-jax2rs

datakurre · 2021-11-28T17:57:56Z

camunda/camunda-bpm-spring-boot-starter@79e862d#diff-572d41f4162cfe2c52d3ca94a817349a3e55e436504331946c56e1a5e8c31d00

tobiasschaefer · 2021-11-28T18:29:56Z

Hi @datakurre ,

thanks for reporting this issue and giving us those hints.

There is a small typo in the dependency you mentioned. Correct is implementation("org.camunda.bpm:camunda-engine-rest-jaxrs2:$camundaVersion") (2 at the end)

I tried replacing the dependency but then it fails with

{"type":"NullPointerException","message":"Cannot invoke \"org.camunda.bpm.engine.rest.spi.FetchAndLockHandler.addPendingRequest(org.camunda.bpm.engine.rest.dto.externaltask.FetchExternalTasksExtendedDto, javax.ws.rs.container.AsyncResponse, org.camunda.bpm.engine.ProcessEngine)\" because \"fetchAndLockHandler\" is null"}

Your're welcome to create a PR (see CONTRIBUTING.md) - otherwise @arolfes and I will have a closer look.

Note: this is the issue of the Spring Boot Starter Project which switched the mentioned dependencies: https://jira.camunda.com/browse/CAM-8799

datakurre · 2021-11-28T19:44:17Z

@tobiasschaefer Thanks for confirming the issue!

Unfortunately, I was unable to solve

{"type":"NullPointerException","message":"Cannot invoke \"org.camunda.bpm.engine.rest.spi.FetchAndLockHandler.addPendingRequest(org.camunda.bpm.engine.rest.dto.externaltask.FetchExternalTasksExtendedDto, javax.ws.rs.container.AsyncResponse, org.camunda.bpm.engine.ProcessEngine)\" because \"fetchAndLockHandler\" is null"}

Some pointers, though...

The exception is raised from

https://github.com/camunda/camunda-bpm-platform/blob/64e60eb7222b58c67104a0912b1d9d4185e2cc1b/engine-rest/engine-rest-jaxrs2/src/main/java/org/camunda/bpm/engine/rest/impl/FetchAndLockRestServiceImpl.java#L38

The missing handler should have been set at

https://github.com/camunda/camunda-bpm-platform/blob/64e60eb7222b58c67104a0912b1d9d4185e2cc1b/engine-rest/engine-rest-jaxrs2/src/main/java/org/camunda/bpm/engine/rest/impl/FetchAndLockContextListener.java#L38

Which was one called at

https://github.com/arolfes/micronaut-camunda-bpm/blob/98eb4d476b0cad48fb208022775e5c5cfb2e7527/example-external-task-process/src/main/java/info/novatec/micronaut/camunda/externaltask/process/FetchAndLockContextFactory.java#L35

but I am not sure, how should it work now.

…itializing the REST api so that long polling works, i.e. the if there are currently no tasks then the server will keep the connection open for the given time.

datakurre · 2021-11-29T17:35:42Z

🎉❤️

tobiasschaefer · 2021-11-29T18:13:13Z

Hi @datakurre ,

we've published release v2.3.1 which fixes the bug you reported.

Please confirm that your issue has been resolved (and thanks for reporting it).

datakurre · 2021-11-29T20:33:48Z

@tobiasschaefer Unfortunately, I was unable to confirm the fix yet 😳

I am new to micronaut, but I assume that updating pom.xml should be enough

     <dependency>
       <groupId>info.novatec</groupId>
       <artifactId>micronaut-camunda-bpm-feature</artifactId>
-      <version>2.3.0</version>
+      <version>2.3.1</version>
       <scope>compile</scope>
     </dependency>
     <dependency>

And after shutting down, I now get the following stacktrace:

22:29:54.891 [Thread-10] INFO  org.camunda.bpm.engine.jobexecutor - ENGINE-14015 Shutting down the JobExecutor[info.novatec.micronaut.camunda.bpm.feature.MnJobExecutor]
22:29:54.892 [JobExecutor[info.novatec.micronaut.camunda.bpm.feature.MnJobExecutor]] INFO  org.camunda.bpm.engine.jobexecutor - ENGINE-14020 JobExecutor[info.novatec.micronaut.camunda.bpm.feature.MnJobExecutor] stopped job acquisition
22:29:54.900 [Thread-10] INFO  org.camunda.bpm.engine - ENGINE-00007 Process Engine default closed
22:29:54.982 [Thread-10] INFO  com.zaxxer.hikari.HikariDataSource - HikariPool-1 - Shutdown initiated...
22:29:55.018 [Thread-10] INFO  com.zaxxer.hikari.HikariDataSource - HikariPool-1 - Shutdown completed.
22:29:55.121 [Thread-10] INFO  o.e.j.server.handler.ContextHandler - Stopped i.m.s.j.@411341bd{/,null,STOPPED}
Exception in thread "Thread-10" io.micronaut.http.server.exceptions.HttpServerException: Error stopping HTTP server: Multiple exceptions
        at io.micronaut.servlet.engine.server.AbstractServletServer.stop(AbstractServletServer.java:109)
        at io.micronaut.servlet.engine.server.AbstractServletServer.stop(AbstractServletServer.java:34)
        at io.micronaut.runtime.Micronaut.lambda$null$0(Micronaut.java:115)
        at java.base/java.lang.Thread.run(Thread.java:833)
Caused by: MultiException[java.lang.AbstractMethodError: Receiver class info.novatec.micronaut.camunda.bpm.feature.JettyServerCustomizer$ServletContextInitializedListener does not define or inherit an implementation of the resolved method 'abstract void contextDestroyed(javax.servlet.ServletContextEvent)' of interface javax.servlet.ServletContextListener., java.lang.AbstractMethodError: Receiver class info.novatec.micronaut.camunda.bpm.feature.JettyServerCustomizer$1 does not define or inherit an implementation of the resolved method 'abstract void contextDestroyed(javax.servlet.ServletContextEvent)' of interface javax.servlet.ServletContextListener.]
        at org.eclipse.jetty.util.MultiException.ifExceptionThrow(MultiException.java:122)
        at org.eclipse.jetty.server.Server.doStop(Server.java:484)
        at org.eclipse.jetty.util.component.AbstractLifeCycle.stop(AbstractLifeCycle.java:94)
        at io.micronaut.servlet.jetty.JettyServer.stopServer(JettyServer.java:59)
        at io.micronaut.servlet.engine.server.AbstractServletServer.stop(AbstractServletServer.java:102)
        ... 3 more
        Suppressed: java.lang.AbstractMethodError: Receiver class info.novatec.micronaut.camunda.bpm.feature.JettyServerCustomizer$ServletContextInitializedListener does not define or inherit an implementation of the resolved method 'abstract void contextDestroyed(javax.servlet.ServletContextEvent)' of interface javax.servlet.ServletContextListener.
                at org.eclipse.jetty.server.handler.ContextHandler.callContextDestroyed(ContextHandler.java:1074)
                at org.eclipse.jetty.servlet.ServletContextHandler.callContextDestroyed(ServletContextHandler.java:584)
                at org.eclipse.jetty.server.handler.ContextHandler.contextDestroyed(ContextHandler.java:1037)
                at org.eclipse.jetty.servlet.ServletHandler.doStop(ServletHandler.java:319)
                at org.eclipse.jetty.util.component.AbstractLifeCycle.stop(AbstractLifeCycle.java:94)
                at org.eclipse.jetty.util.component.ContainerLifeCycle.stop(ContainerLifeCycle.java:180)
                at org.eclipse.jetty.util.component.ContainerLifeCycle.doStop(ContainerLifeCycle.java:201)
                at org.eclipse.jetty.server.handler.AbstractHandler.doStop(AbstractHandler.java:108)
                at org.eclipse.jetty.server.session.SessionHandler.doStop(SessionHandler.java:520)
                at org.eclipse.jetty.util.component.AbstractLifeCycle.stop(AbstractLifeCycle.java:94)
                at org.eclipse.jetty.util.component.ContainerLifeCycle.stop(ContainerLifeCycle.java:180)
                at org.eclipse.jetty.util.component.ContainerLifeCycle.doStop(ContainerLifeCycle.java:201)
                at org.eclipse.jetty.server.handler.AbstractHandler.doStop(AbstractHandler.java:108)
                at org.eclipse.jetty.server.handler.ContextHandler.stopContext(ContextHandler.java:1060)
                at org.eclipse.jetty.servlet.ServletContextHandler.stopContext(ServletContextHandler.java:386)
                at org.eclipse.jetty.server.handler.ContextHandler.doStop(ContextHandler.java:1114)
                at org.eclipse.jetty.servlet.ServletContextHandler.doStop(ServletContextHandler.java:297)
                at org.eclipse.jetty.util.component.AbstractLifeCycle.stop(AbstractLifeCycle.java:94)
                at org.eclipse.jetty.util.component.ContainerLifeCycle.stop(ContainerLifeCycle.java:180)
                at org.eclipse.jetty.util.component.ContainerLifeCycle.doStop(ContainerLifeCycle.java:201)
                at org.eclipse.jetty.server.handler.AbstractHandler.doStop(AbstractHandler.java:108)
                at org.eclipse.jetty.util.component.AbstractLifeCycle.stop(AbstractLifeCycle.java:94)
                at org.eclipse.jetty.util.component.ContainerLifeCycle.stop(ContainerLifeCycle.java:180)
                at org.eclipse.jetty.util.component.ContainerLifeCycle.doStop(ContainerLifeCycle.java:201)
                at org.eclipse.jetty.server.handler.AbstractHandler.doStop(AbstractHandler.java:108)
                at org.eclipse.jetty.server.Server.doStop(Server.java:470)
                ... 6 more
        Suppressed: java.lang.AbstractMethodError: Receiver class info.novatec.micronaut.camunda.bpm.feature.JettyServerCustomizer$1 does not define or inherit an implementation of the resolved method 'abstract void contextDestroyed(javax.servlet.ServletContextEvent)' of interface javax.servlet.ServletContextListener.
                at org.eclipse.jetty.server.handler.ContextHandler.callContextDestroyed(ContextHandler.java:1074)
                at org.eclipse.jetty.servlet.ServletContextHandler.callContextDestroyed(ServletContextHandler.java:584)
                at org.eclipse.jetty.server.handler.ContextHandler.contextDestroyed(ContextHandler.java:1037)
                at org.eclipse.jetty.servlet.ServletHandler.doStop(ServletHandler.java:319)
                at org.eclipse.jetty.util.component.AbstractLifeCycle.stop(AbstractLifeCycle.java:94)
                at org.eclipse.jetty.util.component.ContainerLifeCycle.stop(ContainerLifeCycle.java:180)
                at org.eclipse.jetty.util.component.ContainerLifeCycle.doStop(ContainerLifeCycle.java:201)
                at org.eclipse.jetty.server.handler.AbstractHandler.doStop(AbstractHandler.java:108)
                at org.eclipse.jetty.server.handler.ContextHandler.stopContext(ContextHandler.java:1060)
                at org.eclipse.jetty.servlet.ServletContextHandler.stopContext(ServletContextHandler.java:386)
                at org.eclipse.jetty.server.handler.ContextHandler.doStop(ContextHandler.java:1114)
                at org.eclipse.jetty.servlet.ServletContextHandler.doStop(ServletContextHandler.java:297)
                at org.eclipse.jetty.util.component.AbstractLifeCycle.stop(AbstractLifeCycle.java:94)
                at org.eclipse.jetty.util.component.ContainerLifeCycle.stop(ContainerLifeCycle.java:180)
                at org.eclipse.jetty.util.component.ContainerLifeCycle.doStop(ContainerLifeCycle.java:201)
                at org.eclipse.jetty.server.handler.AbstractHandler.doStop(AbstractHandler.java:108)
                at org.eclipse.jetty.util.component.AbstractLifeCycle.stop(AbstractLifeCycle.java:94)
                at org.eclipse.jetty.util.component.ContainerLifeCycle.stop(ContainerLifeCycle.java:180)
                at org.eclipse.jetty.util.component.ContainerLifeCycle.doStop(ContainerLifeCycle.java:201)
                at org.eclipse.jetty.server.handler.AbstractHandler.doStop(AbstractHandler.java:108)
                at org.eclipse.jetty.server.Server.doStop(Server.java:470)
                ... 6 more
Caused by: [CIRCULAR REFERENCE: java.lang.AbstractMethodError: Receiver class info.novatec.micronaut.camunda.bpm.feature.JettyServerCustomizer$ServletContextInitializedListener does not define or inherit an implementation of the resolved method 'abstract void contextDestroyed(javax.servlet.ServletContextEvent)' of interface javax.servlet.ServletContextListener.]

tobiasschaefer · 2021-11-29T21:13:20Z

@datakurre

Yes, your change in the dependency is correct 👍

The exception is surely an unwanted side effect of the deletion of the contextDestroyed method: f4866e2#diff-188ba99efc68f0cf5b032be1d95ae420cb2d8709ffb6787b117c585c2d39cc7cL170

So this would need to added again - and also for the other listener. However, I cannot reproduce the error but need to to safely fix it.

How are you building, starting and stopping your application? I've tried various ways but never get an exception when stopping it.

Which JDK are you using? The interface "ServletContextListener" has a default implementation for both methods so it's unclear to me why these must be implemented.

datakurre · 2021-11-29T21:53:43Z

@tobiasschaefer I created the app using https://micronaut.io/launch/ with Java 17 and Maven, starting with ./mvnw mn:run with OpenJDK Runtime Environment (build 17.0.1+12), stopping here with Ctrl+C.

Curiously, I also get this error from the default test provided by micronaut launch scaffold with mvn test.

I was able reproduce this by creating a new scaffold with just camunda and h2 features and configuring jetty + webapps + rest.

Update: Got the same results with OpenJDK Runtime Environment (build 11.0.12).

…Listener does not define or inherit an implementation of the resolved method 'abstract void contextDestroyed(javax.servlet.ServletContextEvent)' of interface javax.servlet.ServletContextListener"

…ine or inherit an implementation of the resolved method 'abstract void contextDestroyed(javax.servlet.ServletContextEvent)' of interface javax.servlet.ServletContextListener"

tobiasschaefer · 2021-11-30T07:26:47Z

@datakurre
Sorry about the regression with the exception. It also came in the test because the process engine is started by default and closed again when the application context is closed.

Release 2.3.2 should now work for you. Looking forward to your feedback!

datakurre · 2021-11-30T07:41:29Z

@tobiasschaefer I can confirm that everything works now. Thanks a lot for the hard work and quick fixes!

FYI. asyncResponseTimeout still does not work when run with ./mvwn mn:run, but when I package a JAR its contents look right and asyncResponseTimeout works as expected when running the JAR. Probably work also for other packaging options.

tobiasschaefer · 2021-11-30T17:41:30Z

@datakurre
Strange, that ./mvnw mn:run fails to activate the long polling but I can confirm that behaviour. The Maven project works when starting the application from IntelliJ.
With a Gradle project it works too: ./gradlew run and also from IntelliJ.

Note:

Running a Fat/Uber/Shadow JAR may lead to other problems: https://github.com/camunda-community-hub/micronaut-camunda-bpm#no-version-information-in-fatubershadow-jar
Micronaut's integration with Gradle is generally better than with Maven so this might be a reason to try out Gradle.

datakurre · 2021-11-30T18:50:25Z

@tobiasschaefer Thanks. I'm quite happy now with long-polling working in built version. Regarding maven vs. gradle, are there any runtime related differences? (Not sure if I miss anything that I'd really need.)

tobiasschaefer · 2021-11-30T20:34:28Z

@datakurre no, I’m not aware of any differences.

I’d be happy to discuss any other questions you might have and I’d also like to know more about your use use. I sent you a LinkedIn contact request 😀

…ting to Micronaut 3.x), see also camunda-community-hub/micronaut-camunda-platform-7#353

datakurre mentioned this issue Nov 28, 2021

Close #215: Using CamundaRestApi to process ExternalTasks #235

Merged

arolfes closed this as completed in f4866e2 Nov 29, 2021

tobiasschaefer added a commit to tobiasschaefer/micronaut-camunda-external-client that referenced this issue Dec 1, 2021

Update to GraalVM 21.3.0 and JDK 17 (and make it run again after upda…

4e44a3f

…ting to Micronaut 3.x), see also camunda-community-hub/micronaut-camunda-platform-7#353

tobiasschaefer mentioned this issue Dec 1, 2021

Update to GraalVM 21.3.0 and JDK 17 (and make it run again after upda… camunda-community-hub/micronaut-camunda-external-client#75

Merged

datakurre mentioned this issue Oct 1, 2022

Regression on fetchAndLock long poll (asyncResponseTimeout has no effect) #433

Closed

Provide feedback

Saved searches

Use saved searches to filter your results more quickly

How to configure fetchAndLock long poll? (asyncResponseTimeout has no effect) #353

How to configure fetchAndLock long poll? (asyncResponseTimeout has no effect) #353

datakurre commented Nov 28, 2021

datakurre commented Nov 28, 2021

datakurre commented Nov 28, 2021

tobiasschaefer commented Nov 28, 2021 •

edited

Loading

datakurre commented Nov 28, 2021 •

edited

Loading

datakurre commented Nov 29, 2021

tobiasschaefer commented Nov 29, 2021

datakurre commented Nov 29, 2021

tobiasschaefer commented Nov 29, 2021 •

edited

Loading

datakurre commented Nov 29, 2021 •

edited

Loading

tobiasschaefer commented Nov 30, 2021

datakurre commented Nov 30, 2021

tobiasschaefer commented Nov 30, 2021

datakurre commented Nov 30, 2021

tobiasschaefer commented Nov 30, 2021

How to configure fetchAndLock long poll? (asyncResponseTimeout has no effect) #353

How to configure fetchAndLock long poll? (asyncResponseTimeout has no effect) #353

Comments

datakurre commented Nov 28, 2021

datakurre commented Nov 28, 2021

datakurre commented Nov 28, 2021

tobiasschaefer commented Nov 28, 2021 • edited Loading

datakurre commented Nov 28, 2021 • edited Loading

datakurre commented Nov 29, 2021

tobiasschaefer commented Nov 29, 2021

datakurre commented Nov 29, 2021

tobiasschaefer commented Nov 29, 2021 • edited Loading

datakurre commented Nov 29, 2021 • edited Loading

tobiasschaefer commented Nov 30, 2021

datakurre commented Nov 30, 2021

tobiasschaefer commented Nov 30, 2021

datakurre commented Nov 30, 2021

tobiasschaefer commented Nov 30, 2021

tobiasschaefer commented Nov 28, 2021 •

edited

Loading

datakurre commented Nov 28, 2021 •

edited

Loading

tobiasschaefer commented Nov 29, 2021 •

edited

Loading

datakurre commented Nov 29, 2021 •

edited

Loading