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/09/21 02:03:17 UTC

svn commit: r1173433 - /incubator/flume/branches/flume-728/flume-ng-node/src/main/java/org/apache/flume/conf/file/JsonFileConfigurationProvider.java

Author: esammer
Date: Wed Sep 21 00:03:16 2011
New Revision: 1173433

URL: http://svn.apache.org/viewvc?rev=1173433&view=rev
Log:
- Added missing calls to Configurables.configure(t, ctx) for sinks and channels during config loading.

Modified:
    incubator/flume/branches/flume-728/flume-ng-node/src/main/java/org/apache/flume/conf/file/JsonFileConfigurationProvider.java

Modified: incubator/flume/branches/flume-728/flume-ng-node/src/main/java/org/apache/flume/conf/file/JsonFileConfigurationProvider.java
URL: http://svn.apache.org/viewvc/incubator/flume/branches/flume-728/flume-ng-node/src/main/java/org/apache/flume/conf/file/JsonFileConfigurationProvider.java?rev=1173433&r1=1173432&r2=1173433&view=diff
==============================================================================
--- incubator/flume/branches/flume-728/flume-ng-node/src/main/java/org/apache/flume/conf/file/JsonFileConfigurationProvider.java (original)
+++ incubator/flume/branches/flume-728/flume-ng-node/src/main/java/org/apache/flume/conf/file/JsonFileConfigurationProvider.java Wed Sep 21 00:03:16 2011
@@ -151,6 +151,8 @@ public class JsonFileConfigurationProvid
         Context context = new Context();
         context.setParameters(sinkDef);
 
+        Configurables.configure(sink, context);
+
         if (channel != null) {
           sink.setChannel(channel);
         } else {
@@ -180,6 +182,8 @@ public class JsonFileConfigurationProvid
         Context context = new Context();
         context.setParameters(channelDef);
 
+        Configurables.configure(channel, context);
+
         conf.getChannels().put((String) channelDef.get("name"), channel);
       }
     }