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)