You are viewing a plain text version of this content. The canonical link for it is here.
Posted to users@activemq.apache.org by Sunil Tripathy <su...@yahoo.com> on 2013/08/31 23:58:40 UTC

flume and activemq configuration error

Hi, 
  I am trying to configure flume to use activemq as a source. I am getting the following error when I start my flume agent. 
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)

My flume source configuration is:
# Describe/configure the source
a1.sources.r1.type = org.apache.flume.source.jms.JMSSource
a1.sources.r1.channels = c1
a1.sources.r1.initialContextFactory = org.apache.activemq.jndi.ActiveMQInitialContextFactory
a1.sources.r1.connectionFactory = GenericConnectionFactory
a1.sources.r1.providerURL = tcp://localhost:61616
a1.sources.r1.destinationName = TEST
a1.sources.r1.destinationType = QUEUE

Would like get some help to resolve the issue.

Thanks
Sunil

Re: flume and activemq configuration error

Posted by Christian Posta <ch...@gmail.com>.
Might be best to ask this on the Apache Flume mailing lists:
http://flume.apache.org/mailinglists.html


On Sat, Aug 31, 2013 at 2:58 PM, Sunil Tripathy <su...@yahoo.com>wrote:

> Hi,
>   I am trying to configure flume to use activemq as a source. I am getting
> the following error when I start my flume agent.
> 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)
>
> My flume source configuration is:
> # Describe/configure the source
> a1.sources.r1.type = org.apache.flume.source.jms.JMSSource
> a1.sources.r1.channels = c1
> a1.sources.r1.initialContextFactory =
> org.apache.activemq.jndi.ActiveMQInitialContextFactory
> a1.sources.r1.connectionFactory = GenericConnectionFactory
> a1.sources.r1.providerURL = tcp://localhost:61616
> a1.sources.r1.destinationName = TEST
> a1.sources.r1.destinationType = QUEUE
>
> Would like get some help to resolve the issue.
>
> Thanks
> Sunil




-- 
*Christian Posta*
http://www.christianposta.com/blog
twitter: @christianposta