[prev in list] [next in list] [prev in thread] [next in thread] 

List:       flume-commits
Subject:    svn commit: r1187971 - in /incubator/flume/branches/flume-728/flume-ng-node: pom.xml src/main/java/o
From:       esammer () apache ! org
Date:       2011-10-23 20:34:02
Message-ID: 20111023203402.F312423888FD () eris ! apache ! org
[Download RAW message or body]

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


[prev in list] [next in list] [prev in thread] [next in thread]