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.
