Hi,
i'm using the ftp server example with my server, user.. and it works. Below
the output :
[INFO] --- exec-maven-plugin:1.1.1:java (default-cli) @ camel-example-ftp
---
2013-08-14 08:30:36,422 [tpServer.main()] INFO MainSupport
- Apache Camel 2.11.1 starting
Hi Williem,
it is not about periodicaly camel pull. It's about that how to pull more
than one URL by camel-rss component. I have the list od feed urls to pull in
single route.
Ziga
--
View this message in context:
http://camel.465427.n5.nabble.com/Camel-RSS-component-can-t-be-used-as-Producer
Hi
You need to keep your standalone application running.
See
http://camel.apache.org/running-camel-standalone-and-have-it-keep-running.html
The start method on camelContext is not blocking. So you can use the
Main class, or use other means of keeping the app running.
On Wed, Aug 14, 2013 at 9:5
Hi
Invoking start on the CamelContext is a non-blocking call, check links below
to see how to keep your standalone Camel application running:
http://camel.apache.org/running-camel-standalone-and-have-it-keep-running.html
http://stackoverflow.com/questions/1846791/camelcontext-start-doesnt-block
Did you have chance to check out the link of pulling consumer[1]?
you can pull the feed with ConsumerTemplate.
[1]http://camel.apache.org/polling-consumer.html
--
Willem Jiang
Red Hat, Inc.
FuseSource is now part of Red Hat
Web: http://www.fusesource.com | http://www.redhat.com
Blog: http://
Hi
The maximumPoolSize option is *actually* the value for the corePoolSize of
the ThreadPool being in charge, which is set to 100 in your case (the option
naming seems a bit misleading to me). Can you try with smaller values for
this option to see if you can still reproduce the problem.
Other tha
ok, i understand
but i use camelContext with start so for sql component e.g.
from("direct:infor.insert.ipnl_passages")
.to("sql:insert into cust_ipnl_passages
(ID,DT_CRT,FLAG_TO_DUPLICAT,FLAG_TO_REDIRECT,LINE_CODE,RUN_CODE,COM_CODE,COMPANY_CODE,DT
Hi
consider this simple route
from("netty:tcp://0.0.0.0:7004?textline=true").throttle(100).to("netty:tcp://0.0.0.0:7005?textline=true");
According to this only 100 requests per second will be sent to second
endpoint.
Assume that first endpoint is receiving some thousand messages per second,
h
Yes the throttle is in-memory queue based, so you could end up eating up memory.
There is a route policy that can also throttle by suspending/resuming
the actual route, which then would mean that if the route is suspended
then no new incoming messages comes in.
On Wed, Aug 14, 2013 at 11:23 AM
In contrast to your first route (which consumes from the FTP endpoint) this
second route of yours does *not* own a polling consumer:
http://camel.apache.org/polling-consumer.html
So in this case you have to invoke your route (synchronously), through a
producer template or another route, etc.. So
You will have to use http component and manually process the feed or
dynamically create routes using the url from db and rss consumer.
B.
Sent from mobile
On 14 Aug 2013 08:41, "skazy" wrote:
Hi Bilgin,
I have to write the route which periodicaly reads the list of RSS feed urls
from database (
hello everyboby,I ask a question.
I write the code:
public class TestHttpCamel {
public static void main(String args[]) throws Exception {
CamelContext context = new DefaultCamelContext();
context.addRoutes(new RouteBuilder() {
public
Hi
Babak explained this on another post today. So I am quoting his reply
Hi
Invoking start on the CamelContext is a non-blocking call, check links below
to see how to keep your standalone Camel application running:
http://camel.apache.org/running-camel-standalone-and-have-it-keep-running.html
h
Hi
Thanks for reply.
One more clarification
There is request time out option in netty right ,
For handing time outs also any in-memory queue will be used ?
Because there may be chances we get memory issues when external sever is
not at all replying .
-
Regards
kiran Reddy
--
View t
Hi,
what exactly is you problem. Do you get an exception? try it with the
following in your route:
.to("file:/d:/temp/outbox?fileName=data.txt")
recognize the / before d:
regards, Marco
Am 14.08.2013 12:00, schrieb yiwang:
hello everyboby,I ask a question.
I write the code:
public class
I have recently upgraded Camel to version 2.11.0. In my file transfer
services I have used a predicate together with interceptors to avoid
transferring empty files but instead move them into a subfolder called
"skipped". However, this has stopped working. My predicate looks like this:
*Predicate e
See also the readLockMinLength option
On Wed, Aug 14, 2013 at 4:26 PM, Bengt Rodehav wrote:
> I have recently upgraded Camel to version 2.11.0. In my file transfer
> services I have used a predicate together with interceptors to avoid
> transferring empty files but instead move them into a subfol
Thanks for the tip. It would probably be good enough although I also want
to move the empty files to a dedicated directory to clearly show what took
place.
Do you know f the syntax for checking the file length has changed in Simple
language (or rather File language)? Looking at the documentation I
Hey Dariusz,
According to javadoc on PollingConsumerPollStrategy.rollback() throwing
exception from this method have side effect and in general is used to hold
scheduler.
You probably did that already, but having debug or trace logging helps a little
bit. Also going with debugger may be helpful
I try to keep all my routes in Spring, but I cannot find any example about
how to define the following in Spring:
.resequence(header("seqnum")).stream().capacity(500).timeout(1).comparator(myComparator)
or
.resequence(header("seqnum")).stream(myConfig)
where myComparator is a custom Expres
Hi,
so the RSS component is not able to receive a list of URLs and process them
one by one? IMHO this does not seem like a good design for a component.
-borut
2013/8/14 Bilgin Ibryam
> You will have to use http component and manually process the feed or
> dynamically create routes using the u
Vahdat,
We have already tested with the default value of the maximumPoolSize option,
and we got the same problem. The version 2.10.2.
Flavio Magacho
Gerente de Desenvolvimento
Diretoria de Tecnologia da Informação
M4U
+55 (21) 2546-4050 ▪ Ramal: 4082
+55 (21) 8889-1572
Antes de imprimir, pen
Any chance to test on the latest version of the 2.10.x branch as 2.10.2 is
about 10 months old, or maybe even 2.11.1 which relies on a newer Netty
version.
Babak
Am 14.08.13 21:20 schrieb "Flavio Magacho - M4U" unter
:
>Vahdat,
>We have already tested with the default value of the maximumPoolSi
I am new to Apache Camel and trying to use its SMPP component to send sms to
SMSC. However, the smsc vendor needs me to specify the operator id (i.e.
mobile phone carrier id) in the smpp optional parameters header with a tag
identifier 0x2150 which falls inside the range of SMSC Vendor specific
op
I've committed a test (into the master, 2.11.x and 2.10.x branches) forcing
20 *simultaneous* client calls without any success to reproduce your
problem:
http://git-wip-us.apache.org/repos/asf/camel/diff/2601e560
Babak
Babak Vahdat wrote
> Any chance to test on the latest version of the 2.10.x
Hi,
I have the following use case.
Write a JUnit test( using CamelTestSupport ) to validate the transformation.
1. Send message ( xml ) to IBM MQ
2. Transformation Engine Reads message from queue and drops the transformed
message to another queue.
3. Read the Transformed message (fixed width ) a
1.Is not the reason to add "/"
2.public class TestHttpCamel {
private Main main;
public static void main(String args[]) throws Exception {
TestHttpCamel example = new TestHttpCamel();
example.boot();
}
public void boot()
Is not the reason to add "/"
still not get the data. The HTTP routing write wrong or need what
configuration?
--
View this message in context:
http://camel.465427.n5.nabble.com/Why-can-not-get-the-data-tp5737243p5737284.html
Sent from the Camel - Users mailing list archive at Nabble.com.
I rewrite code is as follows:
public class TestHttpCamel {
private Main main;
public static void main(String args[]) throws Exception {
TestHttpCamel example = new TestHttpCamel();
example.boot();
}
public void boot() throws
Hi,
If you just want to validate the transformed message in unit test, you can
replace the endpoint of IBM MQ with the mock endpoint.
--
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.co
Thank you.
--
View this message in context:
http://camel.465427.n5.nabble.com/Question-about-ZooKeeper-APIs-tp5736960p5737287.html
Sent from the Camel - Users mailing list archive at Nabble.com.
Hi everyone,
I want to add a new route to an ClassPathXmlApplicationContext
programatically. Like the code below,
after the springContext is created, can we add a new route to the
springContext? Is there a solution?
String filename = "META-INF/spring/camel-context.xml";
AbstractXmlApplicationC
If you want the Camel application to act like a HTTP server, then you
should use jetty component for that. See details at:
http://camel.apache.org/jetty
On Thu, Aug 15, 2013 at 5:01 AM, yiwang wrote:
> I rewrite code is as follows:
> public class TestHttpCamel {
> private Main main;
>
Hi
You can see this link how to add new routes from XML files
http://camel.apache.org/loading-routes-from-xml-files.html
On Thu, Aug 15, 2013 at 5:33 AM, bonnahu wrote:
> Hi everyone,
> I want to add a new route to an ClassPathXmlApplicationContext
> programatically. Like the code below,
> a
I would try to let Spring inject the CamelContext into my class.
There you could add your routes.
@Autowired
CamelContext ctx;
public void init() {
ctx.addRoutes(new RouteBuilder() {
public void configure() {
from(...) ...
}
});
}
Jan
> -Ursprüngliche Na
35 matches
Mail list logo
