Hi,
Split eip supports tokenizing by a delimiter and grouping as below;
from("file:inbox")
.split().tokenize("\n", 1000).streaming()
.to("activemq:queue:order");
Is there a specific reason why we don't have such like.
from("file:inbox")
.split().tokenizeByByteSize(1024, 1000).streaming
This is how my tests are set up
@RunWith(CamelSpringBootRunner.class)
@MockEndpoints
@UseAdviceWith
@SpringBootTest(classes =
mydomain.springbootcamel.SpringBootCamelExamples.class)
public class RouteBTests {
@Autowired
private CamelContext camelContext;
@Autowired
private ProducerTempla
Claus
Thanks for taking the time to respond to this camel newbie.
The schema registry url is the host & port for the schema registry, which
allows the KafkaAvroSerializer
(io.confluent.kafka.serializers.KafkaAvroSerializer) to look up the schema
used to serialize and deserialise an avro message,
Hello,
here is code snippet below:
what happens is my route has a bean that performs some verification on a
decoder for messages. if the decoder does not exist for the file ( pre
processing or conditioning the file ) the file is moved to localhost and
saved as the onException processing indicates.
I have a Spring Boot application with camel routes that starts up and runs
fine in Tomcat (it is a web app). However I am having real issues getting it
to run as a unit test. I have an @Configuration file that has 3 RouteBuilder
beans. I do not explicitly define a CamelContext been and instead let
The github docs are the up to date docs, so look there.
What is schema.registry.url, ?
For configuring Camel uris, then see
http://camel.apache.org/uris
Where you can use the # syntax to refer to beans in the spring boot
bean registry
Then to refer to a custom bean in the registry then use
Claus
Sorry to be dense, but which camel component should I be looking at and
where?
If you meant the kafka component, I could not see anything which mentioned
the schema registry in its docs at:
https://github.com/apache/camel/blob/master/components/camel-kafka/src/main/docs/kafka-component.adoc
See the Camel component docs via github
https://github.com/apache/camel/tree/master/components#components
On Tue, May 30, 2017 at 6:19 PM, tim.jones wrote:
> Hi
>
> Using the confluent schema registry for the avro schemas and wanted to use
> camel-kafka (with spring-boot) , but can't work out how
Hi
Using the confluent schema registry for the avro schemas and wanted to use
camel-kafka (with spring-boot) , but can't work out how to introduce the
schema.registry.url, as it is not a URI option.
How can I include this property, such that it is picked up both by
Camel-kafka producers and con
Thanks, got it to work now
--
View this message in context:
http://camel.465427.n5.nabble.com/Dynamic-properties-in-a-camel-route-tp5801295p5801371.html
Sent from the Camel - Users mailing list archive at Nabble.com.
Hi
difference between to and wiretap: Wiretap uses a dedicated thread pool to
process the messages. So you have to be careful about transaction boundaries.
Regards
Stephan
-Ursprüngliche Nachricht-
Von: Caranthir [mailto:candelor...@gmail.com]
Gesendet: Dienstag, 30. Mai 2017 13:23
Hello,
I have a problem. In my camel application I have two JPA endpoints. Where I
get some values from one database and insert it to the other one.
So I defined jpa endpoint for one database and jpa2 for the other database.
i get some value with
from(jpa://...).process( ... ).to(direct:e)
t
Hi Cameleers, Giannis,
we have 2.20 snapshots built at the snapshot repostory[1], other than
a incompatibility with `noStart` flag -- that I don't think is much
used outside of tests, I believe it should fix this.
We are considering to backport this to next patch release of 2.19 (2.19.1).
Any feed
Thank you for the response.
Apologies if i am wrong , the producer and consumer should have the same
topic name if i am not wrong?
callkafkaSuspenseProducer- This is the producer.
callkafkaSuspenseConsumer - This is the consumer.
regards
Darwin
--
View this message in context:
http://camel.
Hello,
we are using Camel 2.17.3 within an integration application with quite a
few data sources, 3 of which are JMS providers.
For all our internal traffic we use ActiveMQ 5.14, the external
providers are SonicMQ and Software AG Universal Messaging.
The application runs within an OSGi cont
I'm trying to build a REST interface using camel-quickfix to interact with a
FIX service. Ideally I want to send synchronous responses to the REST calls.
Following the documentation about "Using the InOut Message Exchange Pattern" at
http://camel.apache.org/quickfix.html and inspecting the Requ
I'm trying to build a REST interface using camel-quickfix to interact with a
FIX service. Ideally I want to send synchronous responses to the REST calls.
Following the documentation about "Using the InOut Message Exchange Pattern"
at http://camel.apache.org/quickfix.html and inspecting the
Request
Thanks Claus.
So the general rule appears to be that do not rely on the class of headers
as the components may manipulate them. So it looks as though MockEndpoint
leaves them alone whereas the enrich route changes the type from pojo to
string.
Quoting from the book:
"Properties—Similar to me
It looks like you use the same topic name, and then send the messages
back to yourself
On Fri, May 26, 2017 at 9:26 AM, darwinanirudh wrote:
> Kakfa consumer and producer for the above post
>
>
> uri="kafka:${kafkaserver}?topic=SuspendedCdr3&zookeeperHost=${zookeeperHost}&zookeeperPort=$
Hi
We are busy these days. Can you maybe log a JIRA and provided a github
PR. And then run all the tests of camel-jms with the potential fix.
That will give us a head start
On Fri, May 26, 2017 at 6:38 PM, Preben.Asmussen wrote:
> Hi Claus
>
> The example is now head, and I just wanted to follow
Hi
I logged a ticket about turning the default off
https://issues.apache.org/jira/browse/CAMEL-11364
On Mon, May 29, 2017 at 5:43 PM, Claus Ibsen wrote:
> Yes its extended by default
> https://github.com/apache/camel/blob/camel-2.17.x/camel-core/src/main/java/org/apache/camel/management/DefaultM
Hi
Can you tell more about how that quick-fix works and what you have
done to make it? Maybe there is something we can do in the camel-jetty
source code, and if so you are welcome to look at providing a fix as a
.patch or github PR
On Mon, May 29, 2017 at 6:05 PM, adie wrote:
> Ok,
> quick fix f
I suggest to use the jpa component instead. Its more maintained and
also part of Apache Camel.
On Tue, May 30, 2017 at 6:59 AM, sarada.ch wrote:
> Working fine now but still feeling weird why they have restricted to and
> form.
>
> to: will insert
> from: will select/delete
>
>
>
> --
> View thi
Working fine now but still feeling weird why they have restricted to and
form.
to: will insert
from: will select/delete
--
View this message in context:
http://camel.465427.n5.nabble.com/Camel-hibernate-issue-with-Select-tp5801204p5801316.html
Sent from the Camel - Users mailing list archive
24 matches
Mail list logo
