Hi
This is not possible. A seda consumer is always active, so you cannot
really share a thread among seda endpoints.
So in your example, there will always be 1 + 3 active seda consumers,
that will take up 4 threads. The thread pools created by the seda
endpoints will be fixed sized. So that means
On Wed, Feb 15, 2012 at 5:11 PM, Antoine DESSAIGNE
wrote:
> Hi everyone,
>
> I'm rather new to Camel and so far I'm loving it.
>
> Right now I have to put my Groovy code within tags. Is it
> possible to use an external .groovy file instead ?
>
We could possible improve the scripting language in
Hi
The language component can load scripts from files/classpath
http://camel.apache.org/language
On Wed, Feb 15, 2012 at 5:11 PM, Antoine DESSAIGNE
wrote:
> Hi everyone,
>
> I'm rather new to Camel and so far I'm loving it.
>
> Right now I have to put my Groovy code within tags. Is it
> possi
Hi
Just to be sure you have this class on the classpath?
org.milyn.SmooksException
On Wed, Feb 15, 2012 at 5:29 PM, Laurentiu Trica
wrote:
> Hello,
>
> I have a problem using the try/catch in Camel Spring DSL.
>
> I have this route:
>
>
>
>
>
>
> org.milyn
Hi
See this question on stackoverflow
http://stackoverflow.com/questions/9283861/camel-exception-handling-doesnt-work-if-exception-clause-is-defined-in-a-separat
On Tue, Feb 14, 2012 at 9:35 PM, anand sridhar wrote:
> Hello,
> I am trying to build a application with several camel routes which re
On Wed, Feb 15, 2012 at 9:25 AM, Willem wrote:
> Hi,
>
> It looks like there are some short coming of the Zip data format which
> doesn't support to combine the files together.
Yes the zip data format does not support files per see. For that we
would need to improve the data format.
As you would
Hi
We should get rid of the WARN logging by JBoss. Although it ought to
be harmless.
I have logged a ticket
https://issues.apache.org/jira/browse/CAMEL-5010
On Wed, Feb 15, 2012 at 7:07 PM, dvsridhar
wrote:
> I am experiencing similar problem here.
> I am using Camel 2.9.0 and Latest Jboss (jb
Hi
See for example about using interceptors
http://camel.apache.org/intercept
On Wed, Feb 15, 2012 at 5:33 PM, balsmn
wrote:
> hi all,
>
> I have a destination by name "testQueue", to which messages sent, all have a
> custom header in encrypted form. Before, consumers of this destination,
> rec
On Thu, Feb 16, 2012 at 4:48 AM, Ellen wrote:
> Hi there!
>
> I'm new to Camel and we have to use Camel 2.6.
> I have a simple route which receives BytesMessage and needs to send to
> external system as TextMessage. I have tried set jmsMessage=Text on the
> endpoint to the external system, but the
thanks, great.
I'll have to upgrade to 2.9, though, as the documentation states the
asyncConsumer property does not yet exist in 2.8.1.
On Wed, Feb 15, 2012 at 3:25 PM, Claus Ibsen-2 [via Camel] <
ml-node+s465427n5486036...@n5.nabble.com> wrote:
> On Tue, Feb 14, 2012 at 3:23 PM, ShlomiJ <[hidde
Babak, Ashwin, thanks for your reply.
As I understand, it is technically impossible to do publish/subscribe
messaging using VM component between different contexts, but possible within
one. And there are other preferable technics to do that, for example through
JMS, NMR, etc. Am I right?
--
View
Hi there!
I'm new to Camel and we have to use Camel 2.6.
I have a simple route which receives BytesMessage and needs to send to
external system as TextMessage. I have tried set jmsMessage=Text on the
endpoint to the external system, but the external system still receives
BytesMessage. Dose anyone
It depends on where do you want to decrypt the header.
If you want to do it before sending, you can add a Processor[1] or
Bean[2] to do the work.
If you want to do it before consumer receives the message, you need to
find other way to do it.
[1]http://camel.apache.org/processor.html
[2]http:
Babak,
Thanks for such informative reply. Would like to add there is one full
chapter dedicated for handling transactions with camel in 'Camel in Action'
book by Claus, et al.
peace,
On Wed, Feb 15, 2012 at 6:54 PM, Babak Vahdat
wrote:
> Hi
>
> Given your use case using XA you're definetly on t
No, if you are using MESSAGE dataformat, you just reuse the CXF
transport, it doesn't read any conent of message.
PAYLOAD and POJO dataformat can do the work that you want.
On Thu Feb 16 03:46:34 2012, Castyn wrote:
I have a CXF bean setup for a route that listens for incoming messages on a
jet
I'm not sure if the JBoss7 support the OSGi out of box.
Maybe you need to ask the question in the JBoss7 community to find out
if you need to any addition work.
On Thu Feb 16 02:07:14 2012, dvsridhar wrote:
I am experiencing similar problem here.
I am using Camel 2.9.0 and Latest Jboss (jboss-
Hi
Given your use case using XA you're definetly on the right way! What you
need is a *global* transaction and not a *local* one as you need the
orchestration of the transaction boundries along the way through JMS
together with your DB.
If you would make use of local transaction managers, let's s
Hi all, two weeks into using camel in earnest and loving it already :)
One point of confusion though...I have a very simple route, message off of a
queue and into a database (using a DAO type bean though in preference to the
JDBC component). If the write to the db fails I want to take a few attemp
Hi,
If you are using the camel-smpp component, then I checked the code and it is
indeed multi-threaded...
Cheers,
Ashwin...
-
-
Ashwin Karpe
Apache Camel Committer & Sr Principal Consultant
FUSESource (a Progress Software Corporation s
Thanks a lot.
-Original Message-
From: Ashwin Karpe [mailto:aka...@fusesource.com]
Sent: Thursday, February 16, 2012 12:07 AM
To: users@camel.apache.org
Subject: Re: Threads in SMPP ,,,
Hi,
I am not sure if this is a homegrown component you have written. I will try
to speak to the behav
Hi,
I am not sure if this is a homegrown component you have written. I will try
to speak to the behavior of Camel as it generally applies to components and
routes in general.
The Camel context allocates a thread pool from which components, endpoints,
routes and other lifecycle managed entities bo
I have a CXF bean setup for a route that listens for incoming messages on a
jetty port. The data format of the bean is in MESSAGE mode. My question is
this, if someone sends an invalid message (whether it is malformed XML,
improper types, etc), will the be the
component that actually creates the
Dears ,
I need to bind as receiver to SMS and wait for SMS to come into my camel , is
it supporting threading ? can we have the receiver from SMSC (from (smpp://) to
support multi threading ? or it depends on camel threads like mina tcp.
Thanks,
Omar Atia
I am experiencing similar problem here.
I am using Camel 2.9.0 and Latest Jboss (jboss-as-7.1.0.CR1b). I am trying
to deploy one of camel examples "camel-example-cxf-tomcat". Using maven
package i created the war and when i tried deploying it gives the same error
what the other user has described.
Sure thing... Glad I could help.
Cheers,
Ashwin...
-
-
Ashwin Karpe
Apache Camel Committer & Sr Principal Consultant
FUSESource (a Progress Software Corporation subsidiary)
http://fusesource.com
Blog: http://opensourceknowledge.blogsp
hi all,
I have a destination by name "testQueue", to which messages sent, all have a
custom header in encrypted form. Before, consumers of this destination,
receive a message, I need to decrypt this header.
is there any camel way of doing it ? or doing it with the help of ActiveMQ
plugin is the o
Hello,
I have a problem using the try/catch in Camel Spring DSL.
I have this route:
org.milyn.SmooksException
http://www.edigrid.de}dpd-wurth-endpoint:T-800"/>
When I use it I get this erro
Hi everyone,
I'm rather new to Camel and so far I'm loving it.
Right now I have to put my Groovy code within tags. Is it
possible to use an external .groovy file instead ?
Thanks a lot,
Antoine.
Hello Ashwin!
thanks a lot for your comment! I think with the ScheduledRoutePolicy I can
solve my problem :)
I really didn't know the routes have such a feature!
Awesome!
Thanks again ;)
--
View this message in context:
http://camel.465427.n5.nabble.com/Reading-all-messages-from-ActiveMQ-in-pre-
Hi,
Hmm, This goes to whether routes are kinda self-directed, i.e., inability to
produce messages to a destination brings down the route itself...
While perfectly do-able, provided the consumer endpoint provides a
capability to do so via a flag/switch, I would rather not employ this
strategy. It
Hi,
Have you taken a look at ScheduledRoutePolicy support in Camel
(CronScheduledRoutePolicy and/or SimpleScheduledRoutePolicy)
Depending on what your requirements are, you spin up and spin down routes as
if they were batch jobs on a given schedule.
http://camel.apache.org/scheduledroutepolicy.h
Hi,
As mentioned in the earlier message by Babak, you can achieve the same
effect by creating a single route with multipleConsumers in a single
context.
The Test you have created adds additional lifecycle management and
processing overhead for no good reason...
Cheers,
Ashwin...
-
---
Hi Ashwin,
Thanks for the tip.
If I have access to the Consumer, can I just call
`consumer.getExceptionHandler().handleException(new
ConnectException(...))`?
Alex
On 15 February 2012 18:00, Ashwin Karpe wrote:
> Hi,
>
> Since the Camel endpoint has no way of knowing whether the service is up
Hi,
Since the Camel endpoint has no way of knowing whether the service is up
other than a ConnectException being thrown, you would need to trap this
Exception and then do whatever you need to do through the Exception handling
mechanism.
You could set up a Processor in the exception handling route
HI Willem Jiang ,
Thanks for replying ..
I found the issue. The issue was that I was using
"System.out.println("response is "+ exchange.getOut().getBody());"
instead I should have used "System.out.println("response is "+
exchange.getIn().getBody());"
getOut and getIn was the issue.
Also the
Not sure why are you trying to use cxfrs to send the request to google.
First, google doesn't provide the REST service,
Second, you need to prepare the parameter for the cxfrs to send.
Can you try to use the camel-http component to send the request ?
On Wed Feb 15 21:54:23 2012, atg roxx wrote:
Hi,
I'm working on an Endpoint which has a background service keeping it alive.
When this service fails, I would like the associated Exception (or a
derived Exception) to propagate to Camel so that it can be dealt with.
In the application I am working on, the behaviour in this case would
be to d
Hi
Check the documentation for the *exact* semantics of the multipleConsumers
option. Given your example each of the given vm consumers (actually it's
SedaConsumer as "VmComponent extends SedaComponent") will *compete* for
getting that *single* exchange your're sending, and depending which one
get
Hi,
I asked a question about JMS and transaction and had the following answer :
Spring Transaction does not support using multiple threads. The
transactional work should be done in the same thread, from spring TX
manager point of view.
I have some difficulties to understand why resequencer suppor
Hi All.
I am facing a issue. I am trying to connect to rest service and want to
process the response which I receive.
But I was not getting any response.
So I thought to try simple connection to google and see if any response
comes from there.
strange that I am not even getting any response fro
On Wed, Feb 15, 2012 at 11:11 AM, 4ndrew wrote:
> Hi,
>
> Is it possible to create a javadoc like documentation for camel Routes? Any
> suggestion? I'd like to generate a doc which describes the actual Routes in
> a method, not the method itself.
> Any help would be greatly appreciated! Thx!
>
Th
hi I am new user to camel.
I have tried an example by loading router from xml file. I have done it
successfully. My code is here.
JAXBContext jaxb =
JAXBContext.newInstance(Constants.JAXB_CONTEXT_PACKAGES);
Unmarshaller unmarshaller = jaxb.createUnmarshaller();
Resource
On Tue, Feb 14, 2012 at 3:23 PM, ShlomiJ wrote:
> *Solved!* sort of...
>
> The problem was that the JMS queue got filled with messages *before* any
> consumer was available.
>
> When the consumers were finally started, by initiating the to:activemq
> endpoint, all existing messages in the JMS queu
On Tue, Feb 14, 2012 at 10:01 AM, Samruben wrote:
> Hi
> I have seen some simplerouterfromxml java file in the link
>
> http://svn.apache.org/viewvc/camel/trunk/tests/camel-itest/src/test/java/org/apache/camel/itest/jaxb/SpringLoadRouteFromXmlTest.java?view=markup&pathrev=1040085
>
> whether I nee
Of course, here it is.
public class OutgoingAggregationStrategy implements AggregationStrategy {
/**
* Aggregates the messages.
*
* @param oldExchange
*the existing aggregated message. Is null the very
*first time as the
Hello!
I'm trying to create multiple listeners to one vm queue in different camel
contexts. My code looks like this:
public class VMTest
{
public static void main(String[] args) throws InterruptedException,
Exception
{
final CamelContext context = new DefaultCamelContext();
Hi,
Is it possible to create a javadoc like documentation for camel Routes? Any
suggestion? I'd like to generate a doc which describes the actual Routes in
a method, not the method itself.
Any help would be greatly appreciated! Thx!
-Andrew
--
View this message in context:
http://camel.465427.
Hi
The behaviour you're observing has nothing to do with Camel itself but the
underlying JMS-Provider [1] which has many configuration options like for
the Dispatching-Policy as well.
Most probably if you would switch to another Provider (like IBM WebSphere
MQ) you would observe another behaviour
Hi
Thanks for the hint, I updated the Wiki:
https://cwiki.apache.org/confluence/display/CAMEL/Resequencer
And the Camel site itself should get automatically updated later on today.
Babak
--
View this message in context:
http://camel.465427.n5.nabble.com/Resequencer-EIP-tp5482502p5485605.html
Hi,
concerning the Stream Resequencing, the default value for the capacity is
1000 (see org.apache.camel.model.config.StreamResequencerConfig).
The documentation could be updated accordingly to the code.
Regards
Hervé
On Wed, Feb 15, 2012 at 10:18 AM, Hervé BARRAULT
wrote:
> Hi,
>
> In your d
Hi,
In your documentation i see for the Stream Resequencing :
"This sets the resequencer's capacity to 5000 and the timeout to 4000 ms
(by default, the capacity is *100* and the timeout is 1000 ms).
Alternatively, you can provide a configuration object."
With the test it seems that there is a cap
Hi,
It looks like there are some short coming of the Zip data format which doesn't
support to combine the files together.
BTW, I'm still interesting about the agggregatorStrategy that you use.
Can you show me the code ?
Willem
--
FuseSource
Web: http://www.fuseso
52 matches
Mail list logo
