[FLUME-2095] JMS source with TIBCO

• Type: Question
• Status: Closed
• Priority: Critical
• Resolution: Fixed
• Affects Version/s: 1.5.0
• Fix Version/s: 1.7.0
• Component/s: Sinks+Sources
• Labels: easyfix features jms

Environment

Windows 7

• Release Note: Adds properties to the configuration for a JMS Source when it needs to connect to a JNDI Connection Factory with a User Name and Password.
• Assignee: Michelle Casbon
• Reporter: Bhaskar Reddy
• Created: 19/Jun/13 10:27
• Updated: 18/Jun/16 17:26
• Resolved: 21/Sep/15 21:03

Description

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.

Issue Links

• links to: Review Request #31924