Hello,
This was originally posted in default Camel forum but I guess camel-users is
best.
Since we upgraded to anything from Camel 2.3 onwards, our InOut() routes are
mis-behaving ;)
After some long and painful debugging we realised that the Splitter()
pattern is causing the problem. The proble
Hi All,
Thanks for all the replies. I lost track of how this relates back to the
Splitter() issue. Is there still some debate about whether this is a bug or
a feature? ;)
Thanks
Andrew
--
View this message in context:
http://camel.465427.n5.nabble.com/Problem-with-Splitter-in-Synchronous-route
Here are our findings when upgrading beyond Camel 2.2
Here are some interesting observations during the testing of Camel 2.3.0
with synchronous "inOut()" in the route:
When using "direct:", no matter what you do, processing will always be
synchronous since "direct" is just a continuation of the
Hi,
I cannot find the class org.apache.camel.impl.GroupedExchange in the 2.1
download from the main camel download site. It is also missing from the
javadocs:
http://camel.apache.org/maven/camel-core/apidocs/index.html
Please can you check what happened to it? Really cool feature to have!
Than
Great, thanks, that did it!
Claus Ibsen-2 wrote:
>
> On Fri, Dec 18, 2009 at 11:18 AM, ee7arh
> wrote:
>>
>> Hi,
>>
>> I cannot find the class org.apache.camel.impl.GroupedExchange in the 2.1
>> download from the main camel download site. It is also m
Hi,
Actually still have a problem here.
We have an aggregator with batchSize(2) and want to aggregate them together
into a GroupedExchange. This seems to go through but the List that we get
out of the GROUPED_EXCHANGE property always has 1 object instead of 2.
Please could you check what we are
Hi,
Please correct documentation page with references to the new
CamelRedeliveryCounter header. It is inconsistent.
http://camel.apache.org/dead-letter-channel.html
The docs say "CamelRedeliveryCount" but the example says
"CamelRedeliveryCounter". I believe the example is correct.
Thanks
Andre
Hi,
When you have a route with mutliple concurrent consumers and this route
contains an aggregator, does the aggregator aggregate messages from all
consumer threads or is there in effect a separate aggregator per consumer
thread?
I have following route which is currently set to 1 concurrentCons
Hi,
I would like to invoke methods in my pojo classes from the ContentRouter
where the bean is an interface. However I get the error:
org.apache.camel.NoSuchBeanException: No bean could be found in the registry
for: serviceEventHandler
I have an interface with the @Service annotation at the top
Hi,
We are heavily using DSL routers to route messages from one bean to another
within our messaging application.
All the examples I find in the documentation using beans always show the
bean name and the method name as a string. This is fine and it works but
when we are debugging a DSL router a
Hi,
Simply put, I wish to produce SOAP objects onto a jms queue which can be
read by a remote consumer. I will have sent the WSDL file to the remote
consumer in advance (and will not publish the WSDL file via HTTP).
However I am not sure how to go about this since I will not need to create a
HTT
Hi,
I followed through the Tutorial for CXF using a JMS transport at following
link:
http://camel.apache.org/better-jms-transport-for-cxf-webservice-using-apache-camel.html
I modified it so that I publish my own service with it's own return types
and managed to get the server side working. I wo
Hi,
I'm getting quite into using the Camel DSL router and got quite far but now
have this situation:
I have a bean method (myBeanMethod1()) which returns not a boolean but a
real object (MyReturnObj1). This object contains an Enum return code
(myReturnCode) and I want to do some routing based on
to("jms:queue:error1Queue")
.when(body().convertTo(MyReturnCodeEnum.class).isEqualTo(MyReturnCodeEnum.ERROR_CODE_2))
.to("jms:queue:error2Queue")
I assumed in above example that the actual object on the "from" queue is the
MyReturnCodeEnum object now rather than the wrapping object MyRetu
ds
Andrew
Claus Ibsen-2 wrote:
>
> On Fri, Feb 27, 2009 at 5:22 PM, ee7arh
> wrote:
>>
>> Hi,
>>
>> I'm getting quite into using the Camel DSL router and got quite far but
>> now
>> have this situation:
> Welcome onboard the ride.
>
Hi,
Getting the following error when starting camel:
"This SpringBuilder is not being used with a SpringCamelContext and there is
no applicationContext property configured"
I am starting Camel from Spring by calling the camel Main class and passing
in a reference to my Spring XML file.
Within
Too add a bit more information
I found the code which throws this error in the camel source base:
public ApplicationContext getApplicationContext() {
+if (applicationContext == null) {
+CamelContext camelContext = getContext();
+if (camelContext instanceof Spr
Hi,
I have a bean defined which has 3 methods all with same name but with
different arguements. I would like to route messages from a queue to this
bean and depending on the object type I was hoping that the correct method
would get called by overloading.
Instead i get the error:
org.apache.cam
same bean method and ask it to take care of selecting
the correct one by overloading.
Thanks and Regards
Andrew
ee7arh wrote:
>
> Hi,
>
> I have a bean defined which has 3 methods all with same name but with
> different arguements. I would like to route messages from a queue to
Hi,
When I tryto use the functions "splitter()" or "multicast()" in my DSL
within a "choice()" block, I am not able to have another "when()" or even an
"otherwise()"
Predicate isInvitation
= PredicateBuilder.regex(header("event_type"), "invitation");
Predicate isReply
= Predicat
The reason is that I want to use Transactions and as far as I know, only
Spring supports this with PROPOGATION_REQUIRED.
Following line does not compile in standard RouteBulder:
Policy required
= new SpringTransactionPolicy(bean(TransactionTemplate.class,
"PROPAGATION_REQUIRED"));
If t
ent whether I'm thinking along the right lines here? It's a
key assumption for my design so would hate to be going in totally the wrong
direction!
Regards
Andrew
ee7arh wrote:
>
> Hi,
>
> When I tryto use the functions "splitter()" or "multicast()" in
Hi,
I have defined a series of routes in Camel which effectively routes messages
from queues, to bean processors and back to queues until at the very end the
message is written to a database and processing is complete.
My application ran out of memory after running for a while and when I
debugge
Hi,
Just a bit more info
I am still testing and waiting to see if the out-of-memory occurs again even
though i am setting now the jvm option: -Xmx32M -server
I am monitoring my application through jconsole and I notice the the number
of "loaded classes" continues to increase and increase.
Hi,
Thanks for response.
I'm using Camel 1.6.0 and ActiveMQ 5.2.0. I also had the same results with
camel 1.5 and activeMQ 5.1
I have attached a graph from Jconsole showing what happens as the
application starts, runs for a about 1.5 hours then crashes with out of
memory. http://www.nabble.com/
t; its fixed in 2.0m1.
>
> Could you either:
> - try without any JAXB
> - try with 1.6.1-SNAPSHOT or 2.0m1/2.0-SNAPSHOT
>
>
>
> On Thu, Mar 19, 2009 at 2:24 PM, ee7arh
> wrote:
>>
>> Hi,
>>
>> Thanks for response.
>>
>> I'm using Came
) When the nunber of classes in memory continues to increase until no more
memory is left...
Andrew
ee7arh wrote:
>
> Hi,
>
> Thanks but we are not using camel-jaxb, everything is being done manually
> using the JaxB classes directly (although now I see camel has this built
>
ow its AMQ loading the classes over and over
> again.
>
> Can you post your AMQ configuration?
>
>
> On Fri, Mar 20, 2009 at 11:30 AM, ee7arh
> wrote:
>>
>> Hi,
>>
>> I can confirm from JHat that only a sing
Hi,
I can confirm from JHat that only a single instance of the bean classes are
loaded:
1 instance of class com.ee.berbe.mobile.external.EventMarshalling
1 instance of class com.ee.berbe.mobile.external.EventRouter
1 instance of class com.ee.berbe.mobile.servicelogic.ServiceEventGenerator
1 inst
Hi again,
I added this component into my camel xml config and added a couple of extra
jar files from activemq to get it working:
I continued to use the id="jms" to avoid modifying all my routes.
Unfortunately, it did not make any difference. I left the application
running
Hi,
My application has continued to run now for almost a full 2 days with 256MB
and I have been connected to it continuously with jconsole via the camel JMX
component.
When I first looked at it this morning my first thought was "oh dear"
because memory heap was hovering dangerously close to the
Hi,
I would like to use the delayer pattern quite extensively to delay quite a
few messages for up to 6 hours. Is there anyway to see how many or even
which messages are currently delayed?
I am routing from a persistent queue to the delayer and then on to a bean. I
am worried that once a messag
runk and
1.x-branch.
Please check out Camel 1.6.1-SNAPSHOT or 2.0-SNAPSHOT for verifaction.
Willem
willem.jiang wrote:
>
> I see and just created a JIRA[1] to track your issue.
> It should be easy to fix :)
>
> [1] https://issues.apache.org/activemq/browse/CAMEL-1426
>
> W
Saw that this feature has been committed in Camel and targeted for release
2.9 :-)
So JMS inOnly will be able to take advantage of the asyncRedelivery option
Many thanks
--
View this message in context:
http://camel.465427.n5.nabble.com/asyncDelayedRedelivery-and-JMS-queues-tp3383826p4935509.ht
34 matches
Mail list logo
