flume-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Richard Ross <richard.prion...@gmail.com>
Subject Re: Flume with ActiveMQ
Date Tue, 25 Feb 2014 03:09:35 GMT
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