Thanks, Jeff. That was it. Easy peasy! Is this documented somewhere? If not, it should be. :-)
Richard. On Feb 24, 2014, at 6:09 PMEST, Jeff Lord wrote: > I think you can just drop the connectionFactory property from the > config altogether with activemq and it will work. > > On Mon, Feb 24, 2014 at 2:17 PM, Richard Ross > <[email protected]> wrote: >> Thanks for these responses. I have tried the FCQN, but the "connection >> factory" is just a name, and not a classname or FQCN. It could be "FOO", as >> far as I can tell. The error occurs when the JNDI connection by this name is >> looked up. I am thinking that this is possibly a configuration detail with >> ActiveMQ. Has anyone successfully created a JMS source? >> >> Thanks again, >> Richard. >> >> On Feb 24, 2014, at 4:05 PMEST, Jeff Lord wrote: >> >> 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 = r1 >>> a1.channels = c1 >>> a1.sources.r1.type = jms >>> a1.sources.r1.channels = c1 >>> a1.sources.r1.initialContextFactory = >>> org.apache.activemq.jndi.ActiveMQInitialContextFactory >>> a1.sources.r1.connectionFactory = GenericConnectionFactory >>> a1.sources.r1.providerURL = tcp://<myipaddress>:61616 >>> a1.sources.r1.destinationName = TEST >>> a1.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 >> >>
