You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flume.apache.org by es...@apache.org on 2011/10/23 22:34:02 UTC
svn commit: r1187971 - in /incubator/flume/branches/flume-728/flume-ng-node:
pom.xml src/main/java/org/apache/flume/node/Application.java
Author: esammer
Date: Sun Oct 23 20:34:02 2011
New Revision: 1187971
URL: http://svn.apache.org/viewvc?rev=1187971&view=rev
Log:
FLUME-819: JDBC channel plugin is not registered with Flume node
Modified:
incubator/flume/branches/flume-728/flume-ng-node/pom.xml
incubator/flume/branches/flume-728/flume-ng-node/src/main/java/org/apache/flume/node/Application.java
Modified: incubator/flume/branches/flume-728/flume-ng-node/pom.xml
URL: http://svn.apache.org/viewvc/incubator/flume/branches/flume-728/flume-ng-node/pom.xml?rev=1187971&r1=1187970&r2=1187971&view=diff
==============================================================================
--- incubator/flume/branches/flume-728/flume-ng-node/pom.xml (original)
+++ incubator/flume/branches/flume-728/flume-ng-node/pom.xml Sun Oct 23 20:34:02 2011
@@ -29,6 +29,12 @@
</dependency>
<dependency>
+ <groupId>org.apache.flume.flume-ng-channels</groupId>
+ <artifactId>flume-jdbc-channel</artifactId>
+ <version>${project.version}</version>
+ </dependency>
+
+ <dependency>
<groupId>org.slf4j</groupId>
<artifactId>slf4j-api</artifactId>
</dependency>
Modified: incubator/flume/branches/flume-728/flume-ng-node/src/main/java/org/apache/flume/node/Application.java
URL: http://svn.apache.org/viewvc/incubator/flume/branches/flume-728/flume-ng-node/src/main/java/org/apache/flume/node/Application.java?rev=1187971&r1=1187970&r2=1187971&view=diff
==============================================================================
--- incubator/flume/branches/flume-728/flume-ng-node/src/main/java/org/apache/flume/node/Application.java (original)
+++ incubator/flume/branches/flume-728/flume-ng-node/src/main/java/org/apache/flume/node/Application.java Sun Oct 23 20:34:02 2011
@@ -14,6 +14,7 @@ import org.apache.flume.SinkFactory;
import org.apache.flume.SourceFactory;
import org.apache.flume.channel.DefaultChannelFactory;
import org.apache.flume.channel.MemoryChannel;
+import org.apache.flume.channel.jdbc.JdbcChannel;
import org.apache.flume.conf.file.AbstractFileConfigurationProvider;
import org.apache.flume.conf.properties.PropertiesFileConfigurationProvider;
import org.apache.flume.lifecycle.LifecycleController;
@@ -76,6 +77,7 @@ public class Application {
public void loadPlugins() {
channelFactory.register("memory", MemoryChannel.class);
+ channelFactory.register("jdbc", JdbcChannel.class);
sourceFactory.register("seq", SequenceGeneratorSource.class);
sourceFactory.register("netcat", NetcatSource.class);