Re: JMSReplyTo improperly utilised by camel to send an incomplete message

Since the route works as expected when you remove the split, I’d try moving all the split/aggregate logic into a direct route and call that from the main route and see if that works. > On Jun 6, 2019, at 6:40 AM, Quinn Stevenson > wrote: > > Mariusz I still have issues with the

Re: JMSReplyTo improperly utilised by camel to send an incomplete message

ull, as it was never accessed). Does that matter? Thanks and regards! > On Jun 5, 2019, at 6:54 AM, Quinn Stevenson > wrote: > > Mariusz sent the following to me directly (he’s having trouble with the > mailing list). > > Hi, > > First of all, you seem to have mixed

Re: JMSReplyTo improperly utilised by camel to send an incomplete message

split and see if it behaves as expected? > On Jun 4, 2019, at 8:32 AM, Quinn Stevenson > wrote: > > It’s been a while since I’ve implemented a route that implements JMS > request-response, but if I remember correctly, you need to choose whether > Camel/Spring will handle

Re: JMSReplyTo improperly utilised by camel to send an incomplete message

It’s been a while since I’ve implemented a route that implements JMS request-response, but if I remember correctly, you need to choose whether Camel/Spring will handle the reply or you will. If you set disableReplyTo=true, Camel/Spring will send the reply using whatever is in the exchange at

Re: [FEEDBACK] - Apache Camel 3 - camel-core vs camel-core-lite vs camel-core-all

I’d prefer to have camel-core act like 2.x as well to minimize surprises as much as possible when upgrading. Maybe the new “lite” module could be called something like “camel-engine”? > On Mar 5, 2019, at 7:49 AM, Steve Huston wrote: > > My assumption is that camel-core (all in one) doesn't

Re: mllp receiver of HL7.. Sender is sending simultaneous "conversations"

OK - I did a little digging and this is a bug - sorry. Can you open a JIRA for it? You can try setting the CamelMllpCloseConnectionAfterSend exchange property in your route to force the connection to close after the acknowledgement is sent. Quinn Stevenson qu...@pronoia-solutions.com (801

Re: mllp receiver of HL7.. Sender is sending simultaneous "conversations"

Hmmm… what version of Camel is this? Quinn Stevenson qu...@pronoia-solutions.com (801) 244-7758 > On Jan 4, 2019, at 10:06 AM, John F. Berry > wrote: > > > > Thanks Quinn, > > I've attempted to increase the consumers with the uri option of > maxConcurrent

Re: mllp receiver of HL7.. Sender is sending simultaneous "conversations"

Sorry for the late reply on this - I was on vacation :-) When I wrote camel-mllp, I had to deal with a somewhat similar situation. I had multiple systems sending to the same host:port (same type of data, different source systems). So camel-mllp will allow multiple/concurrent connections and

Re: JMX Camel New User Question: where do I put service:jmx:rmi...

Find your JMX URI for ActiveMQ - it will look something like service:jmx:rmi:///jndi/rmi:/localhost:1099/jmxrmi Then the from should be something like from("jmx:service:jmx:rmi:///jndi/rmi:/localhost:1099/jmxrmi?objectDomain=jmxExample=simpleBean”) HTH > On Dec 19, 2018, at 9:40 PM, RW

Re: Established Java DSL route into Camel Spring OSGi container - for use with Kataf container

iring.package; > (&(osgi.wiring.package=org.apache.camel.component.sql)(version>=2.21.0)(!(version>=3.0.0)))] > Are these dependencies supposed to be listed under the Felix plugin as export > packages? > >On Monday, October 22, 2018, 9:32:22 PM EDT, Quinn Stevenson > wrote: > >

Re: Established Java DSL route into Camel Spring OSGi container - for use with Kataf container

n.hl7v2.model.Message; > import ca.uhn.hl7v2.util.Terser; > import ca.uhn.hl7v2.DefaultHapiContext; > import ca.uhn.hl7v2.HL7Exception; > import ca.uhn.hl7v2.HapiContext; > > I assume I should have this declared as a POM dependency? I've tried a few > blind tries at declaring

Re: Established Java DSL route into Camel Spring OSGi container - for use with Kataf container

ntainer.ComponentDefinitionException: Unable to > instantiate components > > So I was planning to start this new project and attempt deployment to Karaf.. > and add the steps of my route one at a time.. but I cannot even start with > this one! > > Thanks! > > > On

Re: [Solved] Consuming MLLP uri cannot be "seen" with localhost or 127.0.0.1 from external

You can also use from(“mlll://”) and camel-mllp will create the InetSocketAddress without specific a host, so it should work as well. HTH > On Oct 5, 2018, at 6:20 AM, John F. Berry wrote: > > Thanks Stephan! > For not knowing my question, you answered it perfectly. I knew localhost

Re: Camel Hazelcast XML namespace

Is this a question about the Camel XSDs? As far as I know, there isn’t a “fromF” element in the XML DSL - it’s only in the Java DSL. > On Sep 7, 2018, at 8:15 AM, T Rehman wrote: > > Does anyone know the XML namespace to use for the Hazelcast component? > >

Re: Established Java DSL route into Camel Spring OSGi container - for use with Kataf container

Camel thread not a Karaf or OSGi forum. > > > On Wednesday, September 5, 2018, 9:10:33 AM EDT, Quinn Stevenson > wrote: > > > > The easiest way to bootstrap a route in Karaf is to use Blueprint. I’m > assuming you’ve already converted your jar to an OSGi bundle.

Re: Established Java DSL route into Camel Spring OSGi container - for use with Kataf container

The easiest way to bootstrap a route in Karaf is to use Blueprint. I’m assuming you’ve already converted your jar to an OSGi bundle. If you add a small XML file to src/main/resources/OSGI-INF/blueprint (assuming you’re using Maven for this) the route should startup in Karaf when you install

Re: Exception when sending message to queue

You’ve configured the route to use an XA transaction (the .transacted() ), but it doesn’t look like you’ve configured the connection factories and such for XA. If you can get away with it, you could try “tranacted=true” on both the subscriber and the publisher - it’s not as fail-safe as XA, but

Re: Replacement for Tracer?

The docs also refer to a Karaf command to control the tracer - I can’t find that either. > On Aug 13, 2018, at 11:04 AM, Quinn Stevenson > wrote: > > OK - is there a way to configure the BacklogTracer to log the messages to the > log file the way that the Tracer does? I can

Re: How to use ActiveMQ Artemis through HTTP tunnel

I haven’t ever tried this, so I’m guessing. But have you tried using the JmsComponent instead of the ActiveMQComponent? > On Aug 13, 2018, at 10:58 AM, Simon Martinelli, 72 Services LLC > wrote: > > activemqAmazon

Re: Replacement for Tracer?

alternative to the Tracer. > On Aug 13, 2018, at 10:15 AM, Claus Ibsen wrote: > > Hi > > BacklogTracer or some better implementation we will do in the future > (Camel 3 etc). > > > On Mon, Aug 13, 2018 at 6:03 PM, Quinn Stevenson > wrote: >> The Tracer is ma

Re: How to use ActiveMQ Artemis through HTTP tunnel

There are quite a few examples of configuring camel-jms in the tests - here’s one that may be close (https://github.com/apache/camel/blob/master/components/camel-jms/src/test/resources/org/apache/camel/component/jms/jmsRouteUsingSpringJMSTemplate.xml

Replacement for Tracer?

The Tracer is marked as deprecated, but I can’t seem to find anything on a replacement. What will be replacing Tracer?

Re: How to use ActiveMQ Artemis through HTTP tunnel

? > On Aug 10, 2018, at 8:21 AM, Simon Martinelli, 72 Services LLC > wrote: > > Hi Quinn, > > It's an option of Artemis https://activemq.apache.org/artemis/ to connect to > Netty using a HTTP tunnel. > > Thanks, Simon > > -----Original Message- > From: Q

Re: How to use ActiveMQ Artemis through HTTP tunnel

Just a guess - but I don’t think httpEnabled is a valid option for an ActiveMQ openwire connection - at least I don’t see it here http://activemq.apache.org/connection-configuration-uri.html > On Aug 9, 2018, at 3:05 AM, Simon

Re: Java DSL route now needs a MS SQL .to( How do I declare connection info?

7:58 PM EDT, John F. Berry >>> wrote: >>> >>> Also, in compiling in maven, it doesn't find "SQLComponent". Isn't that >>> part of camel-sql? or am I configuring a different entity? >>> >>> On Tuesday, July 31, 2018, 12:29:49 PM EDT, Jo

Re: Java DSL route now needs a MS SQL .to( How do I declare connection info?

in this solution? I can't seem to find > information in this in my searches. > I'm trying to analyze the parameter string in the .setURL line and the values > within. > > On Tuesday, July 31, 2018, 10:55:42 AM EDT, Quinn Stevenson > wrote: > > Forgot to mention to make su

Re: Java DSL route now needs a MS SQL .to( How do I declare connection info?

Forgot to mention to make sure that when you use this component, use the component name that you register it with - in this example I used “my-sql”. > On Jul 31, 2018, at 8:49 AM, Quinn Stevenson > wrote: > > There’s a few ways to go about this, but I’d probably start ou

Re: Java DSL route now needs a MS SQL .to( How do I declare connection info?

quot;jdbc:derby:memory:orders;create=true" /> > > < property name = "username" value = "" /> > > < property name = "password" value = "" /> > > > > > but not declared in the Java DSL, if that

Re: Java DSL route now needs a MS SQL .to( How do I declare connection info?

From my experience, I’ve always been able to to more with the Java DSL than with Spring. I think routes written using the Spring XML are easier to read than routes written the Java DSL, but that’s just me. If you could post you’re Spring XML that you’re trying to translate, I’m sure we can

Re: Recommended jars to use with Camel

You could look at the POM for the Camel parent for the Camel release you’re using - it has most of the dependencies in it. Here’s a link to the current development version - you’ll need to look in one of the branches for your specific version of Camel.

Re: Cannot send files bigger then 256kb to service bus via amqps

Can you be more specific about what is failing where? We process over 100,000 multi-megabyte messages per day and have never hit this sort of an issue. > On Jun 22, 2018, at 1:20 AM, Tunikov, Eugeniy wrote: > > We are routing messages to service bus. And getting error when trying to send >

Re: [Camel route help] HL7 listener, to parse body, to base64 decode, pdf to file on filesystem

I’d have to work out all the XML syntax for this, but you should be able to use the HAPI Terser ( element in the XML) to extract the field you want. I’d probably do this in a bean - it’s easy to do the HL7 Decode at that point. Something like String myMethod(@Body ca.uhn.hl7v2.model.Message

Re: Type converter misbehavior with camel-cxf and camel-mail

Not sure if this is an option, but can you insert a call to a bean (or processor) before the CXF call that does the body conversion the way you want? > On Jun 13, 2018, at 3:30 AM, Willem Jiang wrote: > > Hi Bagwell, > > Thank you for share your experience of using the camel type converter. >

Re: On completion failure when doing file processing

Have you tried adding bridgeErrorHandler=true to the sftp operation? > On May 10, 2018, at 10:35 AM, Hugo Marcelino > wrote: > > Hello, > > I have inherited some code that is running Apache Camel and was asked if it > was possible to send a notification whenever

Re: How can I include common behavior in several routes?

Have you looked at using a RoutePolicy? http://camel.apache.org/routepolicy.html > On May 10, 2018, at 8:26 AM, Steve973 wrote: > > Hello. If I want, for example, to have several of my routes to be "status > aware", how might I

Re: MLLP and TLS

I hadn’t planned on that since none of the applications I’ve encountered so far support TLS connections, but it could be done. I’ve always had to use VPNs when SSL/TLS was required. > On Apr 13, 2018, at 1:46 AM, Walzer, Thomas > wrote: > > Hi everyone, > >

Re: Unit Test Polling Consumer

You could setup another HTTP route in your test that returns what you’re after to exercise your test conditions - I’ve done that quite a bit in the past. > On Mar 2, 2018, at 10:45 AM, Karel Bernolet wrote: > > Hello, > > --short version -- > > I am trying to unit

Re: Blueprint, property-place-holder error name is already instanciated as null and cannot be removed

t; > > update-strategy="reload” > placeholder-prefix="#{" placeholder-suffix="}"> > > > > > > > > >> O

Re: how to check a property inside of a exchange property

I’m assuming the simple block you shared is for the when clause, but it doesn’t have a comparison - did you miss something? I put together a quick test that shows one way to do this public class ScratchTest extends CamelTestSupport { static final String SOURCE_URI = "direct://source";

Re: Blueprint, property-place-holder error name is already instanciated as null and cannot be removed

Is that really the XML? It’s not well formed - you start with a cm:property-placeholder element and end with a cm:default-properties element. > On Feb 22, 2018, at 12:48 PM, Alex Soto wrote: > > Hello, > > I am having some problems migrating to Camel 2.20.2 from

Re: JMS: override Camel header type conversions?

> consistent, instead of a toString that may be OS locale dependent etc. > > Or it could store the value as a long value of the epoc. > > > > > On Mon, Feb 12, 2018 at 12:19 PM, Quinn Stevenson > <qu...@pronoia-solutions.com> wrote: >> Sorry -

Re: JMS: override Camel header type conversions?

Sorry - ignore that. That feature is used to customize the mapping of the key names - not the values. The only way I can think of right off hand is to add you’re own bean that manipulates the header values before you send them. > On Feb 12, 2018, at 10:14 AM, Quinn Stevenson <qu...@p

Re: JMS: override Camel header type conversions?

You can provide your own implementation using the jmsKeyFormatStrategy URI Option. > On Feb 12, 2018, at 8:34 AM, Probert, Matt > wrote: > > When messages are produced to ActiveMQ, Camel JmsBinding converts > java.util.Date message headers to string via

Re: Processed message counters

We do this by posting an auditing message to Splunk over HTTP. By doing that, we can not only get counts over a particular timeframe, but we can derive message rates as well. > On Jan 25, 2018, at 2:56 PM, Olivier Eymere wrote: > > I am looking for a way to keep running

Re: Backpropagate exception on direct: and vm: routes

Try adding true to the onException element Quinn Stevenson qu...@pronoia-solutions.com (801) 244-7758 > On Jan 12, 2018, at 10:44 AM, Miguel Ruiz Velasco Sobrino > <miguel...@fcm.com.mx> wrote: > > the same as me: > https://stackoverflow.com/questions/34617646/ret

Re: Backpropagate exception on direct: and vm: routes

I don’t see an element in the route - are you handling the exception? Quinn Stevenson qu...@pronoia-solutions.com (801) 244-7758 > On Jan 11, 2018, at 12:37 AM, Miguel Ruiz Velasco Sobrino > <miguel...@fcm.com.mx> wrote: > > Hi!, > > I have a route (direct: or VM:)

Re: MockEndpoint does not receive message if error occures in subroute

[do whatever needed] > > .to("seda:output"); > > > >from("direct:subroute") > > [do whatever needed] > > } > > > > Thanks > > Stephan >

Re: Set shutdown timeout with blueprint

se HOURS: units = "HOURS"; break; case DAYS: units = "DAYS"; } log.info("* Shutdown Timeout = {} {} *", exchange.getContext().getShutdownStrategy().getTimeout(), units); } } Can you share the full XML you are using? Quinn

Re: JMS Acknowledge mode

policies for the different types of exceptions, with appropriate redelivery handling. For the case where I don’t have an exception policy for an exception, Camel will rollback the message. I also use ActiveMQ, so the message will get moved to a DLQ after being rolled-back 6 times. HTH Quinn

Re: HL7/Using terser in Bean

If I understand what you’re asking, you could use a HAPI Terser (https://hapifhir.github.io/hapi-hl7v2/base/apidocs/ca/uhn/hl7v2/util/Terser.html <https://hapifhir.github.io/hapi-hl7v2/base/apidocs/ca/uhn/hl7v2/util/Terser.html>) in your bean. HTH Quinn Stevenson qu...@pronoia-solutio

Re: MockEndpoint does not receive message if error occures in subroute

test will pass. Quinn Stevenson qu...@pronoia-solutions.com (801) 244-7758 > On Dec 1, 2017, at 6:07 AM, Burkard Stephan <stephan.burk...@visana.ch> wrote: > > Hi Camel users > > I have attached a simplified example project (Maven) to illustrate a strange > problem I h

Re: Camel jdbc - select batch processing

I believe you’d need to split using a bean to accomplish what you’re after. Another method would be to split into single rows and then use the aggregator to create the batches of 200 rows each. > On Jun 2, 2017, at 2:51 AM, raja wrote: > > Hi all, >How to select batch of

Re: CamelContext Fails to start when consuming from a down database

I’ve dealt with situations like this using Blueprint reference-listeners. Basically, I setup a reference listener to start the context when a service becomes available (or restart the context if the service implementation is switched). For this to work, I had to write a little code that

Re: how to unit test a Java Route which uses a property-placeholder

I use CamelBlueprintTestSupport and the setConfigAdminInitialConfiguration method. > On May 16, 2017, at 9:23 AM, Mark wrote: > > I have a class that extends RouteBuilder and loaded from a blueprint file > using the tag. In my blueprint file I also use >

Re: Good / Adviced way to poll an entire folder at scheduled moment

I’ve done this with a combination of a ScheduledRoutePolicy (to start the route when I want to start reading the directory) and a call to the control bus when all the files have been processed. I use the “sendEmptyMessageWhenIdle” option on the file component to detect when it’s done. HTH >

Re: Re throwing exception

Have you tried using the “NoErrorHandler”? http://camel.apache.org/error-handler.html > On May 4, 2017, at 10:34 AM, las wrote: > > I have a route and an onException definition. My exception processor is > getting called. But

Re: Extensible Camel routes

This isn’t quite you’re use case since I don’t extend routes, but I have RouteBuilders that I deploy hundreds of times with different configurations using either camel-blueprint, camel-scr and Blueprint namespace handlers. I allow minor variations the routes based on the configuration of the

Re: how to enable Scala/Groovy route definition in camel web console

The only was I’ve seen routes added and removed from a Camel context dynamically is using OGSi and some sort of a service factory - here’s one example ( https://blog.avisi.nl/2014/06/05/creating-camel-routes-on-the-fly-using-osgi/

Re: How long do the camel headers live in routes?

The DSL for 1 looks OK. The DSL for option 2 should be using exchangeProperty.ROUTE_ID instead of property.ROUTE_ID if your Camel version is 2.15 or later. Can you share routes so we can see the details? > On Apr 5, 2017, at 7:21 AM, Amruta Jawlekar wrote: > > I have

Re: AggregationStrategy: null body in new exchange

version of Dozer are you using? I looked in v5.5.1 of the dozer-osgi bundle, and it isn’t there. Did you build dozer yourself and add this class? > On Apr 5, 2017, at 7:35 AM, JD Innocenti <jd.innoce...@gmail.com> wrote: > > Hi, > > Thanks for the reply! As I said to Quinn S

Re: AggregationStrategy: null body in new exchange

Can you share a little more of the route? Specifically I’d like to see the portion that is supposed to be reading the file and passing it on the the aggregation strategy. > On Apr 3, 2017, at 8:20 AM, JD Innocenti wrote: > > Hi all, > > I'm having a problem with

Re: Searching analog of getBean (Spring) in Blueprint

You get it from the Blueprint Container ( https://osgi.org/javadoc/r4v42/org/osgi/service/blueprint/container/BlueprintContainer.html#getComponentInstance(java.lang.String)

Re: Curious routing case

I’d probably use ActiveMQ Message Groups for this http://activemq.apache.org/message-groups.html > On Mar 31, 2017, at 9:08 AM, Artur Jablonski wrote: > > Hello. > > I wonder if someone could push me in the right

Re: Using rollback() inside onException

I don’t this this would make sense for handling java.lang.Exception - I think you’re right about Camel doing the same action by default. I guess if there was some other exception you were handling (i.e. handled(true)), you may want to call rollback - but I can’t think of a really good example

Re: Camel instanciated as null

You’re absolutely correct about the bundle import - if you’re loading the blueprint via the deploy folder, Karaf is creating a bundle for you based on what it sees in the Blueprint. If you’re still seeing the same resolution error (about the org.apache.activemq package) look at the MANIFEST.MF

Re: Camel instanciated as null

This is the RedeliveryPolicy I was referring to (copied from your sample). Regardless, the error you’re seeing is that the org.apache.activemq package isn’t exported by any bundles, but you’re importing it. I’d look and make sure you’re not referencing anything

Re: Camel instanciated as null

It looks like you have an ActiveMQ RedeliveryPolicy - I think you meant to use a Camel Redelivery Policy? > On Mar 29, 2017, at 2:25 PM, mtod09 wrote: > > In JMX I get no entries for this Camel route others work fine that do not use > Artemis. > Log's give me no errors. >

Re: Camel instanciated as null

When you say “it doesn’t run” - what exactly do you see? Can you see the context in JMX? Or is the route just not processing any messages? > On Mar 27, 2017, at 7:58 PM, mtod09 wrote: > > I cleaned this up a bit it loads without any errors but does not run anyone > have

Re: SEDA vs embedded ActiveMQ

IMO, if you need features that ActiveMQ provides (publish/subscribe semantics (JMS Topics), message expiration, Virtual Topics) then an Embedded ActiveMQ broker makes sense. If SEDA does what you need, I think I’d stick with that. > On Mar 29, 2017, at 6:23 AM, Mark Nuttall

Re: Need help retaining files in source folder..

Did you try setting idempotent=false in addition to noop=true? I know noop=true sets idempotent=true, but you may be able to override it. > On Mar 23, 2017, at 2:09 PM, Hari wrote: > > Thank you souciance.. > > I need the file in same folder, as eventually, there would

Re: how to config two routes use the same endpoint?

Could you define route A to send the message to an intermediary (vm endpoint, jms, seda) and then have the other routes consume from there? > On Mar 8, 2017, at 4:54 AM, vonezzz <34618...@qq.com> wrote: > > i want to use two routedefine,not one route. > > > > -- > View this message in

Re: Message is lost while the connection to ActiveMQ is refreshed

Are you using a transacted session with ActiveMQ? > On Mar 20, 2017, at 12:49 PM, hammod wrote: > > I am receiving a message from a client using a netty interface and this > message should be sent to ActiveMQ to be saved. > All is good but if I dropped the connection

Re: Camel with Karaf + Blueprint

Could you share you’re blueprint XML files? I use Blueprint + Karaf extensively, and I’ve always got into trouble if I mistakenly use the Spring namespace. I’d be interested to see what is different about your Blueprint XML files. > On Mar 9, 2017, at 8:24 AM, kumar

Re: Karaf +Camel Blueprint not able to load bean from other active bundles.

Under Blueprint, beans are not directly available across Blueprint contexts. Exposing the beans as services (as you have done) is how you expose them for consumption by other bundles, but you need to reference the services - not the beans directly. > On Mar 14, 2017, at 10:18 AM, kumar

Re: logging/incrementing simple counter

uri="file:{{in.path}}?move=done/${bean:inboundCounter.incrementAndGet}-finished.txt"/> > > This produces a folder called: > C:\temp\in\done\inboundCounter.incrementAndGet-finished.txt > With file: testNaming.xml > > > > > -Original Mes

Re: logging/incrementing simple counter

n the file components move attribute! > uri="file:{{in.path}}?moveFailed=.failed/$simple{file:onlyname}move={{archive-from-erp.path}}/${bean:inboundCounter.incrementAndGet}-{{common.fname.pattern}}"/> > > > -Original Message- > From: Quinn Stevenson [mail

Re: logging/incrementing simple counter

I’d probably use and AtomicLong for this specific use case http://camel.apache.org/schema/spring;> > On Dec 29, 2016, at 2:49 PM, Baltej Singh wrote: > > Following code works, but is there a better way to define the constant 1L in >

Re: Debug exec of python script

Did you try logging the headers? .log( “Stderr: ${header[CamelExecStderr]} ) or .log( “Exit Value: ${header[CamelExecExitValue]} ) Quinn Stevenson qu...@pronoia-solutions.com (801) 244-7758 > On Dec 28, 2016, at 2:13 PM, jgewehr <jgew...@gmail.com> wrote: > > I'm trying to

Re: logging/incrementing simple counter

Try this > On Dec 22, 2016, at 12:45 PM, Baltej Singh wrote: > > Tring to create a simple counter to track some stats, not using the metrics > related components. > Just need to log execCount and do execCount++ everytime route is entered. > What is the syntax for

Re: org.apache.camel.ResolveEndpointFailedException

If I’m reading the error message correctly, it’s failing to set the bus attribute for the cxfcore:bus element because it’s looking for a org.apache.cxf.Bus object and not a String, and it can’t find an object named sfsfBus in the registry. I don’t use CXF much, but I’d check the

Re: camel-core not detecting converters on bundle restart in karaf4

One clarification on this (since it really threw me off for a while). camel-blueprint and camel-spring-dm both include the classes from camel-core-osgi when they are packaged, while camel-scr references them from their own bundle. What that means is if you install camel-blueprint feature, you

Re: Start and Stop ActiveMQ consuming

You could use the Control Bus EIP ( https://camel.apache.org/controlbus.html ) to shutdown the ActiveMQ route when it’s complete. > On Dec 19, 2016, at 5:55 AM, DanielArias wrote: > > Hi, good morning > > I'm trying to read from an

Re: howto aggregate to csv file

Have you tried using pollEnrich to pull in the second file? Something like from(uri).unmarshal().csv() .pollEnrich(“uri”, aggregationStrategy) .marshal().csv() .to(“final file uri”); > On Dec 19, 2016, at 7:19 AM, Richter, Thomas wrote: > > Moin @all, > I have two

Re: camel-core not detecting converters on bundle restart in karaf4

I don’t know enough about how you are doing this to be sure, but this sounds suspiciously similar to an issue I’ve been fighting for quite a while now. I don’t know if it applies, but you may want to look at the workaround in this ticket ( https://issues.apache.org/jira/browse/CAMEL-9570

Re: Simple IN with empty value in list

Maybe something like this would work? .choice.when.simple("${body.stringValue.isEmpty} || ${body.stringValue} in 'gold,silver’") > On Dec 2, 2016, at 9:23 AM, Claus Ibsen wrote: > > I dont think an empty value is supported > > On Fri, Dec 2, 2016 at 3:59 PM, Karts

Re: camel-jms

You’re not missing anything - that’s the way the camel-jms and camel-sjms components work. They get a connection from the connection factory when they startup, and the keep using it. You can configure the Camel route to handle some JMS Exceptions and sometimes get the reconnect to work that

Re: camel-jms

If you’re using ActiveMQ, use a failover URL ( http://activemq.apache.org/how-do-i-configure-automatic-reconnection.html ) and both camel-jms and camel-sjms will reconnect. > On Nov 30, 2016, at 11:38 AM, sa_james

Re: How to use the InOut (Request-Reply) pattern in combination with REST/Jetty?

nt", >> "true"); >> >> rest("/API/").get("/object/{ID}/").to("direct:objectGet"); >> >>from("direct:objectGet").to(ExchangePattern.InOut, >> "activemq:test").process(resultProcessor).to("activemq:test"); >> &g

Re: How to use the InOut (Request-Reply) pattern in combination with REST/Jetty?

I created a simple example of JMS request-response with Camel a while ago - it may help ( https://github.com/hqstevenson/camel-jms-request-response-example.git <https://github.com/hqstevenson/camel-jms-request-response-example.git> ) > On Nov 28, 2016, at 9:35 AM, Quinn Stev

Re: How to use the InOut (Request-Reply) pattern in combination with REST/Jetty?

Yes - this is possible. Look at "Request-Reply” in the JMS docs ( http://camel.apache.org/jms.html ). > On Nov 28, 2016, at 12:51 AM, Frank Wein wrote: > > Hi all, > some additional info/Java code: What I have currently working is some

Re: exception handling

A little clarification - the order does matter, but not as much as it does in Java. For the code snippets you posted, it doesn’t make any difference. You’ve defined one onException block than handles multiple exceptions. The order of the onException blocks themselves can effect which block

Re: Large message handling

I think the EIP you’re referring to is the “Claim Check” pattern ( http://www.enterpriseintegrationpatterns.com/patterns/messaging/StoreInLibrary.html ), and Camel does support that EIP (

Re: Best way to build a wait/retry loop with Camel?

James brings up a very good point. I know ActiveMQ isn’t designed for long-term messages, and it’s bit me a couple of times with KahaDB. What happened was I had quite a few old messages, but they were spaced out over time. KahaDB doesn’t compact files, and it can’t delete files until all

Re: Camel zero routes started upon startup of context

>> >> >> >> >> >> >> >> >> > persistent-id="DemoImportPersistentId" >> update-strategy="reload"> >> >> >> >> >> >> >> >> &

Re: Camel zero routes started upon startup of context

Can you share the Blueprint XML? > On Nov 2, 2016, at 12:53 PM, souciance > wrote: > > I am using camel-blueprint 2.17.0 and the blueprint simply states the > routes and I use the java dsl to implement the routes. Everything is > deployed to Karaf 4.0.2. > >

Re: Conditional Polling Consumer

Sorry - yes, you’re using the right thing. The enrich DSL would use a producer, which isn’t what you were looking for - pollEnrich is the right choice. Sorry for any confusion I may have caused - I’m glad you got it working in spite of my mis-information ;-) > On Nov 2, 2016, at 1:53 AM,

Re: Conditional Polling Consumer

Try enrich() http://camel.apache.org/content-enricher.html > On Nov 1, 2016, at 1:30 PM, Kasim Sert wrote: > > I have an apache camel application which runs as three identical services > in production environment for

Re: Losing mi sanity on pipeline testing

I don’t think DataSet is going to do what you’re after. You could try a mock endpoint, and use returnReplyBody(…) to specify the response - that may do what you’re after > On Oct 28, 2016, at 1:18 AM, Edoardo Causarano > wrote: > > Hi Quinn, > > Thanks that's

Re: Losing mi sanity on pipeline testing

I’m assuming you’re just trying to get the DataSet to work for testing - correct? (DataSet isn’t really meant for anything other than testing). If that’s the case, use the DataSet as the Consumer - i.e. from(“dataset://source”) and you should be OK. > On Oct 27, 2016, at 7:15 AM, Edoardo

Re: OnException across camelcontext not called when using direct-vm

I see there isn’t any exception handling in context2, but the default error handler is still there - have you tried setting the error handler on the context to “No Error Handler”? (http://camel.apache.org/error-handler.html ) > On Oct 25, 2016, at

  1   2   3   4   >