Return-Path: X-Original-To: apmail-camel-users-archive@www.apache.org Delivered-To: apmail-camel-users-archive@www.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id 83A4610945 for ; Wed, 3 Dec 2014 06:53:26 +0000 (UTC) Received: (qmail 16313 invoked by uid 500); 3 Dec 2014 06:53:26 -0000 Delivered-To: apmail-camel-users-archive@camel.apache.org Received: (qmail 16265 invoked by uid 500); 3 Dec 2014 06:53:26 -0000 Mailing-List: contact users-help@camel.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: users@camel.apache.org Delivered-To: mailing list users@camel.apache.org Delivered-To: moderator for users@camel.apache.org Received: (qmail 6827 invoked by uid 99); 3 Dec 2014 06:50:52 -0000 X-ASF-Spam-Status: No, hits=2.3 required=5.0 tests=SPF_SOFTFAIL,URI_HEX X-Spam-Check-By: apache.org Received-SPF: softfail (athena.apache.org: transitioning domain of srinivas.thunga@gmail.com does not designate 162.253.133.43 as permitted sender) Date: Tue, 2 Dec 2014 23:49:26 -0700 (MST) From: smilevasu6 To: users@camel.apache.org Message-ID: <1417589366878-5760010.post@n5.nabble.com> In-Reply-To: <1417589017585-5760009.post@n5.nabble.com> References: <1417578683811-5760000.post@n5.nabble.com> <1417589017585-5760009.post@n5.nabble.com> Subject: Re: camel - xsd MIME-Version: 1.0 Content-Type: text/plain; charset=us-ascii Content-Transfer-Encoding: 7bit X-Virus-Checked: Checked by ClamAV on apache.org Claus, see the console, Dec 02, 2014 10:46:19 PM org.springframework.jdbc.datasource.DriverManagerDataSource setDriverClassName INFO: Loaded JDBC driver: org.apache.hive.jdbc.HiveDriver %%%%%%%%%%CamelContext(camel-1) %%%%%%%%%%Routes: [] 22:46:19.634 [main] DEBUG o.a.camel.impl.DefaultCamelContext - Adding routes from builder: Routes: [] 22:46:19.746 [main] INFO o.a.camel.impl.DefaultCamelContext - Apache Camel 2.12.5 (CamelContext: camel-1) is starting 22:46:19.747 [main] DEBUG o.a.camel.impl.DefaultCamelContext - Using ClassResolver=org.apache.camel.impl.DefaultClassResolver@c299bbd, PackageScanClassResolver=org.apache.camel.impl.DefaultPackageScanClassResolver@7faf9b87, ApplicationContextClassLoader=sun.misc.Launcher$AppClassLoader@15e565bd 22:46:19.748 [main] INFO o.a.c.m.ManagedManagementStrategy - JMX is enabled 22:46:19.748 [main] DEBUG o.a.c.m.DefaultManagementAgent - Starting JMX agent on server: com.sun.jmx.mbeanserver.JmxMBeanServer@301f417 22:46:19.937 [main] DEBUG o.a.c.m.DefaultManagementAgent - Registered MBean with ObjectName: org.apache.camel:context=quickstart.cloudera/camel-1,type=context,name="camel-1" 22:46:19.938 [main] DEBUG o.a.c.support.TimerListenerManager - Added TimerListener: org.apache.camel.management.mbean.ManagedCamelContext@ce0d675 22:46:19.998 [main] DEBUG o.a.c.m.DefaultManagementAgent - Registered MBean with ObjectName: org.apache.camel:context=quickstart.cloudera/camel-1,type=services,name=DefaultTypeConverter 22:46:20.014 [main] DEBUG o.a.c.i.c.AnnotationTypeConverterLoader - Found 3 packages with 15 @Converter classes to load 22:46:20.098 [main] DEBUG o.a.c.i.c.AnnotationTypeConverterLoader - Loading file META-INF/services/org/apache/camel/TypeConverter to retrieve list of packages, from url: jar:file:/home/cloudera/Desktop/sri_share/Camel-Jars/camel-context-2.12.5.jar!/META-INF/services/org/apache/camel/TypeConverter 22:46:20.100 [main] DEBUG o.a.c.i.c.AnnotationTypeConverterLoader - Loading file META-INF/services/org/apache/camel/TypeConverter to retrieve list of packages, from url: jar:file:/home/cloudera/Desktop/sri_share/Camel-Jars/camel-core-2.12.5.jar!/META-INF/services/org/apache/camel/TypeConverter 22:46:20.100 [main] DEBUG o.a.c.i.c.AnnotationTypeConverterLoader - Loading file META-INF/services/org/apache/camel/TypeConverter to retrieve list of packages, from url: jar:file:/home/cloudera/Desktop/sri_share/Camel-Jars/camel-hbase-2.12.5.jar!/META-INF/services/org/apache/camel/TypeConverter 22:46:20.103 [main] DEBUG o.a.c.i.c.AnnotationTypeConverterLoader - Loading file META-INF/services/org/apache/camel/TypeConverter to retrieve list of packages, from url: jar:file:/home/cloudera/Desktop/sri_share/Camel-Jars/camel-spring-2.12.5.jar!/META-INF/services/org/apache/camel/TypeConverter 22:46:20.129 [main] DEBUG o.a.c.i.c.AnnotationTypeConverterLoader - Loaded 3 @Converter classes 22:46:20.130 [main] WARN o.a.c.i.c.DefaultTypeConverter - Overriding type converter from: StaticMethodTypeConverter: public static byte[] org.apache.camel.converter.IOConverter.toByteArray(java.lang.String,org.apache.camel.Exchange) throws java.io.IOException to: StaticMethodTypeConverter: public static byte[] org.apache.camel.component.hbase.converter.HBaseModelConverter.stringToBytes(java.lang.String) 22:46:20.132 [main] WARN o.a.c.i.c.DefaultTypeConverter - Overriding type converter from: StaticMethodTypeConverter: public static java.lang.String org.apache.camel.converter.IOConverter.toString(byte[],org.apache.camel.Exchange) throws java.io.IOException to: StaticMethodTypeConverter: public static java.lang.String org.apache.camel.component.hbase.converter.HBaseModelConverter.bytesToString(byte[]) 22:46:20.137 [main] INFO o.a.c.i.c.DefaultTypeConverter - Loaded 189 type converters 22:46:20.180 [main] DEBUG o.a.c.m.DefaultManagementAgent - Registered MBean with ObjectName: org.apache.camel:context=quickstart.cloudera/camel-1,type=services,name=EndpointRegistry 22:46:20.189 [main] DEBUG o.a.c.m.DefaultManagementAgent - Registered MBean with ObjectName: org.apache.camel:context=quickstart.cloudera/camel-1,type=services,name=DefaultExecutorServiceManager 22:46:20.202 [main] DEBUG o.a.c.m.DefaultManagementAgent - Registered MBean with ObjectName: org.apache.camel:context=quickstart.cloudera/camel-1,type=services,name=SharedProducerServicePool 22:46:20.208 [main] DEBUG o.a.c.impl.SharedProducerServicePool - Starting service pool: org.apache.camel.impl.SharedProducerServicePool@7acd381 22:46:20.213 [main] DEBUG o.a.c.m.DefaultManagementAgent - Registered MBean with ObjectName: org.apache.camel:context=quickstart.cloudera/camel-1,type=services,name=DefaultInflightRepository 22:46:20.224 [main] DEBUG o.a.c.m.DefaultManagementAgent - Registered MBean with ObjectName: org.apache.camel:context=quickstart.cloudera/camel-1,type=services,name=DefaultShutdownStrategy 22:46:20.230 [main] DEBUG o.a.c.m.DefaultManagementAgent - Registered MBean with ObjectName: org.apache.camel:context=quickstart.cloudera/camel-1,type=services,name=DefaultPackageScanClassResolver 22:46:20.244 [main] DEBUG o.a.camel.impl.DefaultCamelContext - Using ComponentResolver: org.apache.camel.impl.DefaultComponentResolver@1e1ebbf6 to resolve component with name: timer 22:46:20.244 [main] DEBUG o.a.c.impl.DefaultComponentResolver - Found component: timer in registry: null 22:46:20.247 [main] DEBUG o.a.c.impl.DefaultComponentResolver - Found component: timer via type: org.apache.camel.component.timer.TimerComponent via: META-INF/services/org/apache/camel/component/timer 22:46:20.261 [main] DEBUG o.a.c.m.DefaultManagementAgent - Registered MBean with ObjectName: org.apache.camel:context=quickstart.cloudera/camel-1,type=components,name="timer" 22:46:20.262 [main] DEBUG o.apache.camel.impl.DefaultComponent - Creating endpoint uri=[timer://foo?period=60000], path=[foo] 22:46:20.273 [main] DEBUG o.a.camel.util.IntrospectionSupport - Configured property: period on bean: Endpoint[timer://foo?period=60000] with value: 60000 22:46:20.284 [main] DEBUG o.a.camel.impl.DefaultCamelContext - timer://foo?period=60000 converted to endpoint: Endpoint[timer://foo?period=60000] by component: org.apache.camel.component.timer.TimerComponent@7de41969 22:46:20.319 [main] DEBUG o.a.c.m.DefaultManagementAgent - Registered MBean with ObjectName: org.apache.camel:context=quickstart.cloudera/camel-1,type=endpoints,name="timer://foo\?period=60000" 22:46:20.378 [main] DEBUG o.a.camel.impl.DefaultCamelContext - Using ComponentResolver: org.apache.camel.impl.DefaultComponentResolver@1e1ebbf6 to resolve component with name: bean 22:46:20.378 [main] DEBUG o.a.c.impl.DefaultComponentResolver - Found component: bean in registry: null 22:46:20.379 [main] DEBUG o.a.c.impl.DefaultComponentResolver - Found component: bean via type: org.apache.camel.component.bean.BeanComponent via: META-INF/services/org/apache/camel/component/bean 22:46:20.385 [main] DEBUG o.a.c.m.DefaultManagementAgent - Registered MBean with ObjectName: org.apache.camel:context=quickstart.cloudera/camel-1,type=components,name="bean" 22:46:20.401 [main] DEBUG o.a.c.p.interceptor.DefaultChannel - Initialize channel for target: 'Bean[com.edms.emagia.TestDemo@1e884ca9]' 22:46:20.411 [main] DEBUG o.a.c.m.DefaultManagementAgent - Registered MBean with ObjectName: org.apache.camel:context=quickstart.cloudera/camel-1,type=tracer,name=BacklogTracer 22:46:20.438 [main] DEBUG o.a.c.m.DefaultManagementAgent - Registered MBean with ObjectName: org.apache.camel:context=quickstart.cloudera/camel-1,type=tracer,name=BacklogDebugger 22:46:20.481 [main] DEBUG o.a.c.m.DefaultManagementAgent - Registered MBean with ObjectName: org.apache.camel:context=quickstart.cloudera/camel-1,type=errorhandlers,name="DefaultErrorHandlerBuilder(ref:CamelDefaultErrorHandlerBuilder)" 22:46:20.485 [main] DEBUG o.a.camel.impl.DefaultCamelContext - Using ComponentResolver: org.apache.camel.impl.DefaultComponentResolver@1e1ebbf6 to resolve component with name: mock 22:46:20.485 [main] DEBUG o.a.c.impl.DefaultComponentResolver - Found component: mock in registry: null 22:46:20.486 [main] DEBUG o.a.c.impl.DefaultComponentResolver - Found component: mock via type: org.apache.camel.component.mock.MockComponent via: META-INF/services/org/apache/camel/component/mock 22:46:20.494 [main] DEBUG o.a.c.m.DefaultManagementAgent - Registered MBean with ObjectName: org.apache.camel:context=quickstart.cloudera/camel-1,type=components,name="mock" 22:46:20.495 [main] DEBUG o.apache.camel.impl.DefaultComponent - Creating endpoint uri=[mock://abc], path=[abc] 22:46:20.507 [main] DEBUG o.a.camel.impl.DefaultCamelContext - mock://abc converted to endpoint: Endpoint[mock://abc] by component: org.apache.camel.component.mock.MockComponent@2110c261 22:46:20.523 [main] DEBUG o.a.c.m.DefaultManagementAgent - Registered MBean with ObjectName: org.apache.camel:context=quickstart.cloudera/camel-1,type=endpoints,name="mock://abc" 22:46:20.526 [main] DEBUG o.a.c.p.interceptor.DefaultChannel - Initialize channel for target: 'To[mock:abc]' 22:46:20.541 [main] DEBUG o.a.c.p.interceptor.DefaultChannel - Initialize channel for target: 'SetHeader[tablename, simple{Simple: abc}]' 22:46:20.545 [main] DEBUG o.a.c.p.interceptor.DefaultChannel - Initialize channel for target: 'SetBody[simple{Simple: load data local inpath '/sri/address.txt' OVERWRITE into table ${in.header.tablename}}]' 22:46:20.590 [main] INFO o.a.camel.impl.DefaultCamelContext - AllowUseOriginalMessage is enabled. If access to the original message is not needed, then its recommended to turn this option off as it may improve performance. 22:46:20.590 [main] INFO o.a.camel.impl.DefaultCamelContext - StreamCaching is not in use. If using streams then its recommended to enable stream caching. See more details at http://camel.apache.org/stream-caching.html 22:46:20.591 [main] DEBUG o.a.camel.impl.DefaultCamelContext - Warming up route id: route1 having autoStartup=true 22:46:20.592 [main] DEBUG org.apache.camel.impl.RouteService - Starting services on route: route1 22:46:20.605 [main] DEBUG org.apache.camel.impl.RouteService - Starting child service on route: route1 -> Pipeline[[Channel[BeanProcessor[com.edms.emagia.TestDemo(0x1e884ca9)]], Channel[sendTo(Endpoint[mock://abc])], Channel[setHeader(tablename, Simple: abc)], Channel[SetBody(Simple: load data local inpath '/sri/address.txt' OVERWRITE into table ${in.header.tablename})]]] 22:46:20.605 [main] DEBUG o.a.c.processor.DefaultErrorHandler - Redelivery enabled: false on error handler: DefaultErrorHandler[Instrumentation:bean[BeanProcessor[com.edms.emagia.TestDemo(0x1e884ca9)]]] 22:46:20.619 [main] DEBUG o.a.c.component.mock.MockEndpoint$1 - Starting producer: Producer[mock://abc] 22:46:20.620 [main] DEBUG org.apache.camel.impl.ProducerCache - Adding to producer cache with key: Endpoint[mock://abc] for producer: Producer[mock://abc] 22:46:20.621 [main] DEBUG o.a.c.processor.DefaultErrorHandler - Redelivery enabled: false on error handler: DefaultErrorHandler[Instrumentation:to[sendTo(Endpoint[mock://abc])]] 22:46:20.621 [main] DEBUG o.a.c.processor.DefaultErrorHandler - Redelivery enabled: false on error handler: DefaultErrorHandler[Instrumentation:setHeader[setHeader(tablename, Simple: abc)]] 22:46:20.621 [main] DEBUG o.a.c.processor.DefaultErrorHandler - Redelivery enabled: false on error handler: DefaultErrorHandler[Instrumentation:setBody[SetBody(Simple: load data local inpath '/sri/address.txt' OVERWRITE into table ${in.header.tablename})]] 22:46:20.621 [main] DEBUG org.apache.camel.impl.RouteService - Starting child service on route: route1 -> Pipeline[[Channel[BeanProcessor[com.edms.emagia.TestDemo(0x1e884ca9)]], Channel[sendTo(Endpoint[mock://abc])], Channel[setHeader(tablename, Simple: abc)], Channel[SetBody(Simple: load data local inpath '/sri/address.txt' OVERWRITE into table ${in.header.tablename})]]] 22:46:20.621 [main] DEBUG org.apache.camel.impl.RouteService - Starting child service on route: route1 -> BeanProcessor[com.edms.emagia.TestDemo(0x1e884ca9)] 22:46:20.639 [main] DEBUG o.a.c.m.DefaultManagementAgent - Registered MBean with ObjectName: org.apache.camel:context=quickstart.cloudera/camel-1,type=processors,name="bean1" 22:46:20.639 [main] DEBUG org.apache.camel.impl.RouteService - Starting child service on route: route1 -> Channel[BeanProcessor[com.edms.emagia.TestDemo(0x1e884ca9)]] 22:46:20.642 [main] DEBUG org.apache.camel.impl.RouteService - Starting child service on route: route1 -> sendTo(Endpoint[mock://abc]) 22:46:20.665 [main] DEBUG o.a.c.m.DefaultManagementAgent - Registered MBean with ObjectName: org.apache.camel:context=quickstart.cloudera/camel-1,type=processors,name="to1" 22:46:20.666 [main] DEBUG org.apache.camel.impl.RouteService - Starting child service on route: route1 -> Channel[sendTo(Endpoint[mock://abc])] 22:46:20.666 [main] DEBUG org.apache.camel.impl.RouteService - Starting child service on route: route1 -> Channel[setHeader(tablename, Simple: abc)] 22:46:20.666 [main] DEBUG org.apache.camel.impl.RouteService - Starting child service on route: route1 -> SetBody(Simple: load data local inpath '/sri/address.txt' OVERWRITE into table ${in.header.tablename}) 22:46:20.687 [main] DEBUG o.a.c.m.DefaultManagementAgent - Registered MBean with ObjectName: org.apache.camel:context=quickstart.cloudera/camel-1,type=processors,name="setBody1" 22:46:20.690 [main] DEBUG org.apache.camel.impl.RouteService - Starting child service on route: route1 -> Channel[SetBody(Simple: load data local inpath '/sri/address.txt' OVERWRITE into table ${in.header.tablename})] 22:46:20.733 [main] DEBUG o.a.c.m.DefaultManagementAgent - Registered MBean with ObjectName: org.apache.camel:context=quickstart.cloudera/camel-1,type=routes,name="route1" 22:46:20.733 [main] DEBUG o.a.c.support.TimerListenerManager - Added TimerListener: org.apache.camel.management.mbean.ManagedSuspendableRoute@32ceaf87 22:46:20.734 [main] DEBUG o.a.camel.impl.DefaultCamelContext - Route: route1 >>> EventDrivenConsumerRoute[Endpoint[timer://foo?period=60000] -> Pipeline[[Channel[BeanProcessor[com.edms.emagia.TestDemo(0x1e884ca9)]], Channel[sendTo(Endpoint[mock://abc])], Channel[setHeader(tablename, Simple: abc)], Channel[SetBody(Simple: load data local inpath '/sri/address.txt' OVERWRITE into table ${in.header.tablename})]]]] 22:46:20.734 [main] DEBUG o.a.camel.impl.DefaultCamelContext - Starting consumer (order: 1000) on route: route1 22:46:20.741 [main] DEBUG o.a.c.m.DefaultManagementAgent - Registered MBean with ObjectName: org.apache.camel:context=quickstart.cloudera/camel-1,type=consumers,name=TimerConsumer(0x770b5264) 22:46:20.745 [main] INFO o.a.camel.impl.DefaultCamelContext - Route: route1 started and consuming from: Endpoint[timer://foo?period=60000] 22:46:20.745 [main] DEBUG o.a.c.m.DefaultManagementLifecycleStrategy - Load performance statistics enabled 22:46:20.749 [main] DEBUG o.a.c.m.DefaultManagementAgent - Registered MBean with ObjectName: org.apache.camel:context=quickstart.cloudera/camel-1,type=services,name=TimerListenerManager 22:46:20.769 [main] DEBUG o.a.c.m.DefaultManagementAgent - Registered MBean with ObjectName: org.apache.camel:context=quickstart.cloudera/camel-1,type=threadpools,name="TimerListenerManager" 22:46:20.769 [main] DEBUG o.a.c.i.DefaultExecutorServiceManager - Created new ScheduledThreadPool for source: org.apache.camel.support.TimerListenerManager@6e0971ae with name: ManagementLoadTask. -> org.apache.camel.util.concurrent.SizedScheduledExecutorService@5aed63a3[ManagementLoadTask] 22:46:20.775 [main] DEBUG o.a.c.support.TimerListenerManager - Started scheduled TimerListener task to run with interval 1000 ms 22:46:20.777 [main] INFO o.a.camel.impl.DefaultCamelContext - Total 1 routes, of which 1 is started. 22:46:20.778 [main] INFO o.a.camel.impl.DefaultCamelContext - Apache Camel 2.12.5 (CamelContext: camel-1) started in 1.041 seconds 22:46:21.798 [Camel (camel-1) thread #1 - timer://foo] DEBUG org.apache.camel.util.ObjectHelper - Cannot find class: homeclouderaDesktopSample.xsd 22:46:22.063 [Camel (camel-1) thread #1 - timer://foo] DEBUG o.a.camel.component.bean.MethodInfo - Setting bean invocation result on the IN message: Address 22:46:22.077 [Camel (camel-1) thread #1 - timer://foo] DEBUG o.a.camel.processor.SendProcessor - >>>> Endpoint[mock://abc] Exchange[Message: Address] 22:46:22.090 [Camel (camel-1) thread #1 - timer://foo] DEBUG o.a.c.component.mock.MockEndpoint - mock://abc >>>> 0 : Exchange[Message: Address] with body: Address and headers:{breadcrumbId=ID-quickstart-cloudera-54377-1417589179447-0-1, firedTime=Tue Dec 02 22:46:21 PST 2014} 22:46:30.779 [main] INFO o.a.camel.impl.DefaultCamelContext - Apache Camel 2.12.5 (CamelContext: camel-1) is shutting down 22:46:30.780 [main] INFO o.a.c.impl.DefaultShutdownStrategy - Starting to graceful shutdown 1 routes (timeout 300 seconds) 22:46:30.782 [main] DEBUG o.a.c.i.DefaultExecutorServiceManager - Created new ThreadPool for source: org.apache.camel.impl.DefaultShutdownStrategy@60c32254 with name: ShutdownTask. -> org.apache.camel.util.concurrent.RejectableThreadPoolExecutor@11648e6f[Running, pool size = 0, active threads = 0, queued tasks = 0, completed tasks = 0][ShutdownTask] 22:46:30.784 [Camel (camel-1) thread #2 - ShutdownTask] DEBUG o.a.c.impl.DefaultShutdownStrategy - There are 1 routes to shutdown 22:46:30.786 [Camel (camel-1) thread #2 - ShutdownTask] DEBUG o.a.c.impl.DefaultShutdownStrategy - Route: route1 suspended and shutdown deferred, was consuming from: Endpoint[timer://foo?period=60000] 22:46:30.786 [Camel (camel-1) thread #2 - ShutdownTask] INFO o.a.c.impl.DefaultShutdownStrategy - Route: route1 shutdown complete, was consuming from: Endpoint[timer://foo?period=60000] 22:46:30.787 [main] INFO o.a.c.impl.DefaultShutdownStrategy - Graceful shutdown of 1 routes completed in 0 seconds 22:46:30.787 [main] DEBUG o.a.c.support.TimerListenerManager - Removed TimerListener: org.apache.camel.management.mbean.ManagedSuspendableRoute@32ceaf87 22:46:30.788 [main] DEBUG o.a.c.m.DefaultManagementAgent - Unregistered MBean with ObjectName: org.apache.camel:context=quickstart.cloudera/camel-1,type=routes,name="route1" 22:46:30.788 [main] DEBUG org.apache.camel.impl.RouteService - Stopping services on route: route1 22:46:30.788 [main] DEBUG org.apache.camel.impl.RouteService - Shutting down child service on route: route1 -> Consumer[timer://foo?period=60000] 22:46:30.788 [main] DEBUG o.a.c.m.DefaultManagementAgent - Unregistered MBean with ObjectName: org.apache.camel:context=quickstart.cloudera/camel-1,type=consumers,name=TimerConsumer(0x770b5264) 22:46:30.788 [main] DEBUG org.apache.camel.impl.RouteService - Shutting down child service on route: route1 -> Pipeline[[Channel[BeanProcessor[com.edms.emagia.TestDemo(0x1e884ca9)]], Channel[sendTo(Endpoint[mock://abc])], Channel[setHeader(tablename, Simple: abc)], Channel[SetBody(Simple: load data local inpath '/sri/address.txt' OVERWRITE into table ${in.header.tablename})]]] 22:46:30.788 [main] DEBUG o.a.c.impl.SharedProducerServicePool - Stopping service pool: org.apache.camel.impl.SharedProducerServicePool@7acd381 22:46:30.789 [main] DEBUG o.a.c.component.mock.MockEndpoint$1 - Stopping producer: Producer[mock://abc] 22:46:30.789 [main] DEBUG org.apache.camel.impl.RouteService - Shutting down child service on route: route1 -> Pipeline[[Channel[BeanProcessor[com.edms.emagia.TestDemo(0x1e884ca9)]], Channel[sendTo(Endpoint[mock://abc])], Channel[setHeader(tablename, Simple: abc)], Channel[SetBody(Simple: load data local inpath '/sri/address.txt' OVERWRITE into table ${in.header.tablename})]]] 22:46:30.808 [main] DEBUG org.apache.camel.impl.RouteService - Shutting down child service on route: route1 -> BeanProcessor[com.edms.emagia.TestDemo(0x1e884ca9)] 22:46:30.809 [main] DEBUG org.apache.camel.impl.RouteService - Shutting down child service on route: route1 -> Channel[BeanProcessor[com.edms.emagia.TestDemo(0x1e884ca9)]] 22:46:30.809 [main] DEBUG org.apache.camel.impl.RouteService - Shutting down child service on route: route1 -> sendTo(Endpoint[mock://abc]) 22:46:30.809 [main] DEBUG org.apache.camel.impl.RouteService - Shutting down child service on route: route1 -> Channel[sendTo(Endpoint[mock://abc])] 22:46:30.809 [main] DEBUG org.apache.camel.impl.RouteService - Shutting down child service on route: route1 -> Channel[setHeader(tablename, Simple: abc)] 22:46:30.809 [main] DEBUG org.apache.camel.impl.RouteService - Shutting down child service on route: route1 -> SetBody(Simple: load data local inpath '/sri/address.txt' OVERWRITE into table ${in.header.tablename}) 22:46:30.809 [main] DEBUG org.apache.camel.impl.RouteService - Shutting down child service on route: route1 -> Channel[SetBody(Simple: load data local inpath '/sri/address.txt' OVERWRITE into table ${in.header.tablename})] 22:46:30.809 [main] DEBUG org.apache.camel.impl.RouteService - Shutting down services on route: route1 22:46:30.813 [main] DEBUG o.a.c.component.bean.BeanComponent - Clearing BeanInfo cache[size=1, hits=0, misses=1, evicted=0] 22:46:30.815 [main] DEBUG o.a.c.support.TimerListenerManager - Removed TimerListener: org.apache.camel.management.mbean.ManagedCamelContext@48f2f70c 22:46:30.815 [main] DEBUG o.a.c.m.DefaultManagementAgent - Unregistered MBean with ObjectName: org.apache.camel:context=quickstart.cloudera/camel-1,type=context,name="camel-1" 22:46:30.815 [main] DEBUG o.a.c.i.DefaultExecutorServiceManager - Forcing shutdown of ExecutorService: org.apache.camel.util.concurrent.SizedScheduledExecutorService@5aed63a3[ManagementLoadTask] 22:46:30.816 [main] DEBUG o.a.c.m.DefaultManagementAgent - Unregistered MBean with ObjectName: org.apache.camel:context=quickstart.cloudera/camel-1,type=threadpools,name="TimerListenerManager" 22:46:30.817 [main] DEBUG o.a.c.i.DefaultExecutorServiceManager - Forcing shutdown of ExecutorService: org.apache.camel.util.concurrent.RejectableThreadPoolExecutor@11648e6f[Running, pool size = 1, active threads = 0, queued tasks = 0, completed tasks = 1][ShutdownTask] 22:46:30.822 [main] DEBUG o.a.c.impl.DefaultInflightRepository - Shutting down with no inflight exchanges. 22:46:30.823 [main] DEBUG o.a.c.m.DefaultManagementAgent - Unregistered MBean with ObjectName: org.apache.camel:context=quickstart.cloudera/camel-1,type=services,name=DefaultInflightRepository 22:46:30.823 [main] DEBUG o.a.c.m.DefaultManagementAgent - Unregistered MBean with ObjectName: org.apache.camel:context=quickstart.cloudera/camel-1,type=processors,name="setBody1" 22:46:30.823 [main] DEBUG o.a.c.m.DefaultManagementAgent - Unregistered MBean with ObjectName: org.apache.camel:context=quickstart.cloudera/camel-1,type=errorhandlers,name="DefaultErrorHandlerBuilder(ref:CamelDefaultErrorHandlerBuilder)" 22:46:30.824 [main] DEBUG o.a.c.m.DefaultManagementAgent - Unregistered MBean with ObjectName: org.apache.camel:context=quickstart.cloudera/camel-1,type=services,name=DefaultTypeConverter 22:46:30.824 [main] DEBUG o.a.c.m.DefaultManagementAgent - Unregistered MBean with ObjectName: org.apache.camel:context=quickstart.cloudera/camel-1,type=services,name=TimerListenerManager 22:46:30.824 [main] DEBUG o.a.c.m.DefaultManagementAgent - Unregistered MBean with ObjectName: org.apache.camel:context=quickstart.cloudera/camel-1,type=services,name=SharedProducerServicePool 22:46:30.824 [main] DEBUG o.a.c.m.DefaultManagementAgent - Unregistered MBean with ObjectName: org.apache.camel:context=quickstart.cloudera/camel-1,type=services,name=DefaultPackageScanClassResolver 22:46:30.824 [main] DEBUG o.a.c.m.DefaultManagementAgent - Unregistered MBean with ObjectName: org.apache.camel:context=quickstart.cloudera/camel-1,type=processors,name="bean1" 22:46:30.824 [main] DEBUG o.a.c.m.DefaultManagementAgent - Unregistered MBean with ObjectName: org.apache.camel:context=quickstart.cloudera/camel-1,type=services,name=DefaultExecutorServiceManager 22:46:30.825 [main] DEBUG o.a.c.m.DefaultManagementAgent - Unregistered MBean with ObjectName: org.apache.camel:context=quickstart.cloudera/camel-1,type=services,name=DefaultShutdownStrategy 22:46:30.825 [main] DEBUG o.a.c.m.DefaultManagementAgent - Unregistered MBean with ObjectName: org.apache.camel:context=quickstart.cloudera/camel-1,type=endpoints,name="timer://foo\?period=60000" 22:46:30.825 [main] DEBUG o.a.c.m.DefaultManagementAgent - Unregistered MBean with ObjectName: org.apache.camel:context=quickstart.cloudera/camel-1,type=endpoints,name="mock://abc" 22:46:30.825 [main] DEBUG o.a.c.m.DefaultManagementAgent - Unregistered MBean with ObjectName: org.apache.camel:context=quickstart.cloudera/camel-1,type=processors,name="to1" 22:46:30.825 [main] DEBUG o.a.c.m.DefaultManagementAgent - Unregistered MBean with ObjectName: org.apache.camel:context=quickstart.cloudera/camel-1,type=tracer,name=BacklogDebugger 22:46:30.829 [main] DEBUG o.a.c.m.DefaultManagementAgent - Unregistered MBean with ObjectName: org.apache.camel:context=quickstart.cloudera/camel-1,type=components,name="timer" 22:46:30.829 [main] DEBUG o.a.c.m.DefaultManagementAgent - Unregistered MBean with ObjectName: org.apache.camel:context=quickstart.cloudera/camel-1,type=tracer,name=BacklogTracer 22:46:30.829 [main] DEBUG o.a.c.m.DefaultManagementAgent - Unregistered MBean with ObjectName: org.apache.camel:context=quickstart.cloudera/camel-1,type=services,name=EndpointRegistry 22:46:30.829 [main] DEBUG o.a.c.m.DefaultManagementAgent - Unregistered MBean with ObjectName: org.apache.camel:context=quickstart.cloudera/camel-1,type=components,name="bean" 22:46:30.829 [main] DEBUG o.a.c.m.DefaultManagementAgent - Unregistered MBean with ObjectName: org.apache.camel:context=quickstart.cloudera/camel-1,type=components,name="mock" 22:46:30.829 [main] DEBUG o.a.camel.util.IntrospectionSupport - Clearing cache[size=0, hits=73, misses=57, evicted=0] 22:46:30.835 [main] INFO o.a.camel.impl.DefaultCamelContext - Apache Camel 2.12.5 (CamelContext: camel-1) uptime 11.099 seconds 22:46:30.837 [main] INFO o.a.camel.impl.DefaultCamelContext - Apache Camel 2.12.5 (CamelContext: camel-1) is shutdown in 0.056 seconds Data is not coming into the table. Tell me one thing, how to do we refer a table name in camel Means how we fetch the element name from xsd in camel, Here what i did, from("timer://foo?period=60000") .bean(TestDemo.class,"parseElement(/home/cloudera/Desktop/Sample.xsd)") .to("mock:abc") .setHeader("tablename", simple("abc")). setBody(simple("load data local inpath '/sri/address.txt' OVERWRITE into table ${in.header.tablename}")) with the below lines can we get the table name .to("mock:abc") .setHeader("tablename", simple("abc")). -- View this message in context: http://camel.465427.n5.nabble.com/camel-xsd-tp5760000p5760010.html Sent from the Camel - Users mailing list archive at Nabble.com.