IBM MQ to Active MQ migration

I want to migrate applications from IBM MQ to Active MQ. I would prefer using camel. Since I am new to this technology, I would appreciate if someone helps me to build it from scratch. -- View this message in context: http://camel.465427.n5.nabble.com/IBM-MQ-to-Active-MQ-migration-tp5783408.htm

issue with tracer

Hi, i have custom tracer class which extends AppenderSkeleton. this maps Camel framework logging events to my custom logging framework events. i expects this class to be called when camelcontext is loaded.. i have added below information to camel context i have camel fr

Camel ScheduledPollEndpoint class scheduler setup in SqlComponent

hi, I have created an endpoint like: But when I do that, jvm throws: org.apache.camel.FailedToCreateConsumerException: Failed to create Consumer for endpoint: Endpoint[sql://$select * from dual?dataSourceRef=veloxityDS&scheduler=spring&scheduler.cron=0+6+8++&useIterator=false]. Reason: There a

Re: How to stop a dynamic route

If you see, I have a do-while monitoring the value of the var CamelBatchComplete, then when is true, stop and remove the route from Camel Context. I don't like this. My question is, there a better way to stop and remove the route when the Batch finish? Using the RouteBuilder for example. Thanks.

How to stop a dynamic route

Hi, I created a project, I want that the route stops when the Camel Batch are complete, I used SimpleScheduledRoutePolicy but you have to define a start an end date, and always stop the route before the route finish to process. I did this, works fine, but I think there is a better way //Creamos

Re: Problem transfer from SMB to FTP OutMemory Java Heap Space

Hi Pontus, sorry Im new in Fuse. The Camel version is 2.12.0 how I can defined the heap size to the Java Process? I add localWorkDirectory into the URI, but fail again, this localWorkDirectory is a directory in Fuse or in the smb server? I put in the localWorkDirectory in smb. I saw localWorkDi

RE: File Consumer Exchange

Hi, You can use the "no operation" functionality. See noop=true @ http://camel.apache.org/file2.html -Oorspronkelijk bericht- Van: bwest [mailto:bwesterfi...@gmail.com] Verzonden: Friday 3 June 2016 1:19 Aan: users@camel.apache.org Onderwerp: File Consumer Exchange Can I ignore an exc

Re: Camel blueprint: Unable to load class org.apache.camel.builder.LoggingErrorHandler

Try changing LoggingErrorHandler to LoggingErrorHandlerBuilder > On Jun 1, 2016, at 10:56 AM, Alex Soto wrote: > > class="org.apache.camel.builder.LoggingErrorHandler"> > >

File Consumer Exchange

Can I ignore an exchange that's been picked up by a file consumer? In other words, I don't want the file to be moved or deleted. I'd like to remain in the directory for other subsequent polls. Thanks! -- View this message in context: http://camel.465427.n5.nabble.com/File-Consumer-Exchan

RE: camel-test-cdi + OpenEJB fails on weld dependency?

It did! Added this: @Produces Validator createValidator(){ Configuration config = Validation.byDefaultProvider().configure(); ValidatorFactory factory = config.buildValidatorFactory(); return factory.getValidator(); } It works now! Cheers, Dmitry -Origina

Re: camel-test-cdi + OpenEJB fails on weld dependency?

https://github.com/apache/bval/blob/trunk/bval-jsr/src/main/java/org/apache/bval/cdi/BValExtension.java#L251 should do it Romain Manni-Bucau @rmannibucau | Blog | Github | LinkedIn

RE: camel-test-cdi + OpenEJB fails on weld dependency?

Makes sense, Thanks Romain. Although I reported that my test is working it's only partially true. I have two test classes so far, one is annotated with @RunWith(CdiTestRunner.class) - it runs without problem, another is annotated with @RunWith(CamelCdiRunner.class) fails with this exception: or

Re: Updating datasource at runtime with camel-sql

If you’re willing to use camel-scr or camel-blueprint, you can make this happen pretty easily. You’d expose the data source as a service, and then inject it into the route - the exact method would change based on whether you’re using camel-scr or camel-blueprint. If you’re using camel-scr, whe

Uninstalling Blueprint bundle using ActiveMQ PooledConnectionFactory causes javax.jms.IllegalStateException: The Consumer is closed

I am using Camel (tried 2.15.2 and 2.16.3) and the activemq-camel (tried 5.12.1 and 5.13.3) component to hook up the routes in my bundle to an external ActiveMQ server. The bundle is deployed in Karaf (tried 3.0.5 and 4.0.5) and started via a Blueprint context (containing the Camel context). The bu

RE: HTTPS Component with SMTP Mail

Stephan, Adding .removeHeaders("*") fixed the problem. It works great! Being new to Camel, I guess this is a "gotcha". Thanks for your help. -- View this message in context: http://camel.465427.n5.nabble.com/HTTPS-Component-with-SMTP-Mail-tp5783362p5783392.html Sent from the Camel - Users ma

Re: How to stop a dynamic route

So, what is your question? On Thu, Jun 2, 2016 at 11:56 AM, Daniel Pompa [via Camel] < ml-node+s465427n5783385...@n5.nabble.com> wrote: > Hi, I created a project, I want that the route stops when the Camel Batch > are complete, I used > SimpleScheduledRoutePolicy but you have to define a start an

Re: Problem transfer from SMB to FTP OutMemory Java Heap Space

Which version of Camel and Camel Extra are you using ? What heap size have you allocated to the Java process ? Have you tried adding the localWorkDirectory URI option to the smb URI to avoid loading the file content into memory ? Best regard Pontus Ullgren On Thu, 2 Jun 2016 at 11:40 Daniel Pomp

Re: QuartzScheduler, reschedule running route

It's simple, remove route , replace fromDefintion & add reoute: RouteDefinition d = context.getRouteDefinition(routeId); context.removeRouteDefinition(d); List inputs = d.getInputs(); for (FromDefinition fromDefinition : inputs) fromDefinition.setUri(uri.replace(oldScheduler, newS

Problem transfer from SMB to FTP OutMemory Java Heap Space

I have a problema with Fuse. I created a route, http://camel.apache.org/schema/spring"; id="sap-xrt-connect-interface-receive-20160414"> ${property.CamelBatchComplete} net.aqualogy.sap.xrt.connect.S

Re: Q about how to help the file2 component to do a better job

Not sure if this helps but I had to go from a file with stream to third party library which wanted a Reader and I used this: //enforce UTF-8 encoding where stream is an InputStream stream = new ByteArrayInputStream(exchange.getIn().getBody().toString(). getBytes("UTF-8")); Then go from the stream

Q about how to help the file2 component to do a better job

Hi, we are using servicemix and I had a problem which was related to the time when that servicemix's JVM started. Aparently, it started before the operating system's locale was set to something UTF-8ish. I solved it (fingers crossed) by making sure that the system property "file.encoding" is e