Hi Salemi,
Typically you can use content based router to categorize the messages.
http://camel.apache.org/content-based-router.html
Regards
Guru
@gnanagurus
--
View this message in context:
Hi
In JMS you can use message groups for ordering
http://activemq.apache.org/message-groups.html
On Wed, Jul 10, 2013 at 5:59 AM, salemi sal...@avaya.com wrote:
Hi,
I like to implement a mechanism in Camel to receive message from a JMS
queue. Once I have identified the type of message based
Hi everybody,
I use Camel 2.11, Java DSL.
I would like to use Camel Test, but I have a problem.
/import org.apache.camel.test.junit4.CamelTestSupport;
public class TestCamelProcess extends CamelTestSupport {
...}/
= The hierarchy of TestCamelProcess is inconsistent.
The error is occur in the
Hi ,
while performing load testing on the following route I am getting these
error for *some *messages
from(netty:tcp://0.0.0.0:7000?textline=true)
.bean(MainDummyProcessor.class)
.to(netty:tcp://0.0.0.0:7001?textline=true).to(netty:tcp://0.0.0.0:7004?textline=true)
Hi!
Claus Ibsen-2 wrote
This is working as designed.
When using the enricher EIPs then the idea is that having the original
message and the new message to combine these into a original message
that is enriched with information from the new message.
I see. Any idea how would you handle
What kind of message body types do you have?
The copy is a shallow copy so it shouldn't be expensive.
On Wed, Jul 10, 2013 at 10:42 AM, solimo rob...@budzko.eu wrote:
Hi!
Claus Ibsen-2 wrote
This is working as designed.
When using the enricher EIPs then the idea is that having the
Hi,When we use log EIP with http, we observe a strange behaviour. The body of
the message is getting lost after it does logging.
public class LogTest extends CamelTestSupport {@Overrideprotected
RouteBuilder createRouteBuilder() throws Exception {return new
RouteBuilder() {
Hi
See this FAQ
http://camel.apache.org/why-is-my-message-body-empty.html
On Wed, Jul 10, 2013 at 12:01 PM, vss123 vss...@gmail.com wrote:
Hi,When we use log EIP with http, we observe a strange behaviour. The body of
the message is getting lost after it does logging.
public class LogTest
Hi,
Iam using CamelSpringTestSupport class to write my JUnit.
But in one scenario i want to use PowerMock too.
If i use PowerMock with CamelTestSupport its giving following error
Error:
java.lang.IllegalStateException: Failed to transform class with name
Hello Willem,
Thanks for the reply.
We have following two jars in the classpath:
1. camel-scala-2.11.0.jar
2. camel-scala_2.9-2.11.0.jar
Can you please let me know if you are referring to the above two jars.
Thank you,
Regards
vkarkhanis
--
View this message in context:
Hi,
I'm trying to create an error handler that sends messages to a DLQ, sends
events to riemann and logs the error with a stack trace. I have done something
like the following.
public RiemannSendProcessor extends SendProcessor {
public void process (Exchange exchange, AsyncCallback callback)
Which Scala version do you use?
Best,
Christian
Sent from a mobile device
Am 10.07.2013 12:34 schrieb vkarkhanis vkarkha...@gmail.com:
Hello Willem,
Thanks for the reply.
We have following two jars in the classpath:
1. camel-scala-2.11.0.jar
2. camel-scala_2.9-2.11.0.jar
Can you please
Hello,
Frankly, we don't use Scala at all ! We just wanted to switch to camel 2.9.0
to 2.11.0 and would still be java.
Thank you,
Regards
vkarkhanis
--
View this message in context:
http://camel.465427.n5.nabble.com/Camel-2-11-0-TypeConverterLoaderException-tp5735404p5735432.html
Sent from
Than remove these both jar files and try again.
Best,
Christian
Sent from a mobile device
Am 10.07.2013 13:16 schrieb vkarkhanis vkarkha...@gmail.com:
Hello,
Frankly, we don't use Scala at all ! We just wanted to switch to camel
2.9.0
to 2.11.0 and would still be java.
Thank you,
Regards
Thanks for your reply. I have already found how to fix this problem.
I extended DefaultHttpBinding and overridden populateRequestParameters()
method. It couldn't use removeHeaders() in camel dsl because header which
contains request body didn't have static name.
There were such code:
String[]
Oops.. right..
Thank you :)
--
View this message in context:
http://camel.465427.n5.nabble.com/Log-processor-loses-message-tp5735417p5735436.html
Sent from the Camel - Users mailing list archive at Nabble.com.
You could have one (and only one) JMS message listener for each kind of
message and use JMS message selector to let one thread select some kind of
messages while leaving other ones. Each listener thread will consume ordered
messages of one kind, each listener will separately from others.
--
I have an http endpoint consuming a *multipart* request, and I would like to
split the corresponding camel message in order to get a list of InputStream
with the different parts.
I tried the following:
But I do receive the raw multipart body.
Is there an *easy* way to split it, without the
In a servlet 3.0 environment, I could exploit the getParts() method on the
servlet request:
http://docs.oracle.com/javaee/6/api/javax/servlet/http/HttpServletRequest.html#getParts()
and do the split like this:
But, unfortunately, I'm stuck to servlet 2.5 :-(
--
View this message in context:
Awesome thanks. Timeout is what I am using and it seemed to be waiting for
inactivity, which I wanted, but I wanted to make sure.
On Tue, Jul 9, 2013 at 11:52 PM, Claus Ibsen claus.ib...@gmail.com wrote:
Hi
There is 2 timer related options
- timeout
- interval
The former is based on
Hi everybody,
I use camel 2.11, java dsl.
/import org.apache.camel.test.junit4.CamelTestSupport;
public class TestCamelProcess extends CamelTestSupport {
...}/
Which JAR should I import to use CamelTestSupport?
I have imported camel-test-2.11.0.jar but it's not enough.
I download these jar
Hi All,
I have a Camel Proxy that pushes BeanInvokation exchanges to a camel
route, and I want to route these messages depending on the method name that
is invoked.
Is there any way to extract this information and put into an header so to
use it in a choice?
For example, considering the
mmm, it seems that simple${body.method.name}/simple works:
setHeader headerName=methodName
simple${body.method.name}/simple
/setHeader
Any comment about this solution? (is it good?)
What happens if the body is not of class
org.apache.camel.component.bean.BeanInvocation?
Is there a way to check
Hi,
I am having an issue with configuring a JMS route with onException. With a
route defined similar to that below, when an exception occurs, the message
is properly sent to myDLQ. But, when there is a transaction timeout due to
the longRunningProcessor taking too long, the message cannot be sent
Ok i found a solution
1) enable multipart filter on the endpoint
2) use @Attachments annotation
--
View this message in context:
http://camel.465427.n5.nabble.com/How-to-split-a-multipart-http-request-tp5735438p5735457.html
Sent from the Camel - Users mailing list archive at Nabble.com.
Can you submit a simple test case to show the error?
BTW, I just checked code of InterceptSendToMockEndpointStrategy, it has the
construction with the parameter list of (java.lang.String,boolean).
Can you check if you have more then one version of camel-core in you class path?
--
Willem
You need add camel-core.jar at same time.
--
Willem Jiang
Red Hat, Inc.
FuseSource is now part of Red Hat
Web: http://www.fusesource.com | http://www.redhat.com
Blog: http://willemjiang.blogspot.com (http://willemjiang.blogspot.com/)
(English)
http://jnn.iteye.com
Hi Frazer,
you can get access the exception from the exchange property:
Exchange.EXCEPTION_CAUGHT
HTH
Bilgin
On 10 July 2013 11:53, Frazer Irving frazer.irv...@mailonline.co.uk wrote:
Hi,
I'm trying to create an error handler that sends messages to a DLQ, sends
events to riemann and logs
Fantastic, thank you
On 10/07/2013 17:13, Bilgin Ibryam bibr...@gmail.com wrote:
Hi Frazer,
you can get access the exception from the exchange property:
Exchange.EXCEPTION_CAUGHT
HTH
Bilgin
On 10 July 2013 11:53, Frazer Irving frazer.irv...@mailonline.co.uk
wrote:
Hi,
I'm trying to create
There is a ? operator, so you can do
simple${body?.method?.name/simple
Then it will be null if the body if the body doesnt have a getMethod().getName()
There is also a bodyAs(type) to use the Camel type converter.
On Wed, Jul 10, 2013 at 4:48 PM, Cristiano Costantini
I've encountered a problem with an FTP Client using passive mode where the
Control Port is being closed by a network device between the host and
client. Some individuals suggested that I try using active mode and that
seemed to work, but I notice an intermittent problem with files not being
,
I would need exactly that, but I've tested sending a string with a producer
template and I got this error:
Failed to invoke method: ?.method?.name on null due to:
org.apache.camel.language.bean.RuntimeBeanExpressionException: Failed to
invoke method: method on null due to:
Hello,
I am writing a simple module to FTP files to a remote server. I am using a
properties file to read the ftp info such as server, username, password etc.
ex: here's how my properties file looks like:
ftp.protocol=ftp
ftp.host=localhost:2121
ftp.path=files
ftp.username=admin
Hello,
I have an endpoint defined as:
to id=file.to.data-decrypted
Is there a way to find out which CSV file that is currently being processed?
I mean I have a couple of CSV files and I do not know the name of those CSV
files. All I know is their structure. If it was XML, I can identify the file
structure using xpath. Is there something similar that I can do for
Thank you for the responds.
The problem I have is that I don't have any control of producer and I can't
ask the producer to put information in the header of the message in order to
use the grouping of ActiveMQ.
-
Alireza Salemi
--
View this message in context:
You can use $simple{ xxx } as well as the syntax
On Wed, Jul 10, 2013 at 7:10 PM, Chris Wolf cwolf.a...@gmail.com wrote:
Hello,
I have an endpoint defined as:
to id=file.to.data-decrypted
Thank you! that worked, I used:
fileName=$simple{file:onlyname.noext}.$simple{id}
On Wed, Jul 10, 2013 at 2:57 PM, Claus Ibsen claus.ib...@gmail.com wrote:
You can use $simple{ xxx } as well as the syntax
On Wed, Jul 10, 2013 at 7:10 PM, Chris Wolf cwolf.a...@gmail.com wrote:
Hello,
I have
Then why don't you do something like:
The route from JMS to Seda is monothreaded, but it should be fast enough
(the bottleneck is javaspaces, is it?), then each route from Seda to
Javaspaces can work in parallel.
--
View this message in context:
I would convert the CSV file into a ListMaplt;String,String, each row
being a MapString,String, the first String being the column header name.
Unfortunately Camel CSV unmarshals to ListListlt;String and Camel Bindy
looks too strict for your case (unmarshalls to ListJavaBean). So I would
code my
Ok. So seems like routes can't be updated. But an existing route can be
deleted and a new route added at runtime.
http://camel.465427.n5.nabble.com/Update-camel-route-at-runtime-using-config-admin-td4965455.html
That kind of answers my question.
Thanks.
--
View this message in context:
This is specific to camel 2.11.0. Done file deletion worked as expected in
2.10.0
Scenario:
I have a fileConsumer configured for a directory with done files. It is
expected that every file dropped in the directory has a filename.done
file.
In both 2.10.0 and 2.11.0 files are consumed
You need to shutdown the template if you don't want to use it anymore.
--
Willem Jiang
Red Hat, Inc.
FuseSource is now part of Red Hat
Web: http://www.fusesource.com | http://www.redhat.com
Blog: http://willemjiang.blogspot.com (http://willemjiang.blogspot.com/)
(English)
Thanks.
I edit the source.
SpringCamelContext context = (SpringCamelContext)
applicationContext.getBean(contextId);
context.start();
ProducerTemplate template = context.createProducerTemplate();
template.sendBody(endPoint, message);
context.stop();
context.stop() works the way I want it to.
44 matches
Mail list logo
