Where communities thrive


  • Join over 1.5M+ people
  • Join over 100K+ communities
  • Free without limits
  • Create your own community
People
Repo info
Activity
    Freddy
    @freddydevio
    Hello together,
    I have some long timing request about > 30 minutes and the netty-http component of quarkus-camel seems to timeout in that time (about 30 minutes). I thought there is no timeout defined? In the documentation it says "requestTimeout" -> "By default no timeout is in use". I've also tried like this: "keepAlive=true&synchronous=true" but it doesn't change anything in the behaviour.
    Has somebody some idea for that?
    Andrea Cosentino
    @oscerd
    Actually the requestTimeout for netty-http is 30s
    @freddydevio
    Freddy
    @freddydevio
    @oscerd yes you are right, if I would define it I would write it in seconds. But at the default there is no one..
    Andrea Cosentino
    @oscerd
    the documentation is the camel documentation
    and the default is 30s
    so the extension is using a 30s requestTimeout.
    Freddy
    @freddydevio
    I get this message in the camel logs:
    2020-04-22 10:44:04,992 DEBUG [org.apa.cam.com.net.NettyProducer] (Camel Thread #5 - NettyClientTCPWorker) Channel: [id: 0xe0634473, L:/10.0.0.110:53134 - R:connector-output-service/172.20.167.160:9092] writing body: DefaultFullHttpRequest(decodeResult: success, version: HTTP/1.1, content: PooledUnsafeDirectByteBuf(ridx: 0, widx: 93, cap: 93))
    POST /import/product?synchronous=true HTTP/1.1
    content-length: 93
    content-type: application/json
    host: shopware-connector-output-service:9092
    connection: keep-alive
    ......
    .....
    2020-04-22 11:14:05,009 DEBUG [org.apa.cam.com.net.NettyProducer] (Camel Thread #5 - NettyClientTCPWorker) Channel is inactive but no message received from address: connector-output-service:9092
    2020-04-22 11:14:05,009 DEBUG [org.apa.cam.pro.Pipeline] (Camel Thread #4 - NettyClientTCPWorker) Message exchange has failed: so breaking out of pipeline for exchange: Exchange[846DC1FFEC9595D-0000000000000000] Exception: org.apache.camel.CamelExchangeException: No response received from remote server: connector-output-service:9092. Exchange[846DC1FFEC9595D-0000000000000000]
    Andrea Cosentino
    @oscerd
    Let me see if we changed the default.
    yes, just checked and there shouldn't be any timeout as default. That's a bit weird.
    Probably you could raise an issue in camel-quarkus for this.
    Thanks.
    arsalone
    @arsalone
    Hello. I was looking the camel-quarkus project but didn't find roadmap. Is there any available?
    Jordi Cardoso Abillar
    @jordicardoso
    How to stop camel-quarkus app? quarkus is still running with camelContext stopped.
    Luca Burgazzoli
    @lburgazzoli
    @jordicardoso this will be available in a future release as the bits needed for that have been added to quakrus only recently
    @arsalone the main goal now is to add support for additional camel component
    Jordi Cardoso Abillar
    @jordicardoso
    @lburgazzoli Thank you very much! very amazing project, I'll keep testing...
    Freddy
    @freddydevio
    Good morning together, I have a weird behaviour since some hours of testing. The issue appears like the first time for me in camel-quarkus. It only appears in the native image, I using the "camel-quarkus-bom:camel-quarkus-bom:1.0.0-M3". But I don't change the parent.
    Here is the error message: `org.apache.camel.component.file.remote.RemoteFile can not be instantiated reflectively as it does not have a no-parameter constructor or the no-parameter constructor has not been added explicitly to the native image`
    I try to fetch a file in camel by the ftp component.
    This is the complete log:
    2020-05-06 14:26:07,747 WARN  [org.apa.cam.com.fil.rem.FtpConsumer] (Camel (camel-1) thread #1 - ftp://test:21/product) ftp://test:21/product?binary=true&delay=15s&delete=true&include=stopmain&localWorkDirectory=%2Ftmp&noop=false&passiveMode=true&password=xxxxxx&preMove=inprogress&recursive=false&resumeDownload=true&transferLoggingIntervalSeconds=1&transferLoggingLevel=INFO&transferLoggingVerbose=true cannot begin processing file: RemoteFile[stopmain] due to: java.lang.InstantiationException: Type `org.apache.camel.component.file.remote.RemoteFile` can not be instantiated reflectively as it does not have a no-parameter constructor or the no-parameter constructor has not been added explicitly to the native image.. Caused by: [org.apache.camel.RuntimeCamelException - java.lang.InstantiationException: Type `org.apache.camel.component.file.remote.RemoteFile` can not be instantiated reflectively as it does not have a no-parameter constructor or the no-parameter constructor has not been added explicitly to the native image.]: org.apache.camel.RuntimeCamelException: java.lang.InstantiationException: Type `org.apache.camel.component.file.remote.RemoteFile` can not be instantiated reflectively as it does not have a no-parameter constructor or the no-parameter constructor has not been added explicitly to the native image.
        at org.apache.camel.component.file.GenericFile.copyFrom(GenericFile.java:81)
        at org.apache.camel.component.file.strategy.GenericFileExpressionRenamer.renameFile(GenericFileExpressionRenamer.java:41)
        at org.apache.camel.component.file.strategy.GenericFileDeleteProcessStrategy.begin(GenericFileDeleteProcessStrategy.java:42)
        at org.apache.camel.component.file.GenericFileConsumer.processExchange(GenericFileConsumer.java:362)
        at org.apache.camel.component.file.remote.RemoteFileConsumer.processExchange(RemoteFileConsumer.java:134)
        at org.apache.camel.component.file.GenericFileConsumer.processBatch(GenericFileConsumer.java:223)
        at org.apache.camel.component.file.GenericFileConsumer.poll(GenericFileConsumer.java:186)
        at org.apache.camel.support.ScheduledPollConsumer.doRun(ScheduledPollConsumer.java:183)
        at org.apache.camel.support.ScheduledPollConsumer.run(ScheduledPollConsumer.java:102)
        at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515)
        at java.util.concurrent.FutureTask.runAndReset(FutureTask.java:305)
        at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:305)
        at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)
        at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)
        at java.lang.Thread.run(Thread.java:834)
        at com.oracle.svm.core.thread.JavaThreads.threadStartRoutine(JavaThreads.java:497)
        at com.oracle.svm.core.posix.thread.PosixJavaThreads.pthreadStartRoutine(PosixJavaThreads.java:193)
    Caused by: java.lang.InstantiationException: Type `org.apache.camel.component.file.remote.RemoteFile` can not be instantiated reflectively as it does not have a no-parameter constructor or the no-parameter constructor has not been added explicitly to the native image.
        at java.lang.Class.newInstance(DynamicHub.java:796)
        at org.apache.camel.component.file.GenericFile.copyFrom(GenericFile.java:79)
        ... 16 more
    Freddy
    @freddydevio

    Okay the last change which I did was changing this parameters:

    • adding preMove=inprogress
    • recursive=true -> false

    I added the premoving to ensure that camel doesn't look at this file again because the process is very long and camel started the process again unfortunately.

    Luca Burgazzoli
    @lburgazzoli
    @freddydevio mind opening an issue ? looks like we are missing to register that class for reflection
    Luca Burgazzoli
    @lburgazzoli
    @freddydevio the issue has been fixed in camel (see apache/camel-quarkus#1113) so it will be available in camel-quarkus once we upgrade to camel 3.3.0
    Kesav Kolla
    @kesavkolla

    Hi I'm trying to use xml based route using routes. I've a xpath expression which uses namespace and it's not taking defined namespaces in routes xml. How do I define namespaces? Here is my route xml

    <routes xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
            xmlns="http://camel.apache.org/schema/spring"
            xmlns:soap-env="http://www.w3.org/2003/05/soap-envelope"
            xsi:schemaLocation="
                http://camel.apache.org/schema/spring
                http://camel.apache.org/schema/spring/camel-spring-3.4.2.xsd">
        <route id="myroute">
            <from uri="platform-http:/handler?httpMethodRestrict=POST"/>
            <setProperty name="MessageType">
                <xpath resultType="java.lang.String" logNamespaces="true">
                    local-name(/soap-env:Envelope/soap-env:Body/*[1])
                </xpath>
            </setProperty>
            <log message="${exchangeProperty.MessageType}"/>
            <setBody>
                <simple>
                    Hello ${body}
                </simple>
            </setBody>
        </route>
    </routes>

    When I try to post XML file to handler endpoint I get the following error:

    org.apache.camel.language.xpath.InvalidXPathException: Invalid xpath: local-name(/soap-env:Envelope/soap-env:Body/*[1]). Reason: javax.xml.xpath.XPathExpressionException: javax.xml.transform.TransformerException: Prefix must resolve to a namespace: soap-env
        at org.apache.camel.language.xpath.XPathBuilder.evaluateAs(XPathBuilder.java:943)
        at org.apache.camel.language.xpath.XPathBuilder.evaluate(XPathBuilder.java:921)
        at org.apache.camel.language.xpath.XPathBuilder.evaluate(XPathBuilder.java:240)
        at org.apache.camel.processor.SetPropertyProcessor.process(SetPropertyProcessor.java:47)
        at org.apache.camel.processor.errorhandler.RedeliveryErrorHandler$SimpleTask.run(RedeliveryErrorHandler.java:395)
        at org.apache.camel.impl.engine.DefaultReactiveExecutor$Worker.schedule(DefaultReactiveExecutor.java:148)
        at org.apache.camel.impl.engine.DefaultReactiveExecutor.scheduleMain(DefaultReactiveExecutor.java:60)
        at org.apache.camel.processor.Pipeline.process(Pipeline.java:147)
        at org.apache.camel.processor.CamelInternalProcessor.process(CamelInternalProcessor.java:286)
        at org.apache.camel.quarkus.component.platform.http.runtime.QuarkusPlatformHttpConsumer.lambda$doStart$2(QuarkusPlatformHttpConsumer.java:123)
    .....................
    Caused by: javax.xml.xpath.XPathExpressionException: javax.xml.transform.TransformerException: Prefix must resolve to a namespace: soap-env
        at java.xml/com.sun.org.apache.xpath.internal.jaxp.XPathImpl.compile(XPathImpl.java:170)
        at org.apache.camel.language.xpath.XPathBuilder.createXPathExpression(XPathBuilder.java:1170)
        at org.apache.camel.language.xpath.XPathBuilder.evaluateAs(XPathBuilder.java:941)
        ... 29 more
    Caused by: javax.xml.transform.TransformerException: Prefix must resolve to a namespace: soap-env
        at java.xml/com.sun.org.apache.xpath.internal.compiler.XPathParser.error(XPathParser.java:621)
        at java.xml/com.sun.org.apache.xpath.internal.compiler.Lexer.mapNSTokens(Lexer.java:637)
        at java.xml/com.sun.org.apache.xpath.internal.compiler.Lexer.tokenize(Lexer.java:269)
    Luca Burgazzoli
    @lburgazzoli
    @kesavkolla I’m not sure this is supported, mind opening an issue on the camel-quarkus github project ?
    Kesav Kolla
    @kesavkolla
    @lburgazzoli I've opened the issue in the project too.
    Rahul Kiran Gaddam
    @rahgadda

    Hi Team,

    I am trying to do a sample application on RedHat https://github.com/atlasmap/atlasmap.
    Do we have any sample example using quarkus.
    I am getting "No endpoint could be found for: atlas:"

    Can you please help.

    Regards,
    Rahul

    Andrea Cosentino
    @oscerd
    No, no sample for atlasmap
    camel-atlasmap is not part of Apache Camel actually
    oluotes
    @oluotes_gitlab
    I'm trying to port an existing Camel Spring boot application to Quarkus. Everything works well in dev mode but when trying to run in native mode I get the the following error
    .sdkman/candidates/java/20.1.0.r11-grl/bin/native-image -J-Dsun.nio.ch.maxUpdateArraySize=100 -J-Djava.util.logging.manager=org.jboss.logmanager.LogManager -J-DCoordinatorEnvironmentBean.transactionStatusManagerEnable=false -J-Dvertx.logger-delegate-factory-class-name=io.quarkus.vertx.core.runtime.VertxLogDelegateFactory -J-Dvertx.disableDnsResolver=true -J-Dio.netty.leakDetection.level=DISABLED -J-Dio.netty.allocator.maxOrder=1 -J-Duser.language=en -J-Dfile.encoding=UTF-8 --initialize-at-build-time= -H:InitialCollectionPolicy=com.oracle.svm.core.genscavenge.CollectionPolicy$BySpaceAndTime -H:+JNI -jar contact-tracing-api-1.0.0-SNAPSHOT-runner.jar -H:FallbackThreshold=0 -H:+ReportExceptionStackTraces -H:+AddAllCharsets -H:+IncludeAllTimeZones -H:EnableURLProtocols=http,https --enable-all-security-services --no-server -H:-UseServiceLoaderFeature -H:+StackTrace contact-tracing-api-1.0.0-SNAPSHOT-runner
    -H:IncludeAllTimeZones and -H:IncludeTimeZones are now deprecated. Native-image includes all timezonesby default.
    [contact-tracing-api-1.0.0-SNAPSHOT-runner:2538]    classlist:  16,790.01 ms,  2.70 GB
    [contact-tracing-api-1.0.0-SNAPSHOT-runner:2538]        setup:     946.69 ms,  2.70 GB
    Error: substitution target for org.apache.camel.quarkus.support.spring.graal.SubstituteBeanUtilsKotlinDelegate is not loaded. Use field `onlyWith` in the `TargetClass` annotation to make substitution only active when needed.
    com.oracle.svm.core.util.UserError$UserException: substitution target for org.apache.camel.quarkus.support.spring.graal.SubstituteBeanUtilsKotlinDelegate is not loaded. Use field `onlyWith` in the `TargetClass` annotation to make substitution only active when needed.
        at com.oracle.svm.core.util.UserError.abort(UserError.java:68)
        at com.oracle.svm.hosted.substitute.AnnotationSubstitutionProcessor.findTargetClass(AnnotationSubstitutionProcessor.java:834)
        at com.oracle.svm.hosted.substitute.AnnotationSubstitutionProcessor.handleClass(AnnotationSubstitutionProcessor.java:252)
        at com.oracle.svm.hosted.substitute.AnnotationSubstitutionProcessor.init(AnnotationSubstitutionProcessor.java:230)
        at com.oracle.svm.hosted.NativeImageGenerator.createDeclarativeSubstitutionProcessor(NativeImageGenerator.java:908)
        at com.oracle.svm.hosted.NativeImageGenerator.setupNativeImage(NativeImageGenerator.java:838)
        at com.oracle.svm.hosted.NativeImageGenerator.doRun(NativeImageGenerator.java:536)
        at com.oracle.svm.hosted.NativeImageGenerator.lambda$run$0(NativeImageGenerator.java:451)
        at java.base/java.util.concurrent.ForkJoinTask$AdaptedRunnableAction.exec(ForkJoinTask.java:1407)
        at java.base/java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:290)
        at java.base/java.util.concurrent.ForkJoinPool$WorkQueue.topLevelExec(ForkJoinPool.java:1020)
        at java.base/java.util.concurrent.ForkJoinPool.scan(ForkJoinPool.java:1656)
        at java.base/java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1594)
        at java.base/java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:177)
    Error: Image build request failed with exit status 1
    [ERROR] Failed to execute goal io.quarkus:quarkus-maven-plugin:1.6.1.Final:build (default) on project contact-tracing-api: Failed to build quarkus application: io.quarkus.builder.BuildException: Build failure: Build failed due to errors
    [ERROR]     [error]: Build step io.quarkus.deployment.pkg.steps.NativeImageBuildStep#build threw an exception: java.lang.RuntimeException: Failed to build native image
    [ERROR]     at io.quarkus.deployment.pkg.steps.NativeImageBuildStep.build(NativeImageBuildStep.java:371)
    [ERROR]     at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
    [ERROR]     at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
    [ERROR]     at java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
    [ERROR]     at java.base/java.lang.reflect.Method.invoke(Method.java:566)
    [ERROR]     at io.quarkus.deployment.ExtensionLoader$2.execute(ExtensionLoader.java:932)
    [ERROR]     at io.quarkus.builder.BuildContext.run(BuildContext.java:277)
    [ERROR]     at org.jboss.threads.ContextClassLoaderSavingRunnable.run(ContextClassLoaderSavingRunnable.java:35)
    [ERROR]     at org.jboss.threads.EnhancedQueueExecutor.safeRun(EnhancedQueueExecutor.java:2046)
    [ERROR]     at org.jboss.threads.EnhancedQueueExecutor$ThreadBody.doRunTask(EnhancedQueueExecutor.java:1578)
    [ERROR]     at org.jboss.threads.EnhancedQueueExecutor$ThreadBody.run(EnhancedQueueExecutor.java:1452)
    [ERROR]     at java.base/java.lang.Thread.run(Thread.java:834)
    [ERROR]     at org.jboss.threads.JBossThread.run(JBossThread.java:479)
    [ERROR] Caused by: java.lang.RuntimeException: Image generation failed. Exit code: 1
    [ERROR]     at io.quarkus.deployment.pkg.steps.NativeImageBuildStep.imageGenerationFailed(NativeImageBuildStep.java:421)
    [ERROR]     at io.quarkus.deployment.pkg.steps.NativeImageBuildStep.build(NativeImageBuildStep.java:349)
    [ERROR]     ... 12 more
    What am I missing? Thanks!
    Luca Burgazzoli
    @lburgazzoli
    do you have a sample repository we can have a look ?
    oluotes
    @oluotes_gitlab
    The issue is resolved.
    it's dependencies related
    oluotes
    @oluotes_gitlab
    any idea on how to resolve
    Error: com.oracle.svm.hosted.substitute.DeletedElementException: Unsupported method java.lang.ClassLoader.defineClass1(ClassLoader, String, byte[], int, int, ProtectionDomain, String) is reachable
    To diagnose the issue, you can add the option --report-unsupported-elements-at-runtime. The unsupported element is then reported at run time when it is accessed the first time.
    Detailed message:
    Trace: 
        at parsing java.lang.ClassLoader.defineClass(ClassLoader.java:1017)
    Call path from entry point to java.lang.ClassLoader.defineClass(String, byte[], int, int, ProtectionDomain): 
        at java.lang.ClassLoader.defineClass(ClassLoader.java:1015)
    Luca Burgazzoli
    @lburgazzoli
    in means that for some reason the defineClass is potentially reachable, it doe not mean that the method is invoked so maybe try to add --report-unsupported-elements-at-runtime i.e. by adding <reportErrorsAtRuntime>true</reportErrorsAtRuntime> to the native image mojo, then we need a possible small reproducer
    Keith Link
    @linktech1
    Why is Quarkus not using Camel for reactive routes? They also seem to be going their own way on the Serverless area and not leveraging Camel K.
    tstuber
    @tstuber
    Hi guys. I am wondering if there is a recommened way to monitor/visualize camel-quarkus routes? I saw that is possible to use hawtio (only for JVM mode - hawtio/hawtio#2643). But is there another approach?
    Luca Burgazzoli
    @lburgazzoli
    HEADS UP: the channel for discussing camel-quarkus has been moved to https://camel.zulipchat.com/
    bslaterdk
    @bslaterdk
    Hi :-)
    I've written a POC service using camel quarkus, but I want to write some test cases.
    But I'm alittle confused, should I write test using Camel test support or using Quarkus, or they intermingle ?
    Luca Burgazzoli
    @lburgazzoli
    @bslaterdk please use https://camel.zulipchat.com as this chat is not more active
    bslaterdk
    @bslaterdk
    @lburgazzoli Thanks. saw the message and already got help there, thanks :-)
    Ângelo Costa
    @angelorlcostaa_twitter
    Hi Guys
    anyone know how i can add a camel-context file to do custom configurations? like for example creating a custom Bean?
    Luca Burgazzoli
    @lburgazzoli
    @angelorlcostaa_twitter this room is not more active, please use https://camel.zulipchat.com/
    Ângelo Costa
    @angelorlcostaa_twitter
    ohh so sorry
    thanks for the help @lburgazzoli
    mnhlvsk
    @mnhlvsk

    Hi all, I'm using Camel component Platform-Htttp to create an endpoint and Quarkus Basic authentication. When I log in and try to get user's identity I'm getting exception ContextNotActiveException.

    @ApplicationScoped
    public class MyProcessor implements Processor {

    @Inject
    public SecurityIdentity identity;
    
    @Override
    public void process(Exchange exchange) {
        String user = identity.getPrincipal().getName();
    }

    }

    koskom-alt
    @koskom-alt

    Hi guys!
    I'm trying to set up interaction with activemq. I am using camel-quarkus-activemq.
    In native mode, after restarting the service, I encountered the following problem:

    • the message broker periodically resets to dlq instead of the destination queue with an error
      dlqDeliveryFailureCause=java.lang.Throwable: duplicate from store for queue:test.queue.

    As far as I can tell, the problem is that there are duplicate JMSMessageIDs. And they appear because the ActiveMQConnectionFactory is created during assembly, and not at the start of the service, respectively, the producerId is registered in advance in the image. And it does not change when the service is restarted, and even worse, this behavior makes horizontal scaling impossible, since each replica will have the same producerId and there will be contention for a unique JMSMessageID.

    Tell me, please, is it possible to somehow bypass this behavior, maybe someone has a successful experience using this component.