Hi,
for easier reading logs I'd like to append db record id to the
exchange id, but it only works in current route. After the exchange is
sent to queue, the appended part is lost
from("direct:source")
.setBody("id from DB)
.process(exchange->
exchange.setExchangeId(exchange.getExchangeId(
nnot use
> exchange id, as its transient.
>
> You can use the breadcrumb-id, and plugin a different uuid generator in
> Camel.
> http://camel.apache.org/mdc-logging.html
>
>
> On Wed, Nov 29, 2017 at 2:40 PM, Dennis Holunder <[hidden email]> wrote:
>
>> Hi,
>
uot;special id"
>
> On Wed, Nov 29, 2017 at 4:45 PM, Dennis Holunder <[hidden email]> wrote:
>
>> but as far as I understand uuid generator doesn't have access to the
>> current exchange, so there is no way to append my id from body to the
>> exchange id o
le to access my
> current exchange as well.
>
> On Wed, Nov 29, 2017 at 5:19 PM, Dennis Holunder <[hidden email]>
> wrote:
>
>> Well, at least in my case its much easier to overwrite the exchange id
>> in each route part.
>>
>> 2017-11-29 17:10 GMT+01:0
be transferred over the wire which
> is supported out of the box.
>
> And don't change the exchange id, that is not really for end users to
> change, but for the component/camel to setup initially.
>
>
>
> On Thu, Nov 30, 2017 at 9:07 AM, Dennis Holunder <[hidden email]
Hi,
I'm trying to resend failed messages for delayed reprocessing via
helper seda queue. If the body of failed exchange wouldn't be very
big, then I'd use redelivery methods available in camel. But having
too many failing exchanges leads to OOM errors. So, instead of default
retrying I'll resend t
Hello,
I'm using zookeeper route policy for leader selection on 8 instances
of my route and get sometimes 2 leaders selected. What I'm doing wrong
here?
String uri = "zookeeper:srv1:2181,srv2:2181,srv3:2181/myapp/myroute";
ZooKeeperRoutePolicy policy = new ZooKeeperRoutePolicy(uri, 1);
policy.se
Is there any documentation or example usage of zookeeper-master component?
2018-01-09 13:17 GMT+01:00 Claus Ibsen-2 [via Camel]
:
> Try the zookeeper-master component - it should be better
>
> On Tue, Jan 9, 2018 at 12:55 PM, Dennis Holunder <[hidden email]> wrote:
>
>>
com/apache/camel/blob/master/components/camel-zookeeper-master/src/main/docs/zookeeper-master-component.adoc
>
> And its also covered in the CiA2 book in the clustering chapter.
>
> On Tue, Jan 9, 2018 at 1:38 PM, Dennis Holunder <[hidden email]> wrote:
>
>> Is there any
ot("/route/root");
master.setGroupName("myGroup");
from("quartz:cron").noAutoStartup().routePolicy(master).log("done");
2018-01-09 16:51 GMT+01:00 Claus Ibsen-2 [via Camel]
:
> Yeah I think it does. Can you give it a try, and we can improve the docs.
>
>
INFO o.a.camel.impl.DefaultCamelContext - Total 9
routes, of which 8 are started
09:11:33 [main] INFO o.a.camel.impl.DefaultCamelContext - Apache
Camel 2.20.1 (CamelContext: camel-1) started in 0.348 seconds
2018-01-10 9:43 GMT+01:00 Dennis Holunder :
> Tried. Leader selection with MasterRoutePolicy didn't wor
018-01-09 16:51 GMT+01:00 Claus Ibsen-2 [via Camel]
:
> Yeah I think it does. Can you give it a try, and we can improve the docs.
>
> On Tue, Jan 9, 2018 at 4:47 PM, Dennis Holunder <[hidden email]> wrote:
>
>> thank you!
>> Does it support multiple zookeeper comma-sep
Hello,
Is there a way to reset throughput logger? I have a cron job and for
each run it should reset the throughput statistics
- D
section 16.5.2.
>
>
> On Tue, Feb 6, 2018 at 2:33 PM, Dennis Holunder <[hidden email]> wrote:
>> Hello,
>>
>> Is there a way to reset throughput logger? I have a cron job and for
>> each run it should reset the throughput statistics
>>
>> - D
&
Hi guys,
having setup with 3 zookeeper servers the zookeeper master policy
works fine if one of clients is gone and the new master is then
selected. But what will happen if one or two of zookeeper servers are
gone and only one is still available? For example, if client is
connected to zookeper1 an
t; have 3, you need 51%+ to be up and running, eg 2 nodes.
> So if you lose 2 nodes, and only have 1 then zk is in zombie mode
> (cant recall what they call this situation) and wont function, you
> need to bring up at least 1 more node to have a quorum.
>
>
>
>
> On Wed, Fe
Hello,
I need a CSV record mapper which would use maps, but ordered ones,
because I need the name of the first header field. Current
implementation creates HashMaps, where the original order is lost.
I tried to implement my own CsvRecordConverter to produce ordered map,
but the interface is not p
; Can you point to where it creates HashMap, maybe we can change that to
> LinkedHashMap.
>
> On Wed, Mar 7, 2018 at 12:08 PM, Dennis Holunder <[hidden email]> wrote:
>
>> Hello,
>>
>> I need a CSV record mapper which would use maps, but ordered ones,
>>
implementation. You
> would need to report this to them.
>
> Sadly there is no way to get the mapping on CSVRecord so we can get
> the column headers (we could maybe do some reflection as workaround).
>
> On Wed, Mar 7, 2018 at 3:29 PM, Dennis Holunder <[hidden email]&
r is a public interface from camel-csv. You can
> implement your own, and configure on the dataformat
>
> On Wed, Mar 7, 2018 at 4:26 PM, Dennis Holunder <[hidden email]> wrote:
>
>> But you could make CsvRecordConverter public, so I could implement the
>> mappe
Hi,
I have multiple seda queues in my route, all with blockWennFull=true
and limited size. In logs I can find the IllegalStateException:
08:33:04 [Camel (camel-1) thread #56 - seda://worker] ERROR deadletter
Exchange[ExchangePattern: InOnly, BodyType: com.Model,
CaughtExceptionType: java.lang.Ill
cer do not have blockWhenFull=true enabled.
>
> And what version of Camel do you use?
> On Tue, Sep 11, 2018 at 8:55 AM Dennis Holunder <[hidden email]> wrote:
>
> >
> > Hi,
> >
> > I have multiple seda queues in my route, all with blockWennFull=true
> >
nfigurations as it sounds like
> that producer do not have blockWhenFull=true enabled.
>
> And what version of Camel do you use?
> On Tue, Sep 11, 2018 at 8:55 AM Dennis Holunder <[hidden email]> wrote:
>
> >
> > Hi,
> >
> > I have multiple seda queues in
> Twitter: @oscerd2
> Github: oscerd
>
>
>
>
>
>
> On Tuesday, September 11, 2018, 9:55:35 AM GMT+2, Dennis Holunder <[hidden
> email]> wrote:
>
>
>
>
>
> Looks like there is new option offerTimeout which causes to ignore
> blockWhenFull:
>
Hi,
according to the seda documetation
https://github.com/apache/camel/blob/master/camel-core/src/main/docs/seda-component.adoc
the default size value is 2147483647. However I observe that it will
actually default to 1000, which is the default value of queueSize
option. Source code of SedaEndpoint
Hello,
I have two onException definitions which catch exceptions and send
them to direct:logerrors endpoint. The second exception might throw an
exception which should be caught and handled by the first one. But
this doesn't work. The FatalFallbackErrorHandler kicks in and as the
result the except
Hello,
I have 2 instances of the route which are using zookeeper to make sure
that only one instance is doing the job at 11:15am. Yesterday
instance1 started but not fully completed the job and today after the
restart of instance1, instance2 became the master and resumed the job
from yesterday. Is
ner
> On Tue, Nov 13, 2018 at 10:23 AM Dennis Holunder <[hidden email]> wrote:
>
> >
> > Hello,
> >
> > I have two onException definitions which catch exceptions and send
> > them to direct:logerrors endpoint. The second exception might throw an
> >
operty before the
> persist, and then retrieve it afterwards when you do the persist.
>
>
> On Fri, Feb 8, 2019 at 9:59 AM Dennis Holunder <[hidden email]> wrote:
>
> >
> > Hi Claus,
> >
> > I was able to redesign the route, so that works as I want. In that
Hi all,
is it possible to use one master route policy to control master
selection for multiple routes inside one application? I need two
routes to be active but only if the application is on the master node
MasterRoutePolicy policy = new MasterRoutePolicy();
from("quartz2://r1?cron=0+0+15+?+*+*"
Hi,
I'm trying to migrate a CDI Route to camel-3 and seeing in log that
the route is starting graceful shutdown right after start.
12:04:00 [main] INFO o.a.camel.impl.DefaultCamelContext Apache Camel
3.0.0 (CamelContext: camel-1) started in 3.683 seconds
12:04:00 [main] DEBUG o.a.c.c.quartz.Qua
]
:
>
> Hi
>
> You can try to debug and set a breakpoint and see maybe if there is
> some way to know.
>
> Also how do you run your cdi app.
>
> On Thu, Dec 5, 2019 at 1:10 PM Dennis Holunder <[hidden email]> wrote:
>
> >
> > Hi,
> >
> > I'
g and set a breakpoint and see maybe if there is
> > some way to know.
> >
> > Also how do you run your cdi app.
> >
> > On Thu, Dec 5, 2019 at 1:10 PM Dennis Holunder <[hidden email]> wrote:
> >
> > >
> > > Hi,
> > >
> > > I'
> 2019-12-05 14:56:02,063 [4 - timer://foo] INFO route1
> > - running
> > processing
> > 2019-12-05 14:56:07,040 [4 - timer://foo] INFO route1
> > - running
> > processing
> >
> > On Thu, Dec 5, 2019 at 2:19 PM Dennis Holunder <[hidd
me. If I run it from IDEA then it
> > > keeps running.
> > >
> > > However the stacktrace you had had quartz in it, which this .zip do not
> > > etc.
> > >
> > >
> > > 2019-12-05 14:56:01,039 [main ] INFO DefaultRoutesCollector
> >
mel-cdi (that component is a bit
> bloated.)
>
> On Thu, Dec 5, 2019 at 3:36 PM Dennis Holunder <[hidden email]> wrote:
>
> >
> > its because routes are removed and stopped in
> > DefaultModel::addRouteDefinitions method. Stop triggers shutdown task
> >
I have some class hierarchy to share common functionality but it
doesn't work with camel-3:
2019-12-06 10:20:35,959 [ngupInterceptor] INFO
MainSupport$HangupInterceptor - Received hang up - stopping the main
instance.
org.apache.camel.FailedToStartRouteException: Failed to start route
route3 beca
Thank you, Claus! I think, it might be also due to a class hierarchies
I have, but see my next mail about that.
Am Fr., 6. Dez. 2019 um 09:20 Uhr schrieb Claus Ibsen-2 [via Camel]
:
>
> On Fri, Dec 6, 2019 at 9:00 AM Dennis Holunder <[hidden email]> wrote:
> >
> > I re
t;
> On Fri, Dec 6, 2019 at 10:23 AM Dennis Holunder <[hidden email]> wrote:
>
> >
> > I have some class hierarchy to share common functionality but it
> > doesn't work with camel-3:
> >
> > 2019-12-06 10:20:35,959 [ngupInterceptor] INFO
> >
ints that can have multiple consumers.
>
> So it may be that 2.x didnt detect this somehow.
>
>
> On Fri, Dec 6, 2019 at 10:55 AM Dennis Holunder <[hidden email]> wrote:
>
> >
> > Ok. It was without custom main BTW. I just modified official camel-cdi
> > examp
Hello,
I've migrated an app to camel 3 which works fine in IDE, but starting
fat jar produces the errors like: java.lang.NoClassDefFoundError:
com/lmax/disruptor/EventTranslatorVararg. The approach works with
camel 2.22 version
I'm using latest weld-se-shaded, deltaspike-cdictrl-weld and
maven-sh
gt;
> See this FAQ
> https://camel.apache.org/manual/latest/faq/how-do-i-use-a-big-uber-jar.html
>
> uber-jar self made are on your own. And it's a hazzle to do. The JARs
> have files in META-INF/services which you need to ensure all of them
> gets shaded, and whatelse.
>
&g
Hi,
in my route I have to evaluate configuration of cron parameters at
runtime. With Camel 2.x it worked, but in camel 3
QuartzEndpoint.getTriggerParameters returns empty map. Is this a bug
or is there another way to get trigger parameters?
In Example below it should contain timeZone parameter,
Hello,
with camel we can schedule quartz cron jobs in a given timezone. Is
this supported in camel quarkus?
Thanks!
cify exactly the
> same set of options.
>
> Il giorno mer 18 mar 2020 alle ore 14:40 Dennis Holunder <
> [hidden email]> ha scritto:
>
> > Hello,
> >
> > with camel we can schedule quartz cron jobs in a given timezone. Is
> > this supported in camel quar
Hello,
is it possible to test a non-http route in camel-quarkus like we do
with CamelTestSupport in camel?
Thanks!
I could create a quarkus test where the route is injected and external
endpoint is mocked with quarkus mock support.
Am Fr., 20. März 2020 um 11:52 Uhr schrieb Dennis Holunder
:
>
> Hello,
>
> is it possible to test a non-http route in camel-quarkus like we do
> with CamelTestS
ay also be able to inject a ProducerTemplate in the test to feed the
> route directly.
>
> Alex
>
> On Wed, Mar 25, 2020 at 7:55 AM Dennis Holunder <[hidden email]>
> wrote:
>
> > I could create a quarkus test where the route is injected and external
> > endpoin
Hi,
I followed camel-example-micrometer (v2.22.2) and see only jvm metrics
under localhost:8088/metrics
and no metrics from the route direct:bar below. How to make these
available in /metrics output as well?
from("netty4-http:http://0.0.0.0:8088/metrics";)
.routeId("netty
Solved. The example was for spring which works and in cdi I solved it
by producing composite registry with added PrometheusMeterRegistry
Am Do., 18. Juni 2020 um 13:10 Uhr schrieb dennisholu [via Camel]
:
>
> Hi,
>
> I followed camel-example-micrometer (v2.22.2) and see only jvm metrics
> under lo
Hi,
tried camel-quarkus-examples-timer-log-main in Intelij and it fails to
start with:
Caused by: java.lang.IllegalArgumentException: The supplied
'main-class' value of
'org.apache.camel.quarkus.main.CamelMainApplication' does not
correspond to either a fully qualified class name or a matching 'n
Hello!
Is there a way to cancel a delay in progress?
.delay(new Expression() {
@Override
public T evaluate(Exchange exchange, Class type) {
return (T) getCurrentDelay();
}
})
for example if the current delay expression returned one hour, but
after a few minutes it is not nee
Hello!
The route below runs into NPE while packaging a project:
@ApplicationScoped
public class MyRoute extends EndpointRouteBuilder {
@Inject
MyProcessor myProcessor;
@Override
public void configure() {
from("direct:start").process(myProcessor::process); }
@ApplicationScoped
Hello,
What is the correct way to block on a "direct" route until completion?
In the route below I must ensure only one instance of "direct:process"
route running. In other words, "direct:process" must not run in
parallel, because of some state
from("timer://first?period=1000")
Hello,
I have some @ApplicationScoped and @Traced Beans which methods are
called from the camel route (camel-quarkus). The traces are sent to
jaeger, but they don't have a common parent span. How can I start a
span for an exchange, so that all subsequent calls to the beans would
have the same pare
Hello,
I have some project containing dependencies:
com.sun.xml.bind:jaxb-core:3.0.0,
com.sun.xml.bind:jaxb-impl;3.0.0,camel-quarkus-fop
to generate some xml to be consumed by pdf engine.
After upgrading from quarkus 1.13.2 to 2.0.0 or later the code doesn't
compile anymore:
'package com.sun.xml.
Downgrading to jaxb-impl;2.3.0 solved the problem
Am Mi., 25. Aug. 2021 um 15:57 Uhr schrieb Dennis Holunder
:
>
> Hello,
>
> I have some project containing dependencies:
> com.sun.xml.bind:jaxb-core:3.0.0,
> com.sun.xml.bind:jaxb-impl;3.0.0,camel-quarkus-fop
> to generate so
57 matches
Mail list logo
