Where communities thrive


  • Join over 1.5M+ people
  • Join over 100K+ communities
  • Free without limits
  • Create your own community
People
Activity
    Luca Burgazzoli
    @lburgazzoli
    @vaibhavflip please use https://camel.zulipchat.com/ as this room is not more active.
    Vaibhav Bansal
    @vaibhavflip
    thanks @lburgazzoli
    gbarreto2020
    @gbarreto2020
    Quick question here. I am using the Camel Salesforce component and I am trying to clear the value of a field on a specific sobject. Any ideas on how to do that?
    Setting the field to null and performing an update does not seem to work.
    gbarreto2020
    @gbarreto2020
    Nevermind all. I figured it out.
    KimJohn Quinn
    @kjq
    Am I just missing something dumb here? I am pulling in this dependency (pom/import) because I just want the starters only and let my SpringBoot POM drive the version. It looks like this BOM pulls in Camel Tooling then Camel spring-boot which has a spring-boot version so I have multiple versions (for example spring-web) and that is causing me issues. I am using the latest SpringBoot.
    <dependency>
         <groupId>org.apache.camel.springboot</groupId>
         <artifactId>camel-spring-boot-bom</artifactId>
          <version>3.5.0</version>
          <scope>import</scope>
          <type>pom</type>
     </dependency>
    KimJohn Quinn
    @kjq
    I was able to override the older spring boot by redeclaring the newer spring boot in a lower Pom.
    Dmitry Volodin
    @dmvolod
    @kjq please use https://camel.zulipchat.com/ as this room is not more active.
    @gbarreto2020 please use https://camel.zulipchat.com/ as this room is not more active.
    Pedro Catalão
    @pedrocatalao
    greetings everyone, quick question, does anyone know if it's possible to fetch a file listing with the FTP component?
    Luca Burgazzoli
    @lburgazzoli
    @pedrocatalao please use https://camel.zulipchat.com/ as this room is not more active.
    Pedro Catalão
    @pedrocatalao
    thanks @lburgazzoli :thumbsup:
    Levent Divilioglu
    @bzdgn

    Hello all, I'm trying to convert my existing queues to virtual topics within Apache Camel. I've applied the examples I've seen in the internet;

    For producers;

    VirtualTopic.<queue_name>

    Also wrapped them with ActiveMQTopic instances. But in my local running AMQ, I cant see the entries.

    is there any reliable hello world example for using Virtual Queues (with ActiveMQ) within Apache Camel?

    Thanks

    Andrea Tarocchi
    @valdar
    @bzdgn please use https://camel.zulipchat.com/ as this room is not more active.
    Levent Divilioglu
    @bzdgn

    @bzdgn please use https://camel.zulipchat.com/ as this room is not more active.

    Thanks!

    Gabriel Soto
    @gsoto
    Should I go with Groovy or JavaScript as my scripting language?
    Andrea Tarocchi
    @valdar
    @gsoto please use https://camel.zulipchat.com/ as this room is not more active.
    Gabriel Soto
    @gsoto
    oh, sure!
    thanks for the heads up, @valdar
    VinayRajN
    @VinayRajN

    Hello All,

    I am working on a Camel project to consume a TCP service.

    TCP call

    <to uri="netty:tcp://0.0.0.0:9001?sync=true&amp;clientMode=true&amp;tcpNoDelay=true&amp;receiveBufferSize=500000&amp;synchronous=true" />

    The connection is made successfully, but the first request's response is chunked but I am expecting a full response.
    From the next subsequent calls, the response is not chunked and I get the full response.

    Appreciate if any help can be extended on this.

    Thanking you in advance.

    Luca Burgazzoli
    @lburgazzoli
    @VinayRajN please use https://camel.zulipchat.com as this chat is not more active
    VinayRajN
    @VinayRajN
    Thank you @lburgazzoli
    NicuD
    @nicud95_twitter
    Hi,
    It seems you can't use the FTP component via proxy? It doesn't recognize the parameter "proxy", I tried to use camel-ftp version 2.24.2 and 2.8.0
    Thanks
    Luca Burgazzoli
    @lburgazzoli
    @nicud95_twitter please use https://camel.zulipchat.com as this chat is not more active
    NicuD
    @nicud95_twitter
    will do, thanks
    mrbq
    @mrbq
    Hello,
    I am connecting to a https endpoint using http4 componet but the first time I try to connect it takes more than 5s to open the connection
    Luca Burgazzoli
    @lburgazzoli
    @mrbq please use https://camel.zulipchat.com as this chat is not more active
    sreekanthjanapati
    @sreekanthjanapati
    Hi, i would like to connect Apache Kafka consumer with Spring boot and Camel but while connecting with SSL
    but I'm getting below error org.apache.camel.spring.boot.CamelSpringBootInitializationException: java.io.IOException: Invalid Keystore format please anyone help me how to resolve this error
        public void configure() throws Exception {
    
            Endpoint createEndpoint = cdcHelper.setupSSLConext(context);
    
            from("{{timerOnce}}").process(consumerCreate)
                    .to(createEndpoint);    // calling kafka consumer 
    
        }
    }
    public Endpoint setupSSLConext(CamelContext camelContext) throws Exception {
    
            KeyStoreParameters keyStoreParameters = new KeyStoreParameters();
            // Change this path to point to your truststore/keystore as jks files
            keyStoreParameters.setResource("kafka.client.truststore.jks");
            keyStoreParameters.setPassword("123456");
    
            KeyManagersParameters keyManagersParameters = new KeyManagersParameters();
            keyManagersParameters.setKeyStore(keyStoreParameters);
            keyManagersParameters.setKeyPassword("123456");
    
            TrustManagersParameters trustManagersParameters = new TrustManagersParameters();
            trustManagersParameters.setKeyStore(keyStoreParameters);
    
            SSLContextParameters sslContextParameters = new SSLContextParameters();
            sslContextParameters.setKeyManagers(keyManagersParameters);
            sslContextParameters.setTrustManagers(trustManagersParameters);
    
            HttpComponent httpComponent = camelContext.getComponent("https4", HttpComponent.class);
            httpComponent.setSslContextParameters(sslContextParameters);
    
    
            // This is important to make your cert skip CN/Hostname checks
            httpComponent.setX509HostnameVerifier(new X509HostnameVerifier() {
                @Override
                public void verify(String s, SSLSocket sslSocket) throws IOException {
    
                }
    
                @Override
                public void verify(String s, X509Certificate x509Certificate) throws SSLException {
    
                }
    
                @Override
                public void verify(String s, String[] strings, String[] strings1) throws SSLException {
    
                }
    
                @Override
                public boolean verify(String s, SSLSession sslSession) {
                    // I don't mind just return true for all or you can add your own logic
                    return true;
                }
    
            });
    
            return     httpComponent.createEndpoint("https://XX.XX.X.XXX/consumers/");
        }
    Andrea Tarocchi
    @valdar
    @sreekanthjanapati please use https://camel.zulipchat.com as this chat is not more active
    sreekanthjanapati
    @sreekanthjanapati
    @valdar thanks
    sreekanthjanapati
    @sreekanthjanapati

    My requirement is to connect the Kafka consumer through the SSL with Spring boot and Camel, for that, I have written the below code but I'm facing an error like Caused by sun.security.validator.ValidatorException: PKIX path building failed: sun.security.provider.certpath.SunCertPathBuilderException: unable to find valid certification path to requested target this, anyone please help me how to resolve this error.

    public class Testing {
        @Bean
         SSLContextParameters sslContextParameters(){
            KeyStoreParameters store = new KeyStoreParameters();
            store.setResource("kafka.client.truststore.jks");
            store.setPassword("123456");
    
            TrustManagersParameters trust = new TrustManagersParameters();
            trust.setKeyStore(store);
    
            SSLContextParameters parameters = new SSLContextParameters();
            parameters.setTrustManagers(trust);
    
            return parameters;
          }
    
    }

    In another file, I'm calling router with sslContextParameters parameter

        @Autowired
        SSLContextParameters params;
    @Override
        public void configure() throws Exception {
        from("{{timerOnce}}").process(consumerCreate).to(
                    "{{conumserRoute}}{{groupName}}?sslContextParameters=params");
    
    }
    Andrea Tarocchi
    @valdar
    @sreekanthjanapati please use https://camel.zulipchat.com as this chat is not more active
    same
    :D
    sreekanthjanapati
    @sreekanthjanapati
    @valdar thanks again, i'm posted there also
    Dinesh Shetye
    @dineshshetye

    I am running in issues with absolute and relative path when trying to pick file from remote location. Can someone please help with this issue? I am using Camel v3.0.1. I have a SFTP location sftp://my.sftpserver.com:22. My default home directory is as below:

    sftp> pwd
    Remote working directory: /Distribution/dor/Rec_Sales/Comp

    I want to change directory to /Distribution/dor/modlpool_daily_L5 to pick files.

    However I am getting error when trying absolute path: //Distribution/dor/modlpool_daily_L5

    28 Oct 2020 12:18:10,432 ERROR [Camel (camelContext) thread #853 - sftp://my.sftpserver.com:22//Distribution/dor/modlpool_daily_L5/] StopRouteExternalExceptionProcessor:34 - ERROR MESSEGE: Cannot list directory: Distribution/dor/modlpool_dail
    y_L5

    Also when trying relative path: ../../modlpool_daily_L5/

    28 Oct 2020 13:14:10,812 ERROR [Camel (camelContext) thread #1148 - sftp://my.sftpserver.com:22/../../modlpool_daily_L5/] StopRouteExternalExceptionProcessor:34 - ERROR MESSEGE: Cannot retrieve file: ../../modlpool_daily_L5/test.txt
    Andrea Tarocchi
    @valdar
    @dineshshetye please use https://camel.zulipchat.com as this chat is not more active
    Saravanakumar Selvaraj
    @saravanakumar1987
    Hi Experts,
    I am trying to create my route like <split strategyRef="groupedBodyAggregationStrategy" completionSize="100">, but it does not allow me to set completionSize for the aggregationStrategy. Any help?
    Saravanakumar Selvaraj
    @saravanakumar1987
    Is this possible to set completionSize for the built-in aggregator in splitter EIP ?
    Andrea Tarocchi
    @valdar
    @saravanakumar1987 please use https://camel.zulipchat.com as this chat is not more active
    chinthasantoshkumar
    @santoshkumar27_twitter
    How to enable/use MDC logging in apache camel 7.4 version
    chinthasantoshkumar
    @santoshkumar27_twitter
    @dineshshetye Use Relative Path but i suggest you to try below
    sftp://my.sftpserver.com:22/../../../../Distribution/dor/Rec_Sales/Comp/modlpool_daily_L5/] StopRouteExternalExceptionProcessor:34 - ERROR MESSEGE: Cannot retrieve file: ../../modlpool_daily_L5/test.txt
    Luca Burgazzoli
    @lburgazzoli
    @santoshkumar27_twitter please use https://camel.zulipchat.com as this chat is not more active
    Zachariah Young
    @zachariahyoung
    I'm trying to use the camel-kafka-starter component with the Confluent Cloud schema registry. How do I configure the component with the user id and password?
    Luca Burgazzoli
    @lburgazzoli
    @zachariahyoung please use https://camel.zulipchat.com as this chat is not more active
    Zachariah Young
    @zachariahyoung
    @lburgazzoli thanks
    Sebastian Dobrea
    @TKSds
    quick question guys, how can I stop a consumer from a doCatch() clause?
    Sebastian Dobrea
    @TKSds
    any tiny tip would be very apreciated, I've been struggling with this for several hours now
    can't seem to make it work