[ 
https://issues.apache.org/jira/browse/FLUME-2095?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14901571#comment-14901571
 ] 

Hudson commented on FLUME-2095:
-------------------------------

UNSTABLE: Integrated in Flume-trunk-hbase-1 #123 (See 
[https://builds.apache.org/job/Flume-trunk-hbase-1/123/])
FLUME-2095. JMS source with TIBCO (johnyrufus: 
http://git-wip-us.apache.org/repos/asf/flume/repo?p=flume.git&a=commit&h=2cc93b777865195a9bb2329946a14f301213ea3d)
* 
flume-ng-sources/flume-jms-source/src/main/java/org/apache/flume/source/jms/JMSSource.java


> JMS source with TIBCO
> ---------------------
>
>                 Key: FLUME-2095
>                 URL: https://issues.apache.org/jira/browse/FLUME-2095
>             Project: Flume
>          Issue Type: Question
>          Components: Sinks+Sources
>    Affects Versions: v1.5.0
>         Environment: Windows 7
>            Reporter: Bhaskar Reddy
>            Assignee: Michelle Casbon
>            Priority: Critical
>              Labels: easyfix, features, jms
>             Fix For: v1.7.0
>
>         Attachments: FLUME-2095-0.patch, FLUME-2095-1.patch, 
> FLUME-2095-2.patch
>
>
> Hi,
> I was trying to use the JMS source to work with TIBCO, but I am encountering 
> the exception below,
> org.apache.flume.FlumeException: Could not lookup ConnectionFactory
>       at org.apache.flume.source.jms.JMSSource.doConfigure(JMSSource.java:222)
>       at 
> org.apache.flume.source.BasicSourceSemantics.configure(BasicSourceSemantics.java:65)
>       at org.apache.flume.conf.Configurables.configure(Configurables.java:41)
>       at 
> org.apache.flume.node.AbstractConfigurationProvider.loadSources(AbstractConfigurationProvider.java:331)
>       at 
> org.apache.flume.node.AbstractConfigurationProvider.getConfiguration(AbstractConfigurationProvider.java:102)
>       at 
> org.apache.flume.node.PollingPropertiesFileConfigurationProvider$FileWatcherRunnable.run(PollingPropertiesFileConfigurationProvider.java:140)
>       at 
> java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:439)
>       at 
> java.util.concurrent.FutureTask$Sync.innerRunAndReset(FutureTask.java:317)
>       at java.util.concurrent.FutureTask.runAndReset(FutureTask.java:150)
>       at 
> java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$101(ScheduledThreadPoolExecutor.java:98)
>       at 
> java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.runPeriodic(ScheduledThreadPoolExecutor.java:180)
>       at 
> java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:204)
>       at 
> java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:895)
>       at 
> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918)
>       at java.lang.Thread.run(Thread.java:662)
> Caused by: javax.naming.NameNotFoundException: Name not found: 
> 'com.tibco.tibjms.TibjmsQueueConnectionFactory'
>       at com.tibco.tibjms.naming.TibjmsContext.lookup(TibjmsContext.java:715)
>       at com.tibco.tibjms.naming.TibjmsContext.lookup(TibjmsContext.java:491)
>       at javax.naming.InitialContext.lookup(InitialContext.java:392)
>       at org.apache.flume.source.jms.JMSSource.doConfigure(JMSSource.java:219)
>       ... 14 more
> Please find my configuration below,
> a1.sources.r1.type = jms
> a1.sources.r1.channels = c1
> a1.sources.r1.initialContextFactory = 
> com.tibco.tibjms.naming.TibjmsInitialContextFactory
> a1.sources.r1.connectionFactory = 
> com.tibco.tibjms.TibjmsQueueConnectionFactory
> a1.sources.r1.providerURL = tibjmsnaming://localhost:7222
> a1.sources.r1.destinationName = sample
> a1.sources.r1.destinationType = QUEUE
> I tried changing the configuration below,
> a1.sources.r1.type = jms
> a1.sources.r1.channels = c1
> a1.sources.r1.initialContextFactory = 
> com.tibco.tibjms.naming.TibjmsInitialContextFactory
> a1.sources.r1.providerURL = tcp://localhost:7222
> a1.sources.r1.destinationName = sample
> a1.sources.r1.destinationType = QUEUE
> Thanks,
> Bhaskar.



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

Reply via email to