I'd be happy to. And thanks for your help. Richard.
On Mon, Feb 24, 2014 at 10:20 PM, Jeff Lord <[email protected]> wrote: > Glad to hear! > I don't see it documented anywhere but that is probably because it > just depends on the jms implementation. Regardless the user guide > clearly states we test with activemq so we should at least document a > default setting for that. Would you be able to file a doc jira to > improve this? > > > flume-ng-sources/flume-jms-source/src/test/java/org/apache/flume/source/jms/TestIntegrationActiveMQ.java > > On Mon, Feb 24, 2014 at 7:09 PM, Richard Ross > <[email protected]> wrote: > > 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 > >>> > >>> > > >
