There are some really good clustering frameworks out there that I've
used in the past to do this kind of thing. Either of following would
be perfect. If you do implement something you might consider donating
it as it would make a nice addition. ;)
http://www.jgroups.org/
or
https://shoal.dev.java.
Hi
I think you are looking for a general problem with load balancing
multiple servers.
Its not Camel specific etc. So I think you should look for a more
broad solution.
Often to put a load balancer in front of your servers which can detect
if a server is down, and redirect to good servers.
On T
Hi,
I have primary camel server running which can read in data from various
sources, transform data and then write to new datastore. I am trying to
figure out how I can implement fail over support if primary camel server
dies for some reason and secondary server should start reading from variou
Hi
Basically its spring JMS under the covers. So go google for how to use
Spring JMS with BEA WebLogic.
And ensure the queue you listen to is already created and exists in
BEA JMS, as it may not support creating queues on demand, as AMQ does.
On Mon, Mar 8, 2010 at 10:52 PM, anandsk wrote:
>
>
Hi
You need to configure the startup order of your routes so the timer is
the last one to be started
http://camel.apache.org/configuring-route-startup-ordering-and-autostartup.html
On Mon, Mar 8, 2010 at 11:27 PM, boday wrote:
>
> I have a polling consumer setup to periodically (using camel-tim
Hi
Content Enricher EIP is the pattern your are looking for.
On Tue, Mar 9, 2010 at 1:53 AM, Tapdur wrote:
>
> Hi all,
>
> i have newbie question relative to EIP pattern, i don't see wich one
> correspond to my pb.
> (to simplify) :
>
> i send an order to "direct:order"
>
> from (direct:order
Hi,
I just checked the code of DirectProducer , DirectConsumer,
DirectEndpoint, the code should be thread safe, unless you stop the
route dynamically.
So please check if you choice a right director endpoint name first.
Willem
Stephen Gargan wrote:
Not to harp about the endpoint uri but I ju
Hi,
I think you just need to set up route like this
from("direct:order").to("http:///...";).to("direct:printOrder")
Or you need to set the MessageExchangePattern of the Exchange to be
InOut[1], if you don't want to change the route.
[1]http://camel.apache.org/request-reply.html
Willem
Tapdu
Hi Jim,
It should be easy to implement your requirement by adding a type
converter which can help use turn the List into a String.
I filled a JIRA[1] for it.
[1]https://issues.apache.org/activemq/browse/CAMEL-2531
Willem
Jim Talbut wrote:
Thank Willem,
The first problem I've found with usi
Hi,
For your first question, you may take a look at the code of
MessageSupport copy() and copyFrom().
For the second question, it's the stream caching issue, we disable the
stream caching by default in Camel 2.x to improve the performance, and
you can enable it as you want[1]
[1]http://cam
Not to harp about the endpoint uri but I just want to get them correct
so I can try and reproduce. In one you have direct:decode and and in
others direct:decoder. Are they consistent in your code?
thanks
ste
On Mon, Mar 8, 2010 at 5:03 PM, boday wrote:
>
> yes, the retry does work fine 99% of t
yes, the retry does work fine 99% of the time...randomly we see this error
after many successful retries of of other messages, etc...
-
Ben - Senior Consultant
using SMX 3.3.1/Camel 2.1
--
View this message in context:
http://old.nabble.com/DirectProducer---no-consumers-available-on-endpoin
Hi all,
i have newbie question relative to EIP pattern, i don't see wich one
correspond to my pb.
(to simplify) :
i send an order to "direct:order"
from (direct:order")
.to(direct:generateOrder-id)
.to(direct:printOrder);
from(direct:generateOrder-id")
.to(http:///...)
from(direct:pri
You say
"Every now and then, I get the following warning in my logs...
WARN - DirectProducer - No consumers available on endpoint:
Endpoint[direct://Decoder]"
This wouldn't happen to coincide with your timer would it? Does the
polling consumer ever succeed or does it always giv
sorry, the '::' was a typo in my post only...
the route works fine during normal execution...basically the following
from('activemq:inbound')
.to('direct:decode');
from('direct:decode')
.convertBodyTo(DOMSource.class)
.process(new DecodeProcessor())
.process(new ValidateProcessor())
.process(ne
Do you have something listening on the direct endpoint? How do you
have it configured? I see you've an extra colon in the endpoint uri
here; Does the route consuming this direct endpoint also use
"direct::Decoder" or just "direct:Decoder".
Are you using a single camel context? If you post the dire
I have a polling consumer setup to periodically (using camel-timer) retry
messages from an error queue.
like this...
//initialized in constructor of polling consumer
private static ProducerTemplate producer = context.createProducerTemplate();
...
Exchange exchange = consumer.receive("activemq:e
try adding this to camel context file. create DefaultJMSConFactory in
weblogic if doesn't exist already.
asindic wrote:
>
> Hi,
> I'm having problems getting a simple producer/consumer application with
> Weblogic, everyth
Thank Willem,
The first problem I've found with using PAYLOAD is that the Tracer
(which I was using with JPA) is no longer logging the full message contents.
This is because it calls toString on the inbound message, but that is
now a CxfPayload, which contains a List and Element.toString()
doe
Hi,
I'm having problems getting a simple producer/consumer application with
Weblogic, everything works fine with AMQ.
There is one queue (topic), a JmsComponent and a RouteBuilder with a route
like this
from("jms:requestQueue").process(new Processor() {}
The producer is working fine, putting
Hello all,
Note: I am using Camel 2.0
I have recently create a custom component that consumes text off a telnet
session, packages it into a Message class extended from DefaultMessage. The
messages are sent down a route through 3 processors. The problem I am
having is that after the first proce
Hi,
I opened a JIRA for this issue. Can you please let me know if there is any
workaround for this issue?.
https://issues.apache.org/activemq/browse/CAMEL-2530
Thanks,
Aanand
--
View this message in context:
http://old.nabble.com/java.net.MalformedURLException%3A-unknown-protocol%3A-c-tp2782429
Hi
You also need quartz.jar itself. If you are using Maven all that is
taken care of.
Basically you need whats listed as compile here
[INFO] The following files have been resolved:
[INFO]aopalliance:aopalliance:jar:1.0:test
[INFO]com.sun.xml.bind:jaxb-impl:jar:2.1.12:compile
[INFO]co
On Mar 5, 2010, at 8:28 AM, Charles Moulliard wrote:
> In the camel jms documentation, it is mentioned that when we would
> like to use Durable Topic Subscription, the limitation that we have is
> that we can only consume message through one JMS connection (so one
> thread) :
>
> "If you wish to
I'm trying to get a Quartz timer up and running. I included
camel-quartz-2-2-0.jar and the two .jars
camel-core.jar and the commons-collections.jar as stated on this page:
http://camel.apache.org/maven/camel-quartz/dependencies.html
from("quartz://report?cron=0+0+6+*+*+?")
.to("file://data");
Hi Norman,
I can reproduce you issue by use the ConsumerTemplate to get the
message, and I filled a JIRA[1] for it.
[1]https://issues.apache.org/activemq/browse/CAMEL-2529
Willem
Norman Maurer wrote:
Hi William,
will try the test later today when I have the code around. At the
moment I wo
Am using vm already.
Claus Ibsen-2 wrote:
>
> Hi
>
> Try to do it in pure Camel, eg using seda, direct, vm etc and not the
> NMR or SMX.
>
>
> On Thu, Mar 4, 2010 at 2:38 PM, lekkie wrote:
>>
>> I saw this and I completely understand it.
>> my problem is not that router1 is waiting for init
27 matches
Mail list logo