They are 2 different eip patterns.
recipient list is dynamic as it computes the endpoints at runtime
based on an expression.
multicast is static where you define the endpoints at design time
They both send a copy of the same message to N+ destinations.
Recipient list can send to 0 .. N endpoints,
Maybe try setting disconnect=true to not keep the connection alive
between polls. As you have a 60 sec delay between then the connection
may timeout or some other issue etc. If you disconnect after done then
you create a new connection on next poll.
On Mon, Nov 11, 2013 at 6:27 AM, Bharath wrote:
There is a getRouteDefinitions that gives you the model of the routes.
And for performancce metrics etc you can use JMX
http://camel.apache.org/camel-jmx.html
On Mon, Nov 11, 2013 at 7:34 AM, CamelTyro <328549...@qq.com> wrote:
> After startuping the camel context, how to get the infomation of a
You can use Camel error handling to retry
http://camel.apache.org/error-handling-in-camel.html
But since your route input is from ActiveMQ you can also use
transactions, and let ActiveMQ do the redelivery, as that would
preserve the message in the broker, in case of a crash etc.
Camel error handl
Hi,
I have a simple route say from(ftp).to(ftp).Here files are moving
properly from source to destination and after some time am getting
2013-11-11 07:59:47,285 | WARN | abc.com/extern | RemoteFileProducer
| t.file.remote.RemoteFileProducer 71 | 102 - org.apache.camel.camel-c
After startuping the camel context, how to get the infomation of a router.
e.g.
I start the camel by Spring. by injecting, I can get the camelContext
instance, defined in the spring configuration files.
Then I get the list of route by context.getRoutes();
By interating each route object, I can g
Hi,
I just created a JIRA[1] of it, we should let user set the default routing key
on the producer.
[1]https://issues.apache.org/jira/browse/CAMEL-6952
--
Willem Jiang
Red Hat, Inc.
Web: http://www.redhat.com
Blog: http://willemjiang.blogspot.com (http://willemjiang.blogspot.com/)
(Englis
I send message to active mq using Main class
Main class - this will fire automatically generated String messages to the
* "corsoft.BroadcastMessageQueue" running on the local ActiveMQ broker
(as defined in
* application.properties).
public class StartDemo {
public class StartDemo {
How did you send the message to ActiveMQ?
--
Willem Jiang
Red Hat, Inc.
Web: http://www.redhat.com
Blog: http://willemjiang.blogspot.com (http://willemjiang.blogspot.com/)
(English)
http://jnn.iteye.com (http://jnn.javaeye.com/) (Chinese)
Twitter: willemjiang
Weibo: 姜宁willem
I suggest you don’t create the such large scope converter, it may introduce
some side effect to camel.
String —>List should be OK.
--
Willem Jiang
Red Hat, Inc.
Web: http://www.redhat.com
Blog: http://willemjiang.blogspot.com (http://willemjiang.blogspot.com/)
(English)
http://jnn.
Hi,
I think you can take a look at DeadLetter DSL[1].
[1]http://camel.apache.org/dead-letter-channel.html
--
Willem Jiang
Red Hat, Inc.
Web: http://www.redhat.com
Blog: http://willemjiang.blogspot.com (http://willemjiang.blogspot.com/)
(English)
http://jnn.iteye.com (http://jnn.jav
It make sense that create a new camel context per test take more time if you
just restart the camel context.
As you are not change the camel route setting differently for each test, so it
should be OK for you just stop and start the camel context before and after the
test.
--
Willem Jiang
R
Hi,
I’m not sure if you ran the test after you started the whole build. It looks
like the bundle plugin wasn’t called.
I suggest you to run “mvm clean install -Dtest=false” from the root and then
run the test.
--
Willem Jiang
Red Hat, Inc.
Web: http://www.redhat.com
Blog: http://willemjiang
Hi,
I think you may need to recompile the route instead of just change the class
path when you move to use Camel 2.12.1.
--
Willem Jiang
Red Hat, Inc.
Web: http://www.redhat.com
Blog: http://willemjiang.blogspot.com (http://willemjiang.blogspot.com/)
(English)
http://jnn.iteye.co
If you want camel-cxf send the exception back to you, you can assert the to get
the example from the template response.
If you just want to test the error handling of the route, you can add a mock
endpoint after the onException, to make sure you go the exception there.
--
Willem Jiang
Red Ha
Hey, i am wondering how testing exception throwing in junit.
I have my mock endpoint defined and the exchange received with a processor
that throws an error.
Now the template.sendBody on the endpoint does throw an error but still has
a normal exchange message.
How can i do this last part to ass
Hi
Camel-Fabric is only provided in Fuse. If you don’t want to use Fuse, you have
to implement the services publish and locator yourself.
--
Willem Jiang
Red Hat, Inc.
Web: http://www.redhat.com
Blog: http://willemjiang.blogspot.com (http://willemjiang.blogspot.com/)
(English)
http
So far all my test projects use sockets or HTTP endpoints; each client
wishing to communicate with another server (or service) needs to know all
the available network addresses of each implementation (e.g. a list of
protocols, host name & ports).
To fix this, I remembered a suggestion made by a us
Hi,
I'm trying to use transacted route with Camel 2.12.1.
This is just a little example to test transacted() method:
public static void main(String args[]) throws Exception {
// create CamelContext
CamelContext context = new DefaultCamelContext();
// add our r
Hi,
I'm trying to execute a single test in camel main (github) and the test
fails because of a ClassNotFoundException:
org.apache.camel.core.xml.AbstractCamelEndpointFactoryBean.
Here the command i use:
[luca@juniper apache-camel]# mvn -Dtest=*BindyComplexCsvUnmarshallTest* test
...
Tests in erro
hello,
I was wondering about the use of the DirtiesContext-annotation at the
class-level. According to http://camel.apache.org/spring-testing.html, it
"forces Spring Testing to automatically reload the CamelContext after each
test method - this ensures that the tests don't clash with each other".
R
Hi Christoph,
thanks for your feedback.
If I understand correctly you are suggesting to implement this on top
of standard message filtering[1] and I think it's a good idea.
So I could write a custom Predicate[2] and build a route like this:
from("direct:start").
filter().MY_PREDICATE("MO
Hi Lorenzo,
very interesting approach that you’ve been posing out there. I just wonder, if
there is really a component necessary to integrate the date / time function, or
if it might be better to implement an approach via the simple DSL.
To me it seems that you are filtering exchange messages a
Hi,
I just created this very simple component to allow/suspend a service at
certain times.
https://bitbucket.org/nottrz/when
Any feedback is welcome.
Bye
Lorenzo
So, after reading some documentation and getting a lot of help from you guys
here, I finally implemented a recipient list that choose the endpoints
dynamically (a dynamic recipient list):
http://camel.apache.org/recipient-list.html
http://camel.apache.org/recipientlist-annotation.html
In my code,
Yes you can do git pull requests from github as any other github project.
https://github.com/apache/camel/
When doing a pull request
https://github.com/apache/camel/pulls
The only thing we cannot do is to pull and close. And the creator of
the pull request would have to close the pull request man
26 matches
Mail list logo