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);