Hello,
I need to restart the camel context with a quartz at fixed interval.
But when I do context.stop() and then context.start() inside quartz
processing; the context stop but doesnt start again...
Also, when I remotely invoke the JMX camel restart, it works.
Is this a normal behaviour?
Thanks.
Hello,
I have an exception handler on a route of queue. If I got an exception, I
want to put the exchange in a DLQ and stop totally the exchange.
But, I put the message in a DLQ, after x seconds I got an
ExchangeTimedOutException. I want to get rid of this. How can i do that?
Here is a sample of
up
Le ven. 26 juil. 2019 à 16:08, Damien Nicolas a
écrit :
> Hmmm actually, if I add a queue, it just move the problem. Any idea?
>
> Le ven. 26 juil. 2019 à 14:46, Damien Nicolas a
> écrit :
>
>> Hello,
>> I have multiple sequential queues in InOut pattern,
Hmmm actually, if I add a queue, it just move the problem. Any idea?
Le ven. 26 juil. 2019 à 14:46, Damien Nicolas a
écrit :
> Hello,
> I have multiple sequential queues in InOut pattern, each queue leads to
> one processor.
> If a processor takes too much time for a treatment,
Writing my problem helps me to figure out how to solve it:
the message in q1 is injected from Spring and no queue for reply was
defined. I changed the exchange pattern of the q1 to InOnly, and now it
works.
Le ven. 26 juil. 2019 à 14:46, Damien Nicolas a
écrit :
> Hello,
> I have mu
Hello,
I have multiple sequential queues in InOut pattern, each queue leads to one
processor.
If a processor takes too much time for a treatment, I would like that the
request-reply detects a timeout and send a timeout exception.
The timeout with "*CamelJmsRequestTimeout*" works but only for the fi
Hello,
I have a set of processor and queue in this design:
q1 -> p1 -> q2 -> p2 -> ... -> qn -> pn
My queues are in InOut exchange pattern. I would like to know if it is
possible to get the ack for a queue after each processor consumption,
instead of having that after the last consumer (pn)?
Th
Hello,
I was using dynamicRouter to compute destination of messages through my JMS
queues routes.
Now, I want to replace these JMS queue routes by Kafka topics and still
using dynamicRouter to determine which route should consume a particular
messages.
*example:*
from(kafka:topic1).to(dynamicRoute
Hello,
I am trying Camel (2.21.0) with Kafka and something has not the behaviour
that I want:
I have a cluster of 3 Kafka nodes (1 leader, 2 for replication) for 1
partition and 1 topic, when I produce a message in my system, it is
correctly consumed with the Camel components.
But, when I kill th
Hello,
I am trying to inject a message in my camel business with the JMX API of
Artemis, with the method "sendTextMessage".
I added few personal headers on the message for my intern routing and
nothing else.
The principle of my business is the following :
If a my server is down (JBoss EAP 7.1), I
t?
Le ven. 5 avr. 2019 à 09:41, Zoran Regvart a écrit :
> Hi Damien,
> I think the point of the Camel and Wildfly integration is to have the
> lifecycle managed by the application server, from the excerpt you
> provided there is an additional lifecycle on top of that. I don'
Hello,
I am developping a CXF Rest service using Camel and deployed on a JBoss EAP
7.1 server.
My service works perfectly, but when I undeploy the application, the HTTP
server used for CXF is still active, so when I want to reupload my
application I get a "bind already exists..." exception.
Shutti
*EDIT:*
if I change
#java:jboss/datasources/test_db
by
#dataSource
I get:
org.apache.camel.RuntimeCamelException: java.lang.IllegalStateException:
Cannot obtain PGConnection
Le ven. 22 févr. 2019 à 09:25, Damien Nicolas a
écrit :
> Hello,
>
> I have a Camel backend running on a
correctly defined cause I use it with my service without
any problem.
What do i have to do to get rid of this error?
--
Damien NICOLAS
Claus: I removed that lines, cause you are right, there is no need to
create bean that will be mocked
Christian: I added it, and still the same issue..
Le lun. 5 nov. 2018 à 15:10, a écrit :
> Hi Damien,
>
> I don't know exactly about Mockito's Spy capabilities, but perhaps
Hello,
I would like to unit test a processor containing a service as an autowired
bean (*messageInformationService*). I would like to mock this bean to make
it return the data I want, but when I do that with Mockito, my service is
null.
*Here is my test class:*
public class GenerateCertificateTe
Ok.. I forgot to add the InOut pattern on my camel consuming queue.
Le ven. 19 oct. 2018 à 09:18, Damien Nicolas a
écrit :
> up
>
> Le mar. 16 oct. 2018 à 16:40, Damien Nicolas a
> écrit :
>
>> Hello,
>>
>> I have a Springboot war with Camel routes deployed
up
Le mar. 16 oct. 2018 à 16:40, Damien Nicolas a
écrit :
> Hello,
>
> I have a Springboot war with Camel routes deployed on a JBoss EAP 7.1
> server. The routes are generated dynamically and some of them have
> *concurrentConsumers
> > 1* because a route can have s
uot;xxx");
try (JMSContext context =
connectionFactory.createContext(userName, password)) {
context.createProducer().send(destination, m);
...
Is the problem comes about the fact there is less header properties
generated when I create manually the headers?? or something else???
Here is the difference between the header properties of the first version
of the project and the second one <https://pastebin.com/qvahstrq>
--
Damien NICOLAS
Hi Damien,
>
> Sorry for the late response, been a bit busy with Camel and Rabbit routes
> at work.
> Did you get this to work by any chance?
> If not, I think what's missing in your test setup is the @Bean
> declarations in your test context. In the pastebin example y
oct. 2018 à 13:04, Valdis Andersons a
écrit :
> Hi Damien,
>
> In your test you need specify the configuration your Camel context is
> supposed to use. This is how we're setting it up:
>
> @Override
> protected AbstractApplicationContext createApplicationContext
available: expected at
least 1 bean which qualifies as autowire candidate. Dependency annotations:
{@org.springframework.beans.factory.annotation.Autowired(required=true)}
Le lun. 1 oct. 2018 à 09:59, Valdis Andersons a
écrit :
> Hi Damien,
>
> We use Spring annotations in our integrati
ay to use Spring annotations but with the advantages of
CamelSpringTestSupport (by using createRouteBuilder())?
--
Damien NICOLAS
septembre 2018 14:56
À : users@camel.apache.org
Objet :Re: Using same queue multiple times in a circuit
Hi Damien,
from("jms:queue:queue1") reads messages once at a time.
Using from("jms:queue:q1?concurrentConsumers=2") may help but imply
consequences in terms of resourc
ner - Execution of JMS
message listener failed. Caused by: [org.apache.camel.RuntimeCamelException
- org.apache.camel.ExchangeTimedOutException: The OUT message was not
received within: 2 millis due reply message with correlationID:
ID:3730343344420000 not received.
How can I make it works without disabling jms replying?
--
Damien NICOLAS
uld you please provide some sample
code for this?
Regards
Damien
--
View this message in context:
http://camel.465427.n5.nabble.com/Only-same-instance-of-SSLContextParameters-is-supported-tp5752688p5752931.html
Sent from the Camel - Users mailing list archive at Nabble.com.
ssage failed to send is
only because the destination service is not available. But in the following
retries, the error just happens. Is it anything to do with catching?
Camel 2.12 seems to be breaking a lot of my existing code that have been
working with 2.8, especially recipientList.
Man
I've just test it with Camel 2.8, it's always good. What has been changed
with Camel 2.12?
Thanks
Damien
--
View this message in context:
http://camel.465427.n5.nabble.com/Only-same-instance-of-SSLContextParameters-is-supported-tp5752688p5752689.html
Sent from the Camel - Users ma
tatic uri, it is successful. I've another
component which has almost the same recipientList with dynamic url in
spring, it works also fine.
Any idea please?
Many thanks
Damien
--
View this message in context:
http://camel.465427.n5.nabble.com/Only-same-instance-of-SSLContextParameters-is-sup
this problem?
Thanks
Damien
--
View this message in context:
http://camel.465427.n5.nabble.com/recipientList-and-ExchangePattern-do-not-work-tp5751457.html
Sent from the Camel - Users mailing list archive at Nabble.com.
}
public class AttachmentAttacher {
private static Logger log = Logger.getLogger(AttachmentAttacher.class
.getName());
public void process(Exchange exchange) {
log.debug("damien: AttachmentAttacher sta
That's the problem, it works now! Thanks a lot
--
View this message in context:
http://camel.465427.n5.nabble.com/org-apache-camel-language-simple-types-SimpleIllegalSyntaxException-Binary-operator-is-does-not-supp1-tp5750642p5750645.html
Sent from the Camel - Users mailing list archive at Nabb
body is fine, but simple expression can't recognise
au.edu.mq.ClassA.
What could be wrong here?
Thanks
Damien
--
View this message in context:
http://camel.465427.n5.nabble.com/org-apache-camel-language-simple-types-SimpleIllegalSyntaxException-Binary-operator-is-does-not-supp1-tp5750642
We have plans to release the Splunk SDK for Java as an OSGI bundle.
http://splunk-base.splunk.com/answers/49450/splunk-java-sdk-as-osgi-bundle
As far as also hosting at maven central , I will enquire with the core
release team and get back to you.
Cheers.
--
View this message in context:
htt
Splunk is not open source , but it has a free license that you can use in
perpetuity to index up to 500MB of data per day. This free version has all
the features required to support Preben's components that are in development
on github, http://www.splunk.com/view/SP-CAAAE8W
The Splunk SDK for Java
35 matches
Mail list logo
