flume-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Luce Sylvain <sylvain.luce....@gmail.com>
Subject Re: Flume with ActiveMQ
Date Tue, 25 Feb 2014 09:33:18 GMT
Hi,
I had the same error and just comment

#a1.sources.r1.connectionFactory = GenericConnectionFactory

And all work fine !


Sylvain

2014-02-25 4:20 GMT+01:00 Jeff Lord <jlord@cloudera.com>:

> 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
> <richard.prionses@gmail.com> 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
> >> <richard.prionses@gmail.com> 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 <ruvikal@gmail.com> 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 <
> richard.prionses@gmail.com>
> >>>> 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 <ruvikal@gmail.com> wrote:
> >>>>
> >>>> Does the queue need any username and password ?
> >>>>
> >>>>
> >>>> On Mon, Feb 24, 2014 at 11:41 AM, richard ross
> >>>> <richard.prionses@gmail.com> 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
> >>>
> >>>
> >
>

Mime
View raw message