On 10/14/10 3:58 AM, Donald Whytock wrote:
Hi all...
If I have a SEDA endpoint set up for not multiple consumers and I use
createConsumer(processor), will that replace the current consumer? Or
simply add a consumer that will never be reached?
Don
The option of support the multiple consumers
Maybe your InternalMessage is not full copied.
Can you just create a new copy of internalMessage in the modify method
and set it to the message body after the modification ?
BTW, you can change the wireTap uri to a log endpoint, it could be easy
track the message.
Willem
On 10/12/10 7:36 PM
On Thu, Oct 14, 2010 at 3:23 PM, Willem Jiang wrote:
> st create a new copy of internalMessage in the modify method and set it to
> the message body after the modification ?
So, Camel will use the same instance across Camel routes?
I failed to replace the message into getIn().setBody() with the
Hi
Did you have chance to go through these document[1]?
You need to add some @Converter,@FallbackConverter annotations and
update the file of META-INF/services/org/apache/camel/TypeConverter.
[1]http://camel.apache.org/type-converter.html
On 10/11/10 2:59 PM, Madhav Bhargava wrote:
Hi All,
There is no Thread.sleep() call in the camel-snmp. So I guess you are telling
the ScheduledPollConsumer's delay time by setting the delay option from URI.
You can find more information about camel-snmp component here[1]
[1]http://camel.apache.org/snmp.html
Willem
ganges_k wrote:
>
> Hi,
>
>
On 10/14/10 4:39 PM, Muhammad Ichsan wrote:
On Thu, Oct 14, 2010 at 3:23 PM, Willem Jiang wrote:
st create a new copy of internalMessage in the modify method and set it to
the message body after the modification ?
So, Camel will use the same instance across Camel routes?
I failed to replace
On Thu, Oct 14, 2010 at 4:06 PM, Willem Jiang wrote:
>> So, Camel will use the same instance across Camel routes?
>>
>> I failed to replace the message into getIn().setBody() with the
>> message clone. It triggers time out exception. May be it's because I'm
>> not quite understand about inOut tri
I see, thanks a lot
> Willem Jiang [mailto:willem.ji...@gmail.com]
> 2010年10月14日 14:34
> users@camel.apache.org
>Re: how about robust-stop and try stop strategy support of camel while stop
the application
I don't think current Camel can
The MEP is very important from outside camel. It tells camel if the producer
(client) who send the request is waiting for a response or not. Thus it allows
consumers to know what to do, but it is (almost) not relevant on the route
itself. It looks like I should have clarified this better.
Cheer
Thanks Willem Jiang
I agree to your comments. Camel's InOnly & InOut pattern does have their means,
and it's not just for optimize;
Because we understand MEP as such, I think the low level Processor should
always handle the MEP correctly, they should judge the MEP, and return the
result by In
monitor (and a few other
things). However, what directory to monitor depends on what day it is. E g
files that are processed are moved to an archive directory with a
subdirectory name with today's date ( e g ./archive/20101014).
I perform my actual monitoring in a custom processor. I would li
I posted on the developer forum (under the thread about JIRA 3223) but it
appears my post didn't get submitted or something. I think this bug is
related to what I'm seeing but it's more severe than what the JIRA ticket
describes.
Anyway, I'm having issues using the File component. Thinking it w
How did you run the test ?
I just test the the simple route with latest Camel 2.5 snapshot, the
file is moved into other directory without any issue.
On 10/14/10 8:50 PM, GSegel wrote:
I posted on the developer forum (under the thread about JIRA 3223) but it
appears my post didn't get submit
From the stack trace it looks like the GenericFileConverter is not be
loaded rightly.
Can you check the log for the type coverters are loaded rightly?
Here is is mine
Oct 14, 2010 10:34:31 PM
org.apache.camel.impl.converter.AnnotationTypeConverterLoader load
INFO: Found 3 packages with 13 @C
I'm not looking to add an additional consumer; I'm looking to replace
the existing one.
In my Chatterbot app, I'm looking to set up a pipeline of message
handlers in an osgi environment. I'll have a service that collects
message handlers and builds a pipeline from them. But since message
handler
( e g ./archive/20101014).
I perform my actual monitoring in a custom processor. I would like to
configure this using the simple language, e g like this:
# Directory to monitor
directory=./archive/${date:now:MMdd}
I've been using the simple language before as part of the route. However
; other
>> things). However, what directory to monitor depends on what day it is. E g
>> files that are processed are moved to an archive directory with a
>> subdirectory name with today's date ( e g ./archive/20101014).
>>
>> I perform my actual monitoring in a
Camel documentation shows how to implement
http://camel.apache.org/message-router.html Message Router pattern . In my
case the given examples are not sufficient. I have tens, and may be hundreds
of out endpoints, and complicated routing logic that is dynamic and can
change at runtime. The Proces
An option is to use a ProducerTemplate from your processor, have a
look here - http://camel.apache.org/producertemplate.html
On Thu, Oct 14, 2010 at 1:52 PM, serega wrote:
>
> Camel documentation shows how to implement
> http://camel.apache.org/message-router.html Message Router pattern . In my
Hi, take a look at the routing slip pattern[1] or the dynamic router. I
think you need the dynamic router.
On 10/14/2010 07:52 PM, serega wrote:
> Camel documentation shows how to implement
> http://camel.apache.org/message-router.html Message Router pattern . In my
> case the given examples
Hi Sergey,
Messages flow along a route that can be statically or dynamically configured.
If I understand you correctly there are 2 things you could look at. One is the
dynamic router [1] (and related routing slip [2]) that allows you to make
decisions at runtime about how your messages flow. T
Hi,
thanks for the quick replies.
The Dynamic Router is exactly what I need.
Sergey.
--
View this message in context:
http://camel.465427.n5.nabble.com/Custom-Router-tp3212534p3212586.html
Sent from the Camel - Users mailing list archive at Nabble.com.
Okay, potentially answering my own question, perhaps DelegateProcessor
would serve for me...
List processors = new ArrayList;
/* add some processors */
DelegateProcessor delegate = new DelegateProcessor(new Pipeline(processors));
Inside a RouteBuilder...
from("seda:queue").process(delegate);
Anyway I have attatched a patch you can use if and when you want.
Some notes
1. Pubsub nodes are not created by the producer. They have to be created
manually before starting producer/consumer.
2. SASLAuthentication should support other authentication mechanisms.
3. Collections with node's is no
On Wed, Oct 13, 2010 at 12:24 PM, ext2 wrote:
> Hi:
> It seems the camel's graceful shutdownis just like the requirement "robust
> stop application": give a waiting time, force stop, and do it's best
> ability to avoid lost message;
>
> But the camel cannot support "try to stop" interface; isn't
On Thu, Oct 14, 2010 at 6:43 AM, ext2 wrote:
> I still feel it's a bug; let's give a sample as following:
>
>
>
>
>
>
>
>
> While writing the aggregator, how does I know where the result stored, in or
> out message? I can only determine it by exchange pattern;
> If the r
You can provide the completion conditions as headers, so that means
you can customize this dynamic.
The aggregator has pluggable API for persistent store, so you can
develop you own. Or use camel-hawtdb.
On Wed, Oct 13, 2010 at 11:10 PM, Leen Toelen wrote:
> Hi,
>
> I am in need for a customized
Hi,
In our application we have a routing slip that is configured at runtime to
invoke endpoints from "plugin" camel routes (camel 2.3) that are provided in
a separate camel context. We are using smx 3, so these plugins are packaged
as separate JBI assemblies.
I'm trying to work out the best met
Hi Steve,
On Thu, Oct 14, 2010 at 4:05 PM, slew wrote:
>
> Hi,
>
> In our application we have a routing slip that is configured at runtime to
> invoke endpoints from "plugin" camel routes (camel 2.3) that are provided in
> a separate camel context. We are using smx 3, so these plugins are packag
Hi Stan,
Thanks for the response and clarifying the blocking queue question, makes
perfect sense now.
I feel more comfortable about continuing with the JBI endpoints now, so
thanks again. One difficulty I'm having (i've posted this on the smx forum
today, so sorry if this counts as a repost), b
You can call stop() to terminate a route. If you wrap this in a condition
that check if the body is null or you can avoid routing messages to your
'foo' queue. This pattern is called 'message filter' and an example is
available at http://camel.apache.org/message-filter.html (scroll down to
"using
In Camel 2.5.0，you can do it by stopping old route which start with the
SEDA endpoint and adding a new route for it.
Here is an unit test[1] that you can take a look.
[1]
https://svn.apache.org/repos/asf/camel/trunk/camel-core/src/test/java/org/apache/camel/component/seda/SedaMultipleConsumers
Hi,
Thanks for the contribution.
Can you create a JIRA[1] and submit the patch ? In this way we can keep
tracking the issue easily.
BTW, maybe we could let servicemix bundle repo to load the specification
version of smack.
[1]https://issues.apache.org/activemq/browse/CAMEL
On 10/15/10 3:13
I'm following this route configuration example to implement a REST service:
http://camel.apache.org/cxfrs.html
I get the following exception when the route is being started. Any ideas?
Caused by: org.springframework.beans.factory.BeanCreationException: Error
creating bean with name 'restService
Hi,
From track trace it looks like you don't put the
cxf-rt-soap-binding.jar into your class path.
As you said you are using CXFRS enpdoint, so I can't tell what's wrong
with it.
How did you CXFRS, CXF endpoint?
Can I have a look at your configuration?
On 10/15/10 9:54 AM, coolgold wrote:
I
35 matches
Mail list logo
