Where communities thrive


  • Join over 1.5M+ people
  • Join over 100K+ communities
  • Free without limits
  • Create your own community
People
Activity
    Sascha Wiegandt
    @TheSasch

    if i read the documentation of the metrics component then it looks like any other datasink where you could put data to. it is possible that within the component there would be something like aggregation. but at the first look ist does not look other than any other consumer. with the from and the metrics-to i thought about that you could change everything you want. if i have such a problem i first introduce a processor to have a look which structure the body and the header data are and have a look if i could find my passwort. then a own solution would help or someone else wrote such a solution ,-)

    While going to the outside get running. i thought about i wrote and i made a mistake. so sorry. documentation also says it is a produce and not a consumer. but it must have also consuming parts because of the behavior you wrote. so please have a look if you could get a execution endpoint within the producer to change some parts of the message.

    Jose Montoya
    @jam01
    Hey guys, I'm trying to find out what camel-jasypt-starter does. The docs don't offer much currently.
    oh sorry, actually there are no docs for the jasypt starter
    We have also found this https://github.com/ulisesbocchio/jasypt-spring-boot/ but wanted to know if maybe we're not seeing something with camel's own starter
    Raju Parashar
    @rajuparashar23

    Hello Everyone,
    Good day

    while working with camel 3.0.0, below piece of code was working

    from("...")
    .process(this::configureExchangeProperties)
    ...
    .to("...")

    private Processor configureExchangeProperties()
    {
    return x-> {
    //.. some general header population
    };
    }

    As mentioned in 3.0 to 3.1 upgradation guide, the supplier version of ProcessorDefintion has been removed,
    and so we modified our code as below before upgrading to 3.1

    from("...")
    .process(this::configureExchangeProperties)
    ...
    .to("...")

    private void configureExchangeProperties(Exchange exchange)
    {
    //.. some general header population
    }

    Now, with just this change, or code started behaving weird. No output were generating. Also, nothing suspicious was found in logs
    Could you please tell, what may be the probable reason ?

    Luca Burgazzoli
    @lburgazzoli
    @jam01 @rajuparashar23 the official camel chat has been moved over Zulip https://camel.zulipchat.com, please move your question there
    Jose Montoya
    @jam01
    Ah ok. Thanks.
    Raju Parashar
    @rajuparashar23
    ok..thank you
    Luca Burgazzoli
    @lburgazzoli
    HEADS UP: the channel for discussing camel has been moved to https://camel.zulipchat.com/
    akhileshacc
    @akhileshacc

    Hi, Can we download all blobs from Azure blob storage, by just specifying container name.
    Something like in Amazon s3, where I specify bucket name and it picks all files in that bucket.

    Currently, I see we need to specify blob name and it will download that file.

    from("azure-storage-blob:/camelazure/container1?blobName=hello.txt&accessKey=yourAccessKey").
    to("file://blobdirectory");
    Luca Burgazzoli
    @lburgazzoli
    @akhileshacc please use https://camel.zulipchat.com/ as this room is not more active
    TwilightAngelo
    @TwilightAngelo

    Probably there is no reconnection mechanism

    As far as I undersstand from this folowing gode: https://is.gd/H3EcX2, there is some problems with single Connection. One for all events, so, maybe I'm not a really good programmer, but, can you please answer me, I really need an advice, if I try to rewrite my own pg_event and use PGPoolingDataSource for estabilishing connection will it be a good decision or not? Is there any troubles to use PGPoolingDataSource except of DataSource? Many thanks!

    Andrea Tarocchi
    @valdar
    @TwilightAngelo please use https://camel.zulipchat.com/ as this room is not more active.
    Leonardo Golfeto
    @leonardogolfeto
    Hi guys
    The RabbitMq is accepting messages in the default exchange from another application and able to view thru the WEb console...but Camel is displayne error
    Caused by: com.rabbitmq.client.ShutdownSignalException: channel error; protocol method: #method<channel.close>(reply-code=403, reply-text=ACCESS_REFUSED - operation not permitted on the default exchange, class-id=40, method-id=10)
    Am i doing some thing wrong
    Andrea Tarocchi
    @valdar
    @leonardogolfeto please use https://camel.zulipchat.com/ as this room is not more active.
    Vaibhav Bansal
    @vaibhavflip
    hi guys, i have a route containing a loop. when graceful shutdown happens, this route keeps on running because of this loop and does not get interrupted till forceful shutdown. Is there a way to interrupt this loop on shutdown
    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