Have you tried using the fqcn of the connection factory? On Monday, February 24, 2014, P lva <[email protected]> wrote:
> If there is no connection factory called 'GenericConnectionFactory' the > lookup fails and you get this. > > > > On Mon, Feb 24, 2014 at 1:29 PM, richard ross > <[email protected]>wrote: > > Thanks for the reply. No, there is no authentication setup yet. > > Here's a little of what I have figured out since the original email. I was > misinterpreting the error from using "GenericConnectionFactory" or " > org.apache.activemq.ActiveMQConnectionFactory", as this is just the JNDI > context name. The error is simply coming from the lookup call from the initial > context. As to why that error is occurring, I still have no idea. > > Richard. > > > On Mon, Feb 24, 2014 at 1:35 PM, P lva <[email protected]> wrote: > > Does the queue need any username and password ? > > > On Mon, Feb 24, 2014 at 11:41 AM, richard ross <[email protected] > > wrote: > > Hello: > > I am doing a POC using Flume (1.4) with a JMS (ActiveMQ 5.6) source. I > have used the example source configuration from the documentation: > > a1.sources = r1a1.channels = c1a1.sources.r1.type = jmsa1.sources.r1.channels > = c1a1.sources.r1.initialContextFactory = > org.apache.activemq.jndi.ActiveMQInitialContextFactorya1.sources.r1.connectionFactory > = GenericConnectionFactorya1.sources.r1.providerURL = > tcp://<myipaddress>:61616a1.sources.r1.destinationName = > TESTa1.sources.r1.destinationType = QUEUE > > > I get the following error: > > 2014-02-24 12:33:05,959 (conf-file-poller-0) [ERROR - > org.apache.flume.node.AbstractConfigurationProvider.loadSources(AbstractConfigurationProvider.java:366)] > Source r1 has been removed due to an error during configuration > 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(AbstractCo > >
