I'm sorry, I don't mention it rightly.
NettyProducer closes all the open channels when it is stopped. context.stop
will shutdown the routes, consumers and producers.
If you don't want to shutdown the CamelContext to close the channel, you can
set the option disconnect to be true.
--
Willem
Hi
No this is currently not support by data formats. Though we have a
JIRA ticket to allow bridging data formats from a component, in a
future release.
Then you can use recipient list, eg something a like
dataformat:json:unmarshal?unmarshalType=${bean:foo?method=getPOJOClass
Currently you c
If you pickup files using the file component, then the message headers
contains file name information.
http://camel.apache.org/file2
On Wed, Jul 10, 2013 at 7:07 PM, Jothi wrote:
> Is there a way to find out which CSV file that is currently being processed?
> I mean I have a couple of CSV files
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.
I just checked the change log, it looks like the patch of CAMEL-5883 didn't
address the batch issue well.
So I just reopen the JIRA[1] for it.
[1]https://issues.apache.org/jira/browse/CAMEL-5883
--
Willem Jiang
Red Hat, Inc.
FuseSource is now part of Red Hat
Web: http://www.fusesource.com |
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)
http://jnn
* camel 2.11.0
* netty 3.6.5.Final
I make a simple main method to try out a simple message with Netty producer.
The message is well sended, but my application is not exit and tcp
connection is not closed.
How do I close TCP connections and shutdown my application gracefully?
sendMessage("cam
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 .done
file.
In both 2.10.0 and 2.11.0 files are consumed successfully when co
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:
http
I would convert the CSV file into a List>, each row
being a Map, the first String being the column header name.
Unfortunately Camel CSV unmarshals to List> and Camel Bindy
looks too strict for your case (unmarshalls to List). So I would
code my own data format to do the conversion CSV -->
List> usi
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:
http://camel.465427.n5.nabble.com/Incoming-mess
Thank you! that worked, I used:
fileName=$simple{file:onlyname.noext}.$simple{id}
On Wed, Jul 10, 2013 at 2:57 PM, Claus Ibsen wrote:
> You can use $simple{ xxx } as well as the syntax
>
> On Wed, Jul 10, 2013 at 7:10 PM, Chris Wolf wrote:
>> Hello,
>>
>> I have an endpoint defined as:
>>
>> >
You can use $simple{ xxx } as well as the syntax
On Wed, Jul 10, 2013 at 7:10 PM, Chris Wolf wrote:
> Hello,
>
> I have an endpoint defined as:
>
>
> uri="file://{{jboss.server.data.dir}}?idempotent=true&preMove={{jboss.server.data.dir}}/holding/${file:onlyname.noext}.${id}&move={{jboss.se
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:
http://camel.465427.n5.nabble
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 C
Hello,
I have an endpoint defined as:
Which throws this exception:
Caused by: org.springframework.beans.factory.BeanDefinitionStoreException:
Invalid bean definition with name 'file.to.data-decrypted' defined in
null: Could not resolve placeholder 'id'
at
org.springframework.beans.fa
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
ftp.password=adm
,
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:
org.apache.camel.c
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
pulled
There is a ? operator, so you can do
${body?.method?.name
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
wrote:
> mmm, it seems that "${body.m
Fantastic, thank you
On 10/07/2013 17:13, "Bilgin Ibryam" 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
>wrote:
>
>> Hi,
>>
>> I'm trying to create an error handler that sends
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 wrote:
> 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
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 (http://jnn.javaey
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 Jiang
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.
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
mmm, it seems that "${body.method.name}" works:
${body.method.name}
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 if body is of the right instance?
Many thanks!!!
Cristiano
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 ?
For example, considering the following
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 here
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 wrote:
> Hi
>
> There is 2 timer related options
> - timeout
> - interval
>
> The former is based on inactivity, and 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:
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
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.
--
View
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.
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[] p
Than remove these both jar files and try again.
Best,
Christian
Sent from a mobile device
Am 10.07.2013 13:16 schrieb "vkarkhanis" :
> 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
> vkarkhani
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 the
Which Scala version do you use?
Best,
Christian
Sent from a mobile device
Am 10.07.2013 12:34 schrieb "vkarkhanis" :
> 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 kn
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)
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:
http://camel.465427
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
org.apache.camel.test.junit4.CamelTestSu
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 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 extends CamelTestS
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() {
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 wrote:
> Hi!
>
>
> Claus Ibsen-2 wrote
>> This is working as designed.
>>
>> When using the enricher EIPs then the idea is that having the original
>> m
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
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")
.bean(MainDummyProcessor
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
47 matches
Mail list logo
