Hi,
that's exatly the point. If you use Hazelcast (for seda queing), you'll do
it, because need the cluster functionality. If you don't need that - don't
use the Hazelcast component for this case. If you need a cluster, then you
'll have normally more than one node. When you shut down one of
Have a look at this: http://camel.apache.org/bean.html
...
.to(bean:customerDataService)
...
On Tue, Jan 20, 2015 at 8:03 PM, Vishnu Kumar vishnu.kumar...@gmail.com
wrote:
http://camel.465427.n5.nabble.com/file/n5761959/StackSp.jpg
--
View this message in context:
The file component has a build in timer. You don't need the first line.
from:quot;file://
fromDirectoryquot;
to:quot;file://toDirectoryquot;
I'm not sure if you really want to read only once from the file system. If
yes, you should probably think about an other solution...
Best regards - Claus
You can use the standard hazelcast XML configuration. There is no Camel
specific magic. See http://www.hazelcast.com/ for a very detailed
documentation.
Best regards - Claus
On 13.07.2013 13:21, Claus Ibsen wrote:
I assume the idea is that you configure an existing
Have you tried a higher completion size? For us 750 was the best.
On 09.11.2012 19:59, Gonzalo Vasquez wrote:
Ok, I've included an aggregator in the splitter, as follows:
camel:route id=pager autoStartup=true
camel:from
Hi Gonzales. Take a look at this:
http://www.catify.com/2012/07/09/parsing-large-files-with-apache-camel/
perhaps it solves your issue.
Best regards - Claus
I'm running a route that basically adds a character per line to a
plain text file, but it's taking to long, and it seems that it's due
Hi,
On 17.10.2011 23:13, bvysocky wrote:
I am trying to use the hazelcast component in camel for creating queues. Is
there a way to configure the queues to be persistent? This was added to
hazelcast in version 1.9.3, which I belive camel 2.8.0 is using. I would
really like to be able to
Hi all,
I'm trying to install camel-spring 2.8.0 on karaf 2.2.3 using features.
That's what I'm doing:
karaf@root features:addurl
mvn:org.apache.camel.karaf/apache-camel/2.8.0/xml/features
karaf@root features:install camel-core
karaf@root osgi:list
START LEVEL 100 , List Threshold: 50
Have you tried to define the transformerFactory (how to do that see
http://camel.apache.org/xslt.html at the end of the page)? I'm not sure
if this is the problem, but it can be. Your code looks fine.
Best regards - Claus
Am Mittwoch, den 22.06.2011, 03:41 +0200 schrieb pcroser
Hi Mirko,
What do you mean with previous answer? There're two answers: true or
false. If you send 'A' twice and you will get true both times, the this
is no idempotent consumer pattern.
Best regards - Claus
Am Dienstag, den 21.06.2011, 14:19 +0200 schrieb Mirko Caserta
But what you want to do is to store something into a store (e.g. a
cache, database, file system,...) then make a lookup if it is inside the
store, if not put it in. I don't understand why it should be more effort
to write 5 lines route code than implementing it. There're 1000 use
cases that
I don't make my money by writing posts on the mailing list. I think a
hour is not to long to wait...
Best regards - Claus
On 21.06.2011 15:57, mcaserta wrote:
Not worth the effort? That'd be an acceptable answer too, no worries :)
Ciao, Mirko.
--
View this message in context:
You strucked no nerve. All I wanted to say is that it's not always
possible to look every 5 minutes on the list. The first thing I did
after doing my 'real' work and looking on the list again was to answer
your question. That's all :)
On 21.06.2011 17:34, mcaserta wrote:
I didn't mean to be
-tp4495731p4495731.html
Sent from the Camel - Users mailing list archive at Nabble.com.
--
claus straube
__
phone+49-89-38157419
mobile +49-176-49673717
web http://www.catify.com
office 5. floor, heßstr. 56, 80798 munich
__
Hi Andre,
On first sight I think this one is not correct:
...
bean method=generateRequest ref=xacmlRequest
to uri=activemq:topic:xacml.authzRequests/
/bean
...
should be
route
from uri=direct:start/
bean method=generateRequest ref=xacmlRequest
/bean
I don't use this plugin. With plain Eclipse everything is fine ;)
One problem could be the @consume annotation. Why do you have on the
one side a polling consumer and on the other a route with direct to the
same bean? Perhaps you could try to comment out the @consume...
Am Mittwoch, den
It's not really clear for me what you're doing. You're trying to call
the route over direct? Are you sending a file?
Additional things you can do:
- give your routes ids -- so you can see if they have been started.
- set a breakpoint into your constructor -- so you can see if your
class have
The routes are looking good.
Have you tried to run your codes with break points?
The interesting part is what are you sending via direct://start? You
said below something like RequestCtx, but you method awaits a File. And
I'm not sure if void is what you want. Look at the sample Bean as
--
View this message in context:
http://camel.465427.n5.nabble.com/what-did-i-forgot-Bean-integration-through-direct-start-tp4490510p4491246.html
Sent from the Camel - Users mailing list archive at Nabble.com.
--
claus straube
__
phone+49-89-38157419
simply try this in your ide (no maven, no fuse-ide). If you can
reproduce this, your routes should work as well...
The test class:
public class TestBean extends CamelSpringTestSupport {
@EndpointInject(uri = mock://out)
private MockEndpoint out;
@Override
protected
Simple answer: no. Worked the sample in your environment?
On 15.06.2011 17:39, Andrè wrote:
could it be that the bean is treated like an processor and not like an input
Endpoint (what i want to have)
--
View this message in context:
Have you extended your test class with CamelSpringTestSupport? There
you've to override a method which loads the camel context. So the beans
should be loaded (you can simply test this by setting a break point into
the descriptor of your bean).
Where comes this 'input4Endpoint' from? It
Hi Marco,
have you tried 'transferExchange=true' inside your JMS route? That could
be a solution for your JMS problem.
Best regards - Claus
On 08.06.2011 18:23, Marco Zapletal wrote:
Hi,
I learned from this thread
of
org.apache.cxf.service.model.MessageInfo on
the exchange, which is not serializable. This results in a runtime
exception, which cancels the execution of the process instance.
regards,
marco
On 08.06.2011 18:26, Claus Straube wrote:
Hi Marco,
have you tried 'transferExchange=true' inside your JMS route? That
could
You can start it once and use it (that's the default way) over your
complete application lifecycle. And you have not to start the route
explicitly, but load them into the context.
Best regards - Claus
Am Freitag, den 03.06.2011, 08:47 +0200 schrieb ltomuno
ltom...@163.com:
java code:
Hi,
I haven't done it yet - but I would try it. Should be a thing of 5
minutes ;)
http://camel.apache.org/file2.html
Best regards - Claus
On 01.06.2011 17:17, sumatheja wrote:
Hi,
I'm a newbie to camel. Want to know if the file component in camel can
read a pdf? if not is there a way to
Hi,
you can validate your xml payload with the validation component:
http://camel.apache.org/validation.html
Best regards - Claus
On 26.05.2011 17:03, Bruno Dusausoy wrote:
Hi,
I know this is a common question, but I couldn't find a simple answer
for this.
Basically what I want to do is
Hi Jeff,
I think you have to separate between the camel context and routes. If I
understand your case correctly you want to load an externally defined
route (as xml file) into your running camel context?
So a simple solution would be to create a bundle with the camel context
and one route
I think so :)
On 25.05.2011 19:08, jguion wrote:
Thanks Claude, I did not think of that. It is a better idea to load just a
route as xml rather than the full camel-context
--
View this message in context:
http://camel.465427.n5.nabble.com/Camel-Activator-OSGI-tp4422370p4425981.html
Sent from
Hi Johannes,
I don't know if there's any best practice. But I think the headers are a
good place for storing meta data containing to the message.
pro class:
- a class is explicit, so you know what properties are available (anyway
- you can store such an object inside the message headers, so
Hi Ichsan,
if you turn on tracing (camelContext trace=true) you can see the
threads. What do you mean by concurrently? If I see this correct,
you're refering to a Spring bean. This is per default a singleton. So
you should have only one instance of mocky...
Best regards - Claus
On
Hi Muhammad,
I think the error must be in your iMessageUtil class. This route works
as you would expect:
public class CamelTestRoutingSlip extends CamelTestSupport {
public void testRoutingSlip(){
template.sendBody(direct:foo, foo);
}
protected RouteBuilder
Ok - Ichsan :)
This works for me in 2.8-SNAPSHOT. I think this is pretty close to that
you want to do (except the spring stuff).
public class CamelTestRoutingSlip extends CamelTestSupport {
@EndpointInject(uri = mock:result)
protected MockEndpoint resultEndpoint;
public void
It also works if I do this:
from(direct:a)
.bean(foo, doA);
//.to(log:A);
from(direct:b)
.bean(foo, doB);
//.to(log:B);
On 03.05.2011 13:49, Claus Straube wrote:
Ok - Ichsan :)
This works for me
Hi Linus,
I think page 420 (and the ones after this) in Camel in action will face
such a issue. You can stop a route on completion and start it again, if
your script has been finished.
Best regards - Claus
On 02.05.2011 09:36, Linus Brimstedt wrote:
Hi!
On Mon, May 2, 2011 at 7:44 AM,
Hi,
I think you can use org.apache.camel.component.file.GenericFileFilter
for this (I've not tested, if this works with FTP, but it should). See
also the docu of the file component: http://camel.apache.org/file2.html
Best regrads - Claus
On 02.05.2011 11:20, tnk wrote:
Hello,
regarding
Hi,
you should double check, if there's
(class=mycompany.generic_soap_provider_bridge.ServiceClient) no typo
inside your context. If the class is in your classpath, Spring will find it.
Best regards - Claus
On 15.04.2011 16:29, Naira Kobo wrote:
Hi,
Thanks for your response.
However, in
Hi Christoph,
you can definitely use the Hazelcast component very easily to figure out
if a instance comes up or goes down by using fromF(hazelcast:%sfoo,
HazelcastConstants.INSTANCE_PREFIX). This is more an event based
approach than polling constantly for an instance.
Best regards - Claus
On 07.04.2011 22:29, Arkadi Shishlov wrote:
On Thu, 07 Apr 2011 16:50:52 +0300, Claus Straube
claus.stra...@catify.com wrote:
On 07.04.2011 15:33, Arkadi Shishlov wrote:
On Thu, 07 Apr 2011 13:24:02 +0300, Andrey Popp 8may...@gmail.com
wrote:
* Apache Camel should try to compile routes
On 08.04.2011 10:14, Arkadi Shishlov wrote:
On Fri, 08 Apr 2011 10:58:27 +0300, Claus Straube
claus.stra...@catify.com wrote:
An empty multicast is no error.
ArrayList l = new ArrayList();
from(direct:a).multicast().to(l);
java.lang.IllegalArgumentException: Definition has no children
? Is there a way to do this with Camel?
--
View this message in context:
http://camel.465427.n5.nabble.com/Route-Question-tp4281861p4286385.html
Sent from the Camel - Users mailing list archive at Nabble.com.
--
claus straube
__
phone+49-89-38157419
mobile
Hi.
I'm not sure what you want to do, but perhaps the context component is
something for you.
Claus
On 04.04.2011 11:49, Sorin Silaghi wrote:
Hi
Is there any way to rurn a route into a camel component ? I'd like to
do this because I want to add some higher level logic to an existing
Hi.
yes:
camelContext xmlns=http://camel.apache.org/schema/spring;
template id=camelTemplate/
!-- use myFilter as filter to allow setting ANT paths for which files to scan
for --
endpoint id=myFileEndpoint
uri=file://target/antpathmatcher?recursive=trueamp;filter=#myAntFilter/
Hi Gonzalo.
1. Each service is a bundle running on an OSGi container; there could be one or
more containers running on one or more JVMs, on one or more servers.
2. Each service could export its entry points on several endpoint types; at
least one type for RPC (SOAP, REST, etc.) and one type
On 29.03.2011 12:58, gonzalo diethelm wrote:
Hi Gonzalo.
Hi Claus, thanks for your insight.
0. First off, does it really make sense to turn my back to J(2)EE? I
know I would be giving up a significant amount of baseline, but I am
really hungry for some lean and mean architecture. Opinions?
On 29.03.2011 13:59, gonzalo diethelm wrote:
One thing I have not been able to figure out is how to expose all these
CRUD services over jetty. Just as an example, let's say I will handle
account objects and will want to support three actions on them:
GET /account/{id} = retrieve that account
On 29.03.2011 15:15, gonzalo diethelm wrote:
Great, this works. And I guess you meant that you would create one
endpoint for each operation, right?
For me it's more transparent - but you can do this like you want ;)
Something like this would work as well
...@gmail.com:
Sorry about that, here is the Smooks thread:
http://old.nabble.com/Streaming-huge-EDI-file-with-camel-td31238361.html
Regards,
/Daniel
On 27 March 2011 11:27, Claus Ibsen claus.ib...@gmail.com wrote:
On Fri, Mar 25, 2011 at 6:19 PM, Claus Straube
claus.stra...@catify.com
wrote
Hi Claus,
I know thats deprecated and I'm using their stuff. The post to the camel
list was because it's still 'camel' and there is a chance that anybody
community has used it before ;)
On 26.03.2011 11:37, Claus Ibsen wrote:
Hi
If you refer to the old smooks component from camel-extra
Hi all.
I've posted this on the smooks list, but there was nobody who could give
me a hint...
I'm trying to transform a huge edi file to xml. For reading the file I'm
using camel. Here is my route:
snip
from(file://target/in?noop=true)
.to(smooks://src/main/resources/smooks-config.xml)
Hi Gosh,
producer is always to()...
consumer is always from()...
Regardless, if data goes in or out. The point is, that you have to force
the producer to do something while a consumer does it itself (e.g. by
polling, on event, etc.)
Best regards - Claus
On 24.02.2011 11:37, ghosh wrote:
over multicast).
On Fri, Feb 18, 2011 at 8:56 AM, Claus Straubeclaus.stra...@catify.com wrote:
I've forgotten the most important part. Here you can find it:
https://github.com/catify/camel-hazelcast
Sorry ;)
On 18.02.2011 08:55, Claus Straube wrote:
Hi all,
we've developed a camel component
/camel-hazelcast
Sorry ;)
On 18.02.2011 08:55, Claus Straube wrote:
Hi all,
we've developed a camel component for the Hazelcast data grid
(http://www.hazelcast.comhttp://www.hazelcast.com/). Hazelcast is a
easy
to use, but powerful data grid solution, entirely written in Java. We've
implemented
;) Thanks in advance.
Best regards - Claus
--
claus straube
__
web http://www.catify.com
office 5. floor, heßstr. 56, 80798 munich
__
I've forgotten the most important part. Here you can find it:
https://github.com/catify/camel-hazelcast
Sorry ;)
On 18.02.2011 08:55, Claus Straube wrote:
Hi all,
we've developed a camel component for the Hazelcast data grid
(http://www.hazelcast.com http://www.hazelcast.com/). Hazelcast
yes :) just try it.
On 29.12.2010 15:54, Marek Kasztelnik wrote:
Hi,
I would like to have couple jetty routes sharing the same port, e.g.:
jetty:http://0.0.0.0:1234/firstroute
jetty:http://0.0.0.0:1234/secondroute
Is it possible to create such configuration?
greetings,
Marek
Hi,
can you post your route?
On 27.12.2010 13:19, kanmisc wrote:
Hi
I have usecase saying - in source endpoint i have few files to be processed.
Each file needs to be read by camel route and assigned an unique id and
processed through dedicated beans and the resulting file will be posted to
for every route , and send
message to some Custom endpoint which will carry out logging.
But in this case the whole message will be send to the endpoint while I
don’t need it.
But isn’t there any camel standard approach to handle this issue?
Can someone suggest me solution?
--
claus straube
Hi,
in 2.6 I miss the 'headerName' attribute in the routing slip definition.
Is there now a convention, or how can I implement this pattern in
Spring? In the Java DSL there is still this attribute...
Thanks in advance - Claus
xs:complexType name=routingSlipDefinition
xs:complexContent
Hi Niranjan,
I think you can use the fileName property. You can find an explanation
under http://camel.apache.org/file2.html.
Best regards - Claus
On 20.12.2010 07:30, niranjan wrote:
Hi Mattias,
I found out the mistake. The file “message1.xml” is not in the correct
path. Now it
Hi Daniel,
I think this is not part of the documentation, because it's a native
spring functionality. With
import resource=myCoolRoutes.xml/
you're importing a new Spring context and here of course you need a
surrounding bean element.
Best regards - Claus
On 07.12.2010 12:11, Illtud
no
elements.
Can you tell me what I am doing wrong please?
Thanks.
--
claus straube
__
phone+49-89-38157419
mobile +49-176-49673717
web http://www.catify.com
office 6. floor, heßstr. 56, 80798 munich
Hi,
perhaps you want to take a look at ActiveMQ Message Groups. I think this
could solve your problem (if you're using ActiveMQ).
http://activemq.apache.org/message-groups.html
Best regards - Claus
On 06.12.2010 09:40, jmh wrote:
Hello,
a common requirement with JMS is to consume messages
Hi,
I'm sure will not get a java object back as http response ;) You should
read this documentation http://camel.apache.org/http.html and perhaps
write a simple test to check out how your response looks like. Then you
can convert it to a java bean or wath ever you want.
Best regards - Claus
to see what all can be done.
Any insight appretiated.
--
claus straube
__
phone+49-89-38157419
mobile +49-176-49673717
web http://www.catify.com
office 6. floor, heßstr. 56, 80798 munich
__
catify
You have to differ between consumers (from), producers (to) and the
route semantic like a content based routing. For me it's not clear what
you want to know. The from uris are depending on the consumer component
you want to use (http://camel.apache.org/components.html) as well as the
Hi,
you can do this by intercepting your routes.
public void testFoo() throws Exception {
RouteDefinition route = context.getRouteDefinitions().get(routeId);
route.adviceWith(context, new RouteBuilder() {
public void configure() throws Exception {
interceptSendToEndpoint(seda:in)
Hi,
I think you can do this using a idempotent repository:
http://camel.apache.org/idempotent-consumer.html
from(ftp:foo)
.split(body().tokenize(\n)
.idempotentConsumer(header(myMessageId),MemoryIdempotentRepository.memoryIdempotentRepository(200))
.to(jms:bar);
in your case the memory
Hi all,
I'm testing with CamelTestSupport and have a long running test:
int runs = 1500;
MockEndpoint out = getMockEndpoint(mock:out2);
...
out.expectedMessageCount(runs);
out.setResultWaitTime(6);
System.out.println(--- +
as there are still 5926 inflight and pending exchanges to
complete, timeout in 10 seconds.
--
claus straube
__
phone+49-89-38157419
mobile +49-176-49673717
web http://www.catify.com
office 6. floor, heßstr. 56, 80798 munich
this should
the correct pattern for my problem...
Any suggestions, how I can do this? Thanks in advance.
Best regards - Claus
--
claus straube
smime.p7s
Description: S/MIME cryptographic signature
71 matches
Mail list logo