Camel Spring boot WAR not executing
hello,
I have a camel spring application , which runs fine from eclipse using the
spring:run goal. But when i tried to execute it from command line using
java -jar , it does not run and throws the below error. I am using camel
2.17.3 and spring boot 1.4.0 release.
org.springframework.beans.factory.BeanDefinitionStoreException: Failed to
process import candidates for configuration class
[org.apache.camel.spring.boot.CamelAutoConfiguration]; nested exception is
java.lang.ClassCastException: java.lang.IndexOutOfBoundsException cannot be
cast to [Ljava.lang.Object;
at
org.springframework.context.annotation.ConfigurationClassParser.processImports(ConfigurationClassParser.java:546)
~[spring-context-4.3.2.RELEASE.jar!/:4.3.2.RELEASE]
at
org.springframework.context.annotation.ConfigurationClassParser.doProcessConfigurationClass(ConfigurationClassParser.java:286)
~[spring-context-4.3.2.RELEASE.jar!/:4.3.2.RELEASE].
I even tried to exclude the CamelAutoConfiguration class from the
Enableautoconfiguration but it fails and says class not found. Inside the
Lib folder of the WAR i also see the jar present
camel-spring-boot-2.17.3.jar.
It looks like some packaging issue for WAR, but I am not able to pinpoint
it. I even tried using the spring-boot-starter-parent but still same error.
My pom.xml as below
http://maven.apache.org/POM/4.0.0;
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance;
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0
http://maven.apache.org/maven-v4_0_0.xsd;>
4.0.0
com.boot
wl-loader-boot
war
0.0.1-SNAPSHOT
wl-loader-boot Webapp
2.17.3
UTF-8
1.7.21
2.5
1.4.0.RELEASE
com.boot.DLBootApplication
org.springframework.boot
spring-boot-dependencies
${spring-boot-version}
pom
import
org.apache.camel
camel-spring-boot
${camel.version}
org.apache.camel
camel-jms
${camel.version}
org.apache.camel
camel-csv
${camel.version}
javax.jms
jms
1.1
javax.jms
javax.jms-api
2.0
org.springframework.boot
spring-boot-starter-web
org.springframework.boot
spring-boot-starter-jdbc
org.springframework.boot
spring-boot-starter-actuator
org.springframework.boot
spring-boot-starter-remote-shell
org.apache.camel
camel-commands-spring-boot
${camel.version}
org.springframework.boot
spring-boot-starter-test
test
org.slf4j
slf4j-api
${slf4j.version}
commons-dbcp
commons-dbcp2
2.1.1
org.apache.commons
commons-pool2
com.oracle
ojdbc6
11.2.0.3
junit
junit
test
org.beanio
beanio
2.1.0
org.apache.commons
commons-lang3
3.4
commons-beanutils
commons-beanutils
com.ibm.mq.client
mq-client
8.0.0.4
org.apache.maven.plugins
maven-compiler-plugin
3.5.1
1.8
1.8
Spring Boot - FatJarRouter or Non FatJar Router
hi,
I am converting my existing spring XML based camel apllication to Spring
boot. I saw the existing examples of camel spring boot.
My issue is I want to load my existing beans & routes which are there in the
camelcontext xml directly .
So I am not sure how do i load my context.xml using the FarjarRouter (if
its possible ) or do i have to use non Fat jar approach.
I have the below entries in my web.xml .
Web Application
contextConfigLocation
file:///${camel.config.location}
location of spring xml files
log4jConfigLocation
file:///${log4j.config.location}
log4jRefreshInterval
1
org.springframework.web.context.ContextLoaderListener
org.springframework.web.util.Log4jConfigListener
--
View this message in context:
http://camel.465427.n5.nabble.com/Spring-Boot-FatJarRouter-or-Non-FatJar-Router-tp5786417.html
Sent from the Camel - Users mailing list archive at Nabble.com.
Re: Camel Suspend moving file to error folder.
Hello, I want the file to remain where it is even if the camel route is suspended. -- View this message in context: http://camel.465427.n5.nabble.com/Camel-Suspend-moving-file-to-error-folder-tp5786039p5786152.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: Camel Suspend moving file to error folder.
any tips or hints guys ? -- View this message in context: http://camel.465427.n5.nabble.com/Camel-Suspend-moving-file-to-error-folder-tp5786039p5786134.html Sent from the Camel - Users mailing list archive at Nabble.com.
Camel Suspend moving file to error folder.
Hello,
I want to know if there is a way to handle this below scenario in which the
file which is being processed get moved to the error folder when the camel
route is suspended. So when i resume the route the file is not there to be
processed . I thought suspend means kinda a wait\sleep process thread. I
tried with the
true & false flag but the outcome
was same, the file got moved to the error folder. I want to resume the
processing the file from the same state in which the route was suspended.
(if its possible)
the processor called is which
suspends all routes.
com.XXX.exception.ErrorThresHoldException
false
java.sql.SQLRecoverableException
java.net.ConnectException
org.springframework.jdbc.CannotGetJdbcConnectionException
true
java.lang.Exception
false
${body} != null
--
View this message in context:
http://camel.465427.n5.nabble.com/Camel-Suspend-moving-file-to-error-folder-tp5786039.html
Sent from the Camel - Users mailing list archive at Nabble.com.
Re: Suspend All routes & Resume incase of Business Exception
Thanks for the Tip -- View this message in context: http://camel.465427.n5.nabble.com/Suspend-All-routes-Resume-incase-of-Business-Exception-tp5785773p5785818.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: Suspend All routes & Resume incase of Business Exception
So you are suggesting I stop each route one by one and resume it also similar fashion . If multiple share the same process, do you think there could be issue of a similar (Stop) thread getting called in respective routes ? Since the logic will be defined in all routes. -- View this message in context: http://camel.465427.n5.nabble.com/Suspend-All-routes-Resume-incase-of-Business-Exception-tp5785773p5785775.html Sent from the Camel - Users mailing list archive at Nabble.com.
Suspend All routes & Resume incase of Business Exception
hello, I wish to know which would be the best approach to Suspend and resume all routes in the context . I saw the route policy approach but it is linked to each route. I want a Global Context policy in which I can suspend route and resume also . For example if there is a DB failure all routes should suspend and my custom code will listen for the connections being active and resume the routes again. -- View this message in context: http://camel.465427.n5.nabble.com/Suspend-All-routes-Resume-incase-of-Business-Exception-tp5785773.html Sent from the Camel - Users mailing list archive at Nabble.com.
Why is camel ignoring Startp event error
hello , I see in my logs the below *2016-07-26 15:39:11,523 WARN [org.apache.camel.spring.Main.main()] (EventHelper.java :807) - Error notifying event Starting CamelContext: camel-1. This exception will be ignored. * java.sql.SQLException: Cannot create PoolableConnectionFactory (IO Error: The Network Adapter could not establish the connection) I am not sure why camel is ignoring this exception. I have tried to use a Onexception clause but apparantely my bean does not get called also. below the camelcontext http://camel.apache.org/schema/spring; > java.sql.SQLException true -- View this message in context: http://camel.465427.n5.nabble.com/Why-is-camel-ignoring-Startp-event-error-tp5785465.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: Camel Spring Bean error Handling
hi, I am not using any specific camel componenet to access DB. just plain old JDBC after getting the datasource which is injected in the bean. My main issue to track the DB connection issues which is happening in my custom code when the issue goes more than a limit suspend all the routes running in the camelcontext. -- View this message in context: http://camel.465427.n5.nabble.com/Camel-Spring-Bean-error-Handling-tp5785414p5785450.html Sent from the Camel - Users mailing list archive at Nabble.com.
Camel Spring Bean error Handling
Hello, My question is not Camel specific but more Spring bean handling issue. My issue is that even if there is an error in bean initialization the camel route starts . I want the camel context only started if there was no errors in Bean initialization . Some of beans are custom but some are third party for example DC connection & JMS connection. Exampe below Datasource . Incase there is a connection failure on startup is see exception thrown in logs but the camel context is started . I want to avoid this. I saw in spring there are ApllicationEevents handling but i dont see specific to bean handling . Is there a good way to handle this. Thx, Fx -- View this message in context: http://camel.465427.n5.nabble.com/Camel-Spring-Bean-error-Handling-tp5785414.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: Route ID in camel logger
it works fine alright as you mentioned but I want to use the throughput option i.e. groupInterval & groupDelay i tried with it does not work. -- View this message in context: http://camel.465427.n5.nabble.com/Route-ID-in-camel-logger-tp5785348p5785355.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: Route ID in camel logger
hi, tried with showHeaders=true does not display additional information and also with showAll only the below gets logged :159) - Received: 400 new messages, with total 400 so far. Last group took: 2269 millis which is: 176.289 messages per second. average: 176.289 -- View this message in context: http://camel.465427.n5.nabble.com/Route-ID-in-camel-logger-tp5785348p5785350.html Sent from the Camel - Users mailing list archive at Nabble.com.
Route ID in camel logger
hello, Is there anyway i can just get the Route ID also printed in the logger . My definition is as below. Or Do i need to use my own CustomFormatter in order to do so. -- View this message in context: http://camel.465427.n5.nabble.com/Route-ID-in-camel-logger-tp5785348.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: Time taken to read messages from queue
hello, I just want to mesaure how much camel JMS component take to read from queue, I dont want the complete exchange time take. I think using a Bean I can measure it which is the only clean option i see. Using grouplog of camel is an option, but I am not sure how many messages are there in queue to set the counter for it. Thanks. -- View this message in context: http://camel.465427.n5.nabble.com/Time-taken-to-read-messages-from-queue-tp5785225p5785265.html Sent from the Camel - Users mailing list archive at Nabble.com.
Time taken to read messages from queue
Hello, I want to know if there is a simple way in camel to measure the time taken by route to read all messages present in the queue. Example My queue get populated on some time intervals , so i want to know how time it took just for the JMS component to read from the queue and not the full time cycle of the exchange. MY route as below java.lang.Exception false true I want only the time taken by the route to read the all the messages in the queue present at the time. Like a batch total time . -- View this message in context: http://camel.465427.n5.nabble.com/Time-taken-to-read-messages-from-queue-tp5785225.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: Not move file on custom exception thown (file component)
Solved the issue , using a custom logic in processor . So it works fine. currently Only problem was that the Stop processor thread was taking time to shutdown route. So added a delay to counter that. Thanks all for the inputs. -- View this message in context: http://camel.465427.n5.nabble.com/Not-move-file-on-custom-exception-thown-file-component-tp5779476p5779563.html Sent from the Camel - Users mailing list archive at Nabble.com.
RE: Not move file on custom exception thown (file component)
Do you mean in runtime change the permission depending on the exception raised. I dont think it will be possible to change in between with a camel lock in place on that file. I could try though ! -- View this message in context: http://camel.465427.n5.nabble.com/Not-move-file-on-custom-exception-thown-file-component-tp5779476p5779495.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: Not move file on custom exception thown (file component)
you are right Claus ! . But I stop the route to avoid that problem (if you see the stop processor). There will be manual intervention to handle this exception , thats why i have to keep the file at the same place. -- View this message in context: http://camel.465427.n5.nabble.com/Not-move-file-on-custom-exception-thown-file-component-tp5779476p5779485.html Sent from the Camel - Users mailing list archive at Nabble.com.
Not move file on custom exception thown (file component)
hello,
I have a below route configuration, my problem is that I don't want camel
to move the file to error Or complete folder incase i throw a custom
exception while processing . But currently it moves the file to complete or
error if I handle the exception true/false. Is there a way to make camel
leave the file as it is in the same folder. I am stopping the route for the
exception "com.exception.FileSequenceException" which works but the file
gets moved, which i want to avoid in this special scenario.
com.exception.ErrorThresHoldException
com.exception.InvalidFileException
false
com.exception.FileSequenceException
true
java.lang.Exception
false
${body} != null
--
View this message in context:
http://camel.465427.n5.nabble.com/Not-move-file-on-custom-exception-thown-file-component-tp5779476.html
Sent from the Camel - Users mailing list archive at Nabble.com.
Re: JMS Route not shutting down (in hang mode forever)
okay, saw a post of stopping using a different route thread, now it stops. However I want to log the exception in my routepolicy. Is there anyway I can get the exception in the route object. -- View this message in context: http://camel.465427.n5.nabble.com/JMS-Route-not-shutting-down-in-hang-mode-forever-tp5778736p5778737.html Sent from the Camel - Users mailing list archive at Nabble.com.
JMS Route not shutting down (in hang mode forever)
hello, I have configured the defaultshutdown timeout & configured the route as below , but the the route does not stop properly . I can see the DefaultShutdownStrategy being called but it not forcing to close the route. - JmsConsumer[TESTQ]] ( DefaultShutdownStrategy.doShutdown : 230) | Timeout occurred during graceful shutdown. Forcing the routes to be shutdown now. Notice: some resources may still be running as graceful shutdown did not complete successfully. 2016-03-08 11:46:56,984 WARN [Camel (camel-1) thread #2 - ShutdownTask] ( DefaultShutdownStrategy.run : 639) | Interrupted while waiting during graceful shutdown, will force shutdown now. 2016-03-08 11:46:56,985 DEBUG [Camel (camel-1) thread #1 - JmsConsumer[TESTQ]] (sMessageListenerContainer.stop: 127) | Stopping listenerContainer: org.apache.camel.component.jms.DefaultJmsMessageListenerContainer@7d47e9b with cacheLevel: 3 and sharedConnectionEnabled: true 2016-03-08 11:46:56,985 INFO [Camel (camel-1) thread #2 - ShutdownTask] ( DefaultShutdownStrategy.run : 668) | Route: ProcessQueue shutdown complete, was consuming from: Endpoint[wmq://queue:TESTQ] 2016-03-08 11:46:56,986 DEBUG [Camel (camel-1) thread #1 - JmsConsumer[TESTQ]] (sMessageListenerContainer.stopSharedConnection: 156) | Stopping shared connection on listenerContainer: org.apache.camel.component.jms.DefaultJmsMessageListenerContainer@7d47e9b 2016-03-08 11:46:56,986 DEBUG [Camel (camel-1) thread #1 - JmsConsumer[TESTQ]] (sMessageListenerContainer.destroy : 141) | Destroying listenerContainer: org.apache.camel.component.jms.DefaultJmsMessageListenerContainer@7d47e9b with cacheLevel: 3 and sharedConnectionEnabled: true 2016-03-08 11:46:56,986 DEBUG [Camel (camel-1) thread #1 - JmsConsumer[TESTQ]] (sMessageListenerContainer.shutdown: 215) | Shutting down JMS listener container 2016-03-08 11:46:56,987 DEBUG [Camel (camel-1) thread #1 - JmsConsumer[TESTQ]] (sMessageListenerContainer.doShutdown : 557) | Waiting for shutdown of message listener invokers 2016-03-08 11:46:56,987 DEBUG [Camel (camel-1) thread #1 - JmsConsumer[TESTQ]] (sMessageListenerContainer.doShutdown : 563) | Still waiting for shutdown of 1 message listener invokers 2016-03-08 11:46:57,987 DEBUG [Camel (camel-1) thread #1 - JmsConsumer[TESTQ]] (sMessageListenerContainer.doShutdown : 563) | Still waiting for shutdown of 1 message listener invokers 2016-03-08 11:46:58,987 DEBUG [Camel (camel-1) thread #1 - JmsConsumer[TESTQ]] (sMessageListenerContainer.doShutdown : 563) | Still waiting for shutdown of 1 message listener invokers 2016-03-08 11:46:59,987 DEBUG [Camel (camel-1) thread #1 - JmsConsumer[TESTQ]] (sMessageListenerContainer.doShutdown : 563) | Still waiting for shutdown of 1 message listener invokers 2016-03-08 11:47:00,987 DEBUG [Camel (camel-1) thread #1 - JmsConsumer[TESTQ]] (sMessageListenerContainer.doShutdown : 563) | Still waiting for shutdown of 1 message listener invokers 2016-03-08 11:47:01,987 DEBUG [Camel (camel-1) thread #1 - JmsConsumer[TESTQ]] (sMessageListenerContainer.doShutdown : 563) | Still waiting for shutdown of 1 message listener invokers 2016-03-08 11:47:02,987 DEBUG [Camel (camel-1) thread #1 - JmsConsumer[TESTQ]] (sMessageListenerContainer.doShutdown : 563) | Still waiting for shutdown of 1 message listener invokers 2016-03-08 11:47:03,987 DEBUG [Camel (camel-1) thread #1 - JmsConsumer[TESTQ]] (sMessageListenerContainer.doShutdown : 563) | Still waiting for shutdown of 1 message listener invokers 2016-03-08 11:47:04,987 DEBUG [Camel (camel-1) thread #1 - JmsConsumer[TESTQ]] (sMessageListenerContainer.doShutdown : 563) | Still waiting for shutdown of 1 message listener invokers Configuration:- java.lang.Exception false true Any Ideas ? -- View this message in context: http://camel.465427.n5.nabble.com/JMS-Route-not-shutting-down-in-hang-mode-forever-tp5778736.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: camel beanIO componenet , is it meant for parsing large files ???
Sure , i will take a look -- View this message in context: http://camel.465427.n5.nabble.com/camel-beanIO-componenet-is-it-meant-for-parsing-large-files-tp5778470p5778489.html Sent from the Camel - Users mailing list archive at Nabble.com.
camel beanIO componenet , is it meant for parsing large files ???
hello,
I was planning to use the camel beanIO component , but I saw something in
its implementation that beats the reasoning of processing large files using
beanIO .
In readModels(Exchange exchange, InputStream stream) method
Object readObject;
while ((readObject = in.read()) != null) {
if (readObject instanceof BeanIOHeader) {
exchange.getOut().getHeaders().putAll(((BeanIOHeader)
readObject).getHeaders());
}
results.add(readObject);
}
return results;
#
Here the List of objects are added and returned only after the whole file is
read, so in case of a very big file There could be memeory issues ?. Hope my
understanding is right .
While in.read will only load one line at a time but the List of read Objects
will have a the whole file in memory.
regards,
Felix T
--
View this message in context:
http://camel.465427.n5.nabble.com/camel-beanIO-componenet-is-it-meant-for-parsing-large-files-tp5778470.html
Sent from the Camel - Users mailing list archive at Nabble.com.
JMS Prefetch size for MQ series.
hello,
Is there any prefetch option for the JMS componenet, I see option in
ActiveMQ component.
I want to fetch 100 messages at a time from a queue .
I have configured as below, I am able to connect using connection
Factory.
However I have a query about the ackknwledgement mode. I tried with
client mode, but I expected the messages to be in unackowledment mode untill
I ackowledge from my processor or bean, but the messages are removed when i
read them . IS it some setting at the MQ server level or my undertsatnding
is wrong ?.
java.lang.Exception
false
${body} != null
--
View this message in context:
http://camel.465427.n5.nabble.com/JMS-Prefetch-size-for-MQ-series-tp5778294.html
Sent from the Camel - Users mailing list archive at Nabble.com.
Re: Camel BeanIO catch and ignore InvalidRecordException
hello, I have exactly same issue with the beanIO component. The solution I saw was handling the error at bean Reader level. i.e. by registering your custom ErrorHandler in BeanReader. But how do we do it using camel is mystery for me . -- View this message in context: http://camel.465427.n5.nabble.com/Camel-BeanIO-catch-and-ignore-InvalidRecordException-tp5762999p5777667.html Sent from the Camel - Users mailing list archive at Nabble.com.
pass custom constant value to a bean in Spring XML
hello, I am trying to pass a constant value which is defined in a class, but it does not work .I am using 2.16.1 version of camel. I have defined as below in the XML. But the value of the Constant is not passed to the method and is always NULL. Is there anyway I can Re use the Constants from a Java class or I need to Hard code it ? rx Felix -- View this message in context: http://camel.465427.n5.nabble.com/pass-custom-constant-value-to-a-bean-in-Spring-XML-tp5777598.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: Route shudtdown using Route Policy not working
ok thanks, I tried a different approach it worked, using body null check.
But I have a problem to get the number of lines processed for each file ,
since
the BATCHSIZE returns only the no of files processed .
I tried the below approach to get the splitsize but I cant get it outside
the split tag, I tried setting in headers but still cant get it outside
${body} != null
I checked online I saw a post (
http://git.net/r/users-camel-apache/2015-08/msg00220.html) using
custom aggregation strategy , not sure why do i need to do that just to get
a count.
Is there any simple way I can do it. ?
--
View this message in context:
http://camel.465427.n5.nabble.com/Route-shudtdown-using-Route-Policy-not-working-tp5777220p5777268.html
Sent from the Camel - Users mailing list archive at Nabble.com.
Route shudtdown using Route Policy not working
hello,
I have defined a route & route Policy class
1000
DS
${body} != null
My CustomRoute Policy class
public class CustomRoutePolicy extends RoutePolicySupport{
@Override
public void onExchangeDone(Route route, Exchange exchange) {
CamelContext context = exchange.getContext();
String stop = route.getId();
try {
context.getInflightRepository().remove(exchange);
context.stopRoute(stop);
} catch (Exception e) {
// let the exception handle handle it, which is often just to log it
getExceptionHandler().handleException("Error Stopping route", e);
}
}
}
Problem is that it does not stop route and i see below in the logs.
[el-1) thread #1 - ShutdownTask] DefaultShutdownStrategyINFO
Waiting as there are still 1 inflight and pending exchanges to complete,
timeout in 4948 seconds. Inflights per route: [UserCSVToDB = 1]
[el-1) thread #1 - ShutdownTask] DefaultShutdownStrategyINFO
Waiting as there are still 1 inflight and pending exchanges to complete,
timeout in 4947 seconds. Inflights per route: [UserCSVToDB = 1]
[el-1) thread #1 - ShutdownTask] DefaultShutdownStrategyINFO
Waiting as there are still 1 inflight and pending exchanges to complete,
timeout in 4946 seconds. Inflights per route: [UserCSVToDB = 1]
[el-1) thread #1 - ShutdownTask] DefaultShutdownStrategyINFO
Waiting as there are still 1 inflight and pending exchanges to complete,
timeout in 4945 seconds. Inflights per route: [UserCSVToDB = 1]
[el-1) thread #1 - ShutdownTask] DefaultShutdownStrategyINFO
Waiting as there are still 1 inflight and pending exchanges to complete,
timeout in 4944 seconds. Inflights per route: [UserCSVToDB = 1]
[el-1) thread #1 - ShutdownTask] DefaultShutdownStrategyINFO
Waiting as there are still 1 inflight and pending exchanges to complete,
timeout in 4943 seconds. Inflights per route: [UserCSVToDB = 1]
[el-1) thread #1 - ShutdownTask] DefaultShutdownStrategyINFO
Waiting as there are still 1 inflight and pending exchanges to complete,
timeout in 4942 seconds. Inflights per route: [UserCSVToDB = 1]
--
View this message in context:
http://camel.465427.n5.nabble.com/Route-shudtdown-using-Route-Policy-not-working-tp5777220.html
Sent from the Camel - Users mailing list archive at Nabble.com.
Re: Route shudtdown using Route Policy not working
hello, Tried that too, same issue. I used a oncompletion with a processor it worked then But the now the issue is the route gets stopped after the processing of 1 Exchange message. Since I am using the Split stream , camel sends 1 row at a time in exchange . I want to Stop the route after all files have finished processing. -- View this message in context: http://camel.465427.n5.nabble.com/Route-shudtdown-using-Route-Policy-not-working-tp5777220p5777237.html Sent from the Camel - Users mailing list archive at Nabble.com.
Extend FileComponent and create Custom componenet
hello, Is it possible to extend a existing component and create a new component . I have some specific business logic for file consuimg and in current component I find it difficult to make all scenarios work. Or the only option is to current your own custom component ? -- View this message in context: http://camel.465427.n5.nabble.com/Extend-FileComponent-and-create-Custom-componenet-tp5777137.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: Camel file component URI dynamic options & Filter query
hello Claus,
Thanks for the Tip.
I had tried for the point 2) using a eventnotifer class, but the results are
quiet confusing or maybe I am handling some other event . But i see the
Exchange completed is fired for each message sent. So ite becomes diffcult
to know which is the exact exchaneg complete event. I will try with a
callback and see if that works fine.
Below is MY event notifier code.
@Override
public void notify(EventObject event) throws Exception {
if (event instanceof ExchangeCompletedEvent) {
ExchangeCompletedEvent exchangeCompletedEvent =
(ExchangeCompletedEvent) event;
Exchange exchange = exchangeCompletedEvent.getExchange();
String FileName =
(String)exchange.getProperty(Exchange.FILE_NAME_CONSUMED);
System.out.println("EXCHANGE COMPLETED "+FileName);
}else if(event instanceof ExchangeCreatedEvent){
ExchangeCreatedEvent exchangeCreatedEvent = (ExchangeCreatedEvent)
event;
Exchange exchange = exchangeCreatedEvent.getExchange();
String FileName = (String)
exchange.getProperty(Exchange.FILE_NAME_CONSUMED);
System.out.println("EVEN "+FileName);
}else{
System.out.println("EVENT NOt KNOWN "+event.getClass().getName());
}
}
protected void doStart() throws Exception {
// filter out unwanted events
setIgnoreCamelContextEvents(true);
setIgnoreServiceEvents(true);
setIgnoreRouteEvents(false);
setIgnoreExchangeCreatedEvent(false);
setIgnoreExchangeCompletedEvent(false);
setIgnoreExchangeFailedEvents(false);
setIgnoreExchangeRedeliveryEvents(true);
setIgnoreExchangeSentEvents(false);
}
The Results On Console.
EVEN null
1 CSV Line - printed
EXCHANGE COMPLETED null
EVEN null
2 second CSV line - printed
EXCHANGE COMPLETED null
EVENT NOt KNOWN org.apache.camel.management.event.ExchangeSendingEvent
Updating sequence 0
EVENT NOt KNOWN org.apache.camel.management.event.ExchangeSentEvent
EXCHANGE COMPLETED null
--
View this message in context:
http://camel.465427.n5.nabble.com/Camel-file-component-URI-dynamic-options-Filter-query-tp5776861p5777145.html
Sent from the Camel - Users mailing list archive at Nabble.com.
Re: Camel file component URI dynamic options & Filter query
hello, I have tried with the below route & filter configuration , its works fine once , the filter is never called again after the first run . Do i need to call the filter explicitly to start the poll again? Since in my Filter I am getting the sequence from the Db always in the accept method. DS -- View this message in context: http://camel.465427.n5.nabble.com/Camel-file-component-URI-dynamic-options-Filter-query-tp5776861p5777100.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: Camel file component URI dynamic options & Filter query
I tried with a new approach it works atleast for basic condition . But the problem is if there is any file left in the folder which did not match in the Run , the route keeps on polling and the filter is called everytime . 1) Is there any way in which the route can be told to stop pooling after subsequent polls which did not result any file processing. 2) There could be a gap in the sequence, i.e. after 2 , 4 can be the next file how can i come to know that the route has finished processing one cylce, so that I can increment again in filter and the route will work again. 3) Incase there is a file les than sequence or any junk file , it should be moved to different folder. Since I am using a Filter , not sure if that can be done . I can configure a different route to counter this. DS -- View this message in context: http://camel.465427.n5.nabble.com/Camel-file-component-URI-dynamic-options-Filter-query-tp5776861p5777107.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: Camel file component URI dynamic options & Filter query
thanks, will try that -- View this message in context: http://camel.465427.n5.nabble.com/Camel-file-component-URI-dynamic-options-Filter-query-tp5776861p5776884.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: Agggegrate Scenario Camel
hello, Sorry ,I dont have much idea of using "embedded aggregor and build your map in aggregator strategy" in XML. In java I could try it out. Do you have any links or pointer which I can read too and try out for XML. -- View this message in context: http://camel.465427.n5.nabble.com/Agggegrate-Scenario-Camel-tp5776478p5776494.html Sent from the Camel - Users mailing list archive at Nabble.com.
Agggegrate Scenario Camel
hello, I am not sure if the below use case is possible in camel. I checked the documentation of aggreration in camel but it does not look like it will fit my need. Scenario:- I have to read from a csv file and collect some limited messages in a map which need to be sent to a external Java API call for enrichment of the messsages and the response got bac,k will be send to endpoint. The reason is that I want to avoid single call to the API every second for performance reasons and rather have it called with some limited set data at once. Can this be done in camel ? -- View this message in context: http://camel.465427.n5.nabble.com/Agggegrate-Scenario-Camel-tp5776478.html Sent from the Camel - Users mailing list archive at Nabble.com.
IdempotentConsumer Query (How does it work)
hello, I had read the doc at http://camel.apache.org/idempotent-consumer.html. I have a doubt on how it maintains the uniqueness . I checked the code in DefaultExchange and saw the ExchangeID generated using Instance, Prefix etc. But I am not sure How it makes the message ID unique and avoid duplicates . For example :- In my case I have to read a CSV file and process it. But in case of an exception or IO error if the route stops and if I restart the route again it should start from the line in CSV which was not read earlier and not processed. The already processed lines should be skipped or ignored since they will be duplicates . I thought of using JDBC based IdempotentConsumer . But I am not sure if it will work fine in this scenario . Any pointer will be helpful to understand. -- View this message in context: http://camel.465427.n5.nabble.com/IdempotentConsumer-Query-How-does-it-work-tp5776387.html Sent from the Camel - Users mailing list archive at Nabble.com.
RE: IdempotentConsumer Query (How does it work)
Thanks for the Tip will try it out -- View this message in context: http://camel.465427.n5.nabble.com/IdempotentConsumer-Query-How-does-it-work-tp5776387p5776392.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: statement.maxRows not working as expected camel jdbc
hello Christain, Have created the JIRA https://issues.apache.org/jira/browse/CAMEL-9491 thanks -- View this message in context: http://camel.465427.n5.nabble.com/statement-maxRows-not-working-as-expected-camel-jdbc-tp5775898p5776003.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: Camel Shiro Security
It should work . Or else try with a processor -- View this message in context: http://camel.465427.n5.nabble.com/Camel-Shiro-Security-tp5775078p5775889.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: Multiple Datasource in sql or JDBC component
ok thanks , will try this -- View this message in context: http://camel.465427.n5.nabble.com/Multiple-Datasource-in-sql-or-JDBC-component-tp5774594p5774680.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: Basicdatasource Connection question Camel
okay thanks for the Pointers Claus -- View this message in context: http://camel.465427.n5.nabble.com/Basicdatasource-Connection-question-Camel-tp5774457p5774474.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: Consume messages & rollback
hello, Okay even if I use spring transaction, i still don't get it if the processing is fail safe even if I set Ack to false For example I have a route as below and even a dead letter channel configured. In the error handler I am logging the message in a DB in case if it was not delivered. But what will happen in case the message was not logged in the DB due to some environment error etc. What happens to the message , will the Active MQ get the ACK . Because as far I have read in the documentation of camel , as soon as the Processor has finished execution the ack is sent back. (Hope I am right) even if there was a error or not after it . How can my scenario be handled in a effective way. http://camel.apache.org/schema/spring;> http://camel.apache.org/schema/spring;> regards, Felix T -- View this message in context: http://camel.465427.n5.nabble.com/Consume-messages-rollback-tp5773638p5773865.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: Start a route based on a specific time everyday , but stop logic is based on ...
any hints ? -- View this message in context: http://camel.465427.n5.nabble.com/Start-a-route-based-on-a-specific-time-everyday-but-stop-logic-is-based-on-tp5771696p5772320.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: Dynamic datasource with Camel 2.15.x
hello, You could try with SimpleRegistry. It worked fine for me ,though never tried with PropertyPlaceholderDelegateRegistry. SimpleRegistry reg = new SimpleRegistry(); I load a lot of beans during camel start time using camel context Object camelContext = new DefaultCamelContext(loadBeans()); never faced any issue yet ?. -- View this message in context: http://camel.465427.n5.nabble.com/Dynamic-datasource-with-Camel-2-15-x-tp5772178p5772181.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: kyro data format in camel
here is the class implementataion also.
public final class KyroDataFormat implements DataFormat {
@Override
public void marshal(Exchange exchange, Object graph, OutputStream
stream)
throws Exception {
stream.write(new KryoSerializationUtil().serialize(graph));
}
@Override
public Object unmarshal(Exchange exchange, InputStream stream)
throws Exception {
final byte[] bytes = exchange.getContext().getTypeConverter()
.mandatoryConvertTo(byte[].class, stream);
return new KryoSerializationUtil().deserialize(bytes,
.class);
}
}
--
View this message in context:
http://camel.465427.n5.nabble.com/kyro-data-format-in-camel-tp5771093p5771489.html
Sent from the Camel - Users mailing list archive at Nabble.com.
Re: kyro data format in camel
ohh Sorry for that, below is the part where it is used. -- View this message in context: http://camel.465427.n5.nabble.com/kyro-data-format-in-camel-tp5771093p5771488.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: Trigger a event to a queue when File component starts processing files
solved it by Splitting the route to 3 different routes -- View this message in context: http://camel.465427.n5.nabble.com/Trigger-a-event-to-a-queue-when-File-component-starts-processing-files-tp5771346p5771380.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: kyro data format in camel
no issue as such in execution of route. -- View this message in context: http://camel.465427.n5.nabble.com/kyro-data-format-in-camel-tp5771093p5771220.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: Send Message to a queue before start end of a route starts prcoessing
Sorry my BAD, I forgot the SetBody Tag in the onCompletion, it works fine now -- View this message in context: http://camel.465427.n5.nabble.com/Send-Message-to-a-queue-before-start-end-of-a-route-starts-prcoessing-tp5771056p5771060.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: Send Message to a queue before start end of a route starts prcoessing
sorry it works , but not the way i want it to be. the Start message comes in the end of the queue just before the end message entry, ideally i thought it would be the first message in the queue , but its the second last . any workarounds ? -- View this message in context: http://camel.465427.n5.nabble.com/Send-Message-to-a-queue-before-start-end-of-a-route-starts-prcoessing-tp5771056p5771061.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: Loading XML Routes from local directory
hi, Now sure of what exactly you want to do. As far as i understood , you want to keep all your routes in a XML file or multiple XML file 8specific for each route). I think the only option is currently is to use the loadRoutesDefinition which you have mentioned already. I have used it it works fine. And I am getting my route Definitions from a DB and streaming it as XML to the method. (Dont ask why .)) -- View this message in context: http://camel.465427.n5.nabble.com/Loading-XML-Routes-from-local-directory-tp5771018p5771024.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: Load Bean Definitions from XML in Camel
hello Christain, Sorry , I was not clear in the question. I meant the bean tags in XML , can it be loaded dynamically in camel i.e. a java method which will get the bean definations from a DB rather that hardcoding it in XML. I know that using a complex Java reflection I can load the class and bind it in the registry via the BIND method of the MAIN Class. I was wondering just like the loadRoutes method which can accept a XML stream , can I do the same for the java beans (which are mostly processor datasoource entries). Hope I was clear regards, Felix T -- View this message in context: http://camel.465427.n5.nabble.com/Load-Bean-Definitions-from-XML-in-Camel-tp5770892p5770958.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: Camel and ISO 8583
thanks will take a look -- View this message in context: http://camel.465427.n5.nabble.com/Camel-and-ISO-8583-tp5770965p5770967.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: Logging Error in Message or Exchange in DB (Not getting the exception in Processor)
okay, worked Like a Charm. Just a question, the ErrorProcessor will be called once only after the redelivery policy limit is exhausted I hope not for every re delivery. -- View this message in context: http://camel.465427.n5.nabble.com/Logging-Error-in-Message-or-Exchange-in-DB-Not-getting-the-exception-in-Processor-tp5770526p5770528.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: Some Stupid Questions
Thanks for your answers I will try them out whatever possible. I tried the Below things too. 1) I checked the bean construction the saw that it being created only once so i change the bean defination to below bean id=CustomProcessorCSV class=com..CustomProcessor scope=prototype constructor-arg value=CSV/ /bean But still I see only one Instance being created on the Logs, isn',t scope prototype supposed to return from registry a new instance so in turn it should create multiple instance of the bean. Hope my understanding is okay ? -- View this message in context: http://camel.465427.n5.nabble.com/Some-Stupid-Questions-tp5770217p5770275.html Sent from the Camel - Users mailing list archive at Nabble.com.
Error in Tokenize in XMl DSL
hello,
I have a route defined as
route customId=false id=routeCSV
xmlns=http://camel.apache.org/schema/spring;
from
uri=file:{{camel.csvinpath}}?noop=trueamp;delay=500amp;readLock=trueamp;move={{camel.csvinpath}}/
split id=splitCSV streaming=true parallelProcessing=true
simple${body}/simple
tokenize token=\n/
unmarshalcsv skipFirstLine=true//unmarshal
process ref=CustomProcessorCSV/
process ref=FieldsMappingProcessor/
to
uri=rabbitmq://localhost/EXCHANGE?autoDelete=falseamp;queue=QUEUEamp;routingKey=TEST/
/split
/route
I get this error as below on execution, I checked everywhere dont see a
solution. I am using the version 2.15.1 of camel. I double checked the
version XSD and it has the attribute token mentioned.
cvc-complex-type.2.4.a: Invalid content was found starting with element
'tokenize'. One of '{http://camel.apache.org/schema/spring:aop,
http://camel.apache.org/schema/spring:aggregate,
http://camel.apache.org/schema/spring:bean,
http://camel.apache.org/schema/spring:doCatch,
http://camel.apache.org/schema/spring:when,
http://camel.apache.org/schema/spring:choice,
http://camel.apache.org/schema/spring:otherwise,
http://camel.apache.org/schema/spring:convertBodyTo,
http://camel.apache.org/schema/spring:delay,
http://camel.apache.org/schema/spring:dynamicRouter,
http://camel.apache.org/schema/spring:enrich,
http://camel.apache.org/schema/spring:filter,
http://camel.apache.org/schema/spring:doFinally,
http://camel.apache.org/schema/spring:idempotentConsumer,
http://camel.apache.org/schema/spring:inOnly,
http://camel.apache.org/schema/spring:inOut,
http://camel.apache.org/schema/spring:intercept,
http://camel.apache.org/schema/spring:interceptFrom,
http://camel.apache.org/schema/spring:interceptSendToEndpoint,
http://camel.apache.org/schema/spring:loadBalance,
http://camel.apache.org/schema/spring:log,
http://camel.apache.org/schema/spring:loop,
http://camel.apache.org/schema/spring:marshal,
http://camel.apache.org/schema/spring:multicast,
http://camel.apache.org/schema/spring:onCompletion,
http://camel.apache.org/schema/spring:onException,
http://camel.apache.org/schema/spring:pipeline,
http://camel.apache.org/schema/spring:policy,
http://camel.apache.org/schema/spring:pollEnrich,
http://camel.apache.org/schema/spring:process,
http://camel.apache.org/schema/spring:recipientList,
http://camel.apache.org/schema/spring:removeHeader,
http://camel.apache.org/schema/spring:removeHeaders,
http://camel.apache.org/schema/spring:removeProperties,
http://camel.apache.org/schema/spring:removeProperty,
http://camel.apache.org/schema/spring:resequence,
http://camel.apache.org/schema/spring:rollback,
http://camel.apache.org/schema/spring:route,
http://camel.apache.org/schema/spring:routingSlip,
http://camel.apache.org/schema/spring:sample,
http://camel.apache.org/schema/spring:setBody,
http://camel.apache.org/schema/spring:setExchangePattern,
http://camel.apache.org/schema/spring:setFaultBody,
http://camel.apache.org/schema/spring:setHeader,
http://camel.apache.org/schema/spring:setOutHeader,
http://camel.apache.org/schema/spring:setProperty,
http://camel.apache.org/schema/spring:sort,
http://camel.apache.org/schema/spring:split,
http://camel.apache.org/schema/spring:stop,
http://camel.apache.org/schema/spring:threads,
http://camel.apache.org/schema/spring:throttle,
http://camel.apache.org/schema/spring:throwException,
http://camel.apache.org/schema/spring:to,
http://camel.apache.org/schema/spring:transacted,
http://camel.apache.org/schema/spring:transform,
http://camel.apache.org/schema/spring:doTry,
http://camel.apache.org/schema/spring:unmarshal,
http://camel.apache.org/schema/spring:validate,
http://camel.apache.org/schema/spring:whenSkipSendToEndpoint,
http://camel.apache.org/schema/spring:wireTap,
http://camel.apache.org/schema/spring:restBinding}' is expected.
--
View this message in context:
http://camel.465427.n5.nabble.com/Error-in-Tokenize-in-XMl-DSL-tp5770101.html
Sent from the Camel - Users mailing list archive at Nabble.com.
Re: Error in Tokenize in XMl DSL
hanks Claus worked line a Charm. But i got stuck on the CSV format. I have changed the XML to below, since I want to skip the First line of the CSV and skipFirstLine is not present in the version 2.15.1. split id=splitCSV streaming=true parallelProcessing=true tokenize token=\n/ unmarshalcsv formatName=EXCEL skipHeaderRecord=true/ /unmarshalprocess ref=CustomProcessorCSV/ I get the below error, But if I remove skipHeaderRecord attribute it works fine but I get the Firts lien too. Is there anyway I can get the first line skipped. java.lang.IllegalArgumentException: The header contains a duplicate name: 00 in X 117, GAP220, at org.apache.commons.csv.CSVParser.initializeHeader(CSVParser.java:406)[commons-csv-1.1.jar:1.1] at org.apache.commons.csv.CSVParser.init(CSVParser.java:283)[commons-csv-1.1.jar:1.1] at org.apache.commons.csv.CSVParser.init(CSVParser.java:251)[commons-csv-1.1.jar:1.1] at org.apache.camel.dataformat.csv.CsvUnmarshaller$BulkCsvUnmarshaller.unmarshal(CsvUnmarshaller.java:92)[camel-csv-2.15.1.jar:2.15.1] -- View this message in context: http://camel.465427.n5.nabble.com/Error-in-Tokenize-in-XMl-DSL-tp5770135p5770146.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: DUMP Camelcontext to XML DSL -- API ?
hello, Not sure what the question is? Are you talking about some tooling that can take Camel java code and covert to xml automatic? I was thinking of a API call which can do it. That is dump the whole CamelContext things in XML . including bean information related things . If its a tool also no problem for me. I had a different question but i will raise another topic don,t want to mix that question with this. -- View this message in context: http://camel.465427.n5.nabble.com/DUMP-Camelcontext-to-XML-DSL-API-tp5769450p5769640.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: What about a simpe to use dynamic to out of the box
ok kool, will try out when i get time -- View this message in context: http://camel.465427.n5.nabble.com/What-about-a-simpe-to-use-dynamic-to-out-of-the-box-tp5769255p5769597.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: DUMP Camelcontext to XML DSL -- API ?
hello,
I tried the ManagedRoute way, it worked but a problem i faced was that the
bean entries which are linked to the routes are not dumped. Moreover the
XML representation was not full working if i tried to load the XML as
spring .
for example expressionDefinitionbody/expressionDefinition which was
generated by the API did not work and i got error from camel saying language
schema not present etc. when i changed it to
simple${body}/simple . It worked fine
So can i dump the whole camlecontext as XML using some API which is
currently as the in the object ??
If there any ready reckoner which i can use to convert the java DSL to XMl
DSL.
regards,
Felix
--
View this message in context:
http://camel.465427.n5.nabble.com/DUMP-Camelcontext-to-XML-DSL-API-tp5769450p5769596.html
Sent from the Camel - Users mailing list archive at Nabble.com.
DUMP Camelcontext to XML DSL -- API ?
hello,
I was wondering if there simple way i can dump the camelcontext details
into a XML i.e. convert from JAVA DSL to XMl DSL . Using the camlecontext
object I an get the necessary information of the routes and it
configuration.
I am trying to convert my Routes which are java DSL based to XML and it
takes a lot of time and research just to know which tags and enclosing etc
to use.
for example split(body()) -- is to be respresented like
split
simple${body}/simple
/split
If there is a guide which helps in converting it faster do let me know. Or
else we could have this as a new API feature in camel.
regards,
Felix
--
View this message in context:
http://camel.465427.n5.nabble.com/DUMP-Camelcontext-to-XML-DSL-API-tp5769450.html
Sent from the Camel - Users mailing list archive at Nabble.com.
Re: DUMP Camelcontext to XML DSL -- API ?
saw this post http://camel.465427.n5.nabble.com/Is-there-a-tools-to-convert-java-dsl-to-xml-td5768015.html will try using ManagedRoute dumpRouteAsXml(). -- View this message in context: http://camel.465427.n5.nabble.com/DUMP-Camelcontext-to-XML-DSL-API-tp5769450p5769451.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: Cannot store file error CSV
okay, I will try that. I had tried without existing file and without existing file , in both cases it gave the same issue. -- View this message in context: http://camel.465427.n5.nabble.com/Cannot-store-file-error-CSV-tp5769339p5769441.html Sent from the Camel - Users mailing list archive at Nabble.com.
Cannot store file error CSV
hello, I am trying to write from a DB to CSV file , and I always get a cannot store file exception. My route is like below from(timer://getData?period=2h).setBody(constant(SQL Query)).to(jdbc:DS?outputType=StreamList).split(body()).to(file://C:\\GitWrk?fileName=data.csvfileExist=Append); I am writing to my local disk ,so I have full permission rights too. I tried without and with split too but same error. org.apache.camel.component.file.GenericFileOperationFailedException: Cannot store file: C:\GitWrK\data.csv at org.apache.camel.component.file.FileOperations.storeFile(FileOperations.java:292)[camel-core-2.15.1.jar:2.15.1] at org.apache.camel.component.file.GenericFileProducer.writeFile(GenericFileProducer.java:277)[camel-core-2.15.1.jar:2.15.1] at org.apache.camel.component.file.GenericFileProducer.processExchange(GenericFileProducer.java:165)[camel-core-2.15.1.jar:2.15.1] at org.apache.camel.component.file.GenericFileProducer.process(GenericFileProducer.java:79)[camel-core-2.15.1.jar:2.15.1] at org.apache.camel.util.AsyncProcessorConverterHelper$ProcessorToAsyncProcessorBridge.process(AsyncProcessorConverterHelper.java:61)[camel-core-2.15.1.jar:2.15.1] at org.apache.camel.processor.SendProcessor.process(SendProcessor.java:129)[camel-core-2.15.1.jar:2.15.1] Any Pointers ? Regards, Felix -- View this message in context: http://camel.465427.n5.nabble.com/Cannot-store-file-error-CSV-tp5769339.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: What about a simpe to use dynamic to out of the box
+1 for me. If you can have Dynamic from too it would be a great feature. -- View this message in context: http://camel.465427.n5.nabble.com/What-about-a-simpe-to-use-dynamic-to-out-of-the-box-tp5769255p5769268.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: readSize option JDBC component not working for split
okay , it worked . Thanks -- View this message in context: http://camel.465427.n5.nabble.com/readSize-option-JDBC-component-not-working-for-split-tp5769042p5769060.html Sent from the Camel - Users mailing list archive at Nabble.com.
readSize option JDBC component not working for split
hello, I tried using the readSize option in the JDBC , but does not work. Is it that it won't work because I am using split with StreamList . I just want to get row By row from a DB , but i want only the first 10 rows. Currently it gets all the rows . Me code as below. from(timer://getData?period=2h).setBody(constant(from)).to(jdbc:DS?readSize=10outputType=StreamList).split(body()).process(new CustomProcessor(CustomConstants.DB)).to(to); regards, Felix T -- View this message in context: http://camel.465427.n5.nabble.com/readSize-option-JDBC-component-not-working-for-split-tp5769042.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: Dynamic Routes aadition in Standalone application
okay, so if you say if i can add using the camelcontext i need not restart the application again ? -- View this message in context: http://camel.465427.n5.nabble.com/Dynamic-Routes-aadition-in-Standalone-application-tp5769018p5769041.html Sent from the Camel - Users mailing list archive at Nabble.com.
Dynamic Routes aadition in Standalone application
hello, I have write some code to start camel in Standalone mode , with some routes . But how do I make the roue addition dynamic without restarting the camel instance. I will be updating the route dynamically based on some triggers in my application. Looking at the standalone approach I dont see it possible without restarting the camel instance. Below is my code // create a Main instance main = new Main(); main.enableHangupSupport(); // add routes main.addRouteBuilder(new CustomDynamicRouteBuilderWithoutContext(rabbitmq://localhost/+EXCHANGE_NAME+?autoDelete=falsequeue=+QUEUE_NAME+username=guestpassword=guestroutingKey=+ROUTING_KEY,stream:out,XML)); main.addRouteBuilder(new CustomDynamicRouteBuilderWithoutContext(select * from TBL_DB,stream:out,DB)); // incase of DB need to provide Datasource Object main.bind(DS,setupDataSource1(jdbc:oracle:thin:@nero2:15521:FYR)); // enable hangup support so you can press ctrl + c to terminate the JVM // run until you terminate the JVM System.out.println(Starting Camel. Use ctrl + c to terminate the JVM.\n); main.run(); How do I add new routes without restarting the camel application, is there any way or other approach I could try. regards, Felix T -- View this message in context: http://camel.465427.n5.nabble.com/Dynamic-Routes-aadition-in-Standalone-application-tp5769018.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: Camel website is not showing the code blocks
helllo, I also still the css tags missging issue on the website class=brush: xml Many of the XML tag content are missing, but some are present also which is strange regards, Felix T -- View this message in context: http://camel.465427.n5.nabble.com/Camel-website-is-not-showing-the-code-blocks-tp5768644p5768694.html Sent from the Camel - Users mailing list archive at Nabble.com.
