You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@flume.apache.org by "Jeff Lord (JIRA)" <ji...@apache.org> on 2014/03/03 17:39:20 UTC

[jira] [Created] (FLUME-2339) JMS Source configuration example causes a javax.naming.NameNotFoundException. Removing or commenting out the "connectionFactory" property fixes this

Jeff Lord created FLUME-2339:
--------------------------------

             Summary: JMS Source configuration example causes a javax.naming.NameNotFoundException. Removing or commenting out the "connectionFactory" property fixes this
                 Key: FLUME-2339
                 URL: https://issues.apache.org/jira/browse/FLUME-2339
             Project: Flume
          Issue Type: Improvement
          Components: Docs
            Reporter: Jeff Lord


Submitted on behalf of Richard Ross
The example jms source in the docs lists a connectionFactory property.
For an activemq source this will cause it to fail on startup as the connectionFactory is not used. We should update the docs to reflect this.

The default JMS Source configuration example causes a javax.naming.NameNotFoundException. Removing or commenting out the "connectionFactory" property fixes this. Maybe this should be documented?

Below is my full configuration example that reproduces the error:

# example.conf: A single-node Flume configuration

# Name the components on this agent
a1.sources = r1
a1.sinks = k1
a1.channels = c1

# Describe/configure the source
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://mqserver:61616
a1.sources.r1.destinationName = BUSINESS_DATA
a1.sources.r1.destinationType = QUEUE

# Describe the sink
a1.sinks.k1.type = logger

# Use a channel which buffers events in memory
a1.channels.c1.type = memory
a1.channels.c1.capacity = 1000
a1.channels.c1.transactionCapacity = 100

# Bind the source and sink to the channel
a1.sources.r1.channels = c1
a1.sinks.k1.channel = c1




--
This message was sent by Atlassian JIRA
(v6.2#6252)