svn commit: r1368362 - /flume/trunk/flume-ng-core/src/main/java/org/apache/flume/channel/ChannelProcessor.java

[mubarak]

Author: mubarak
Date: Thu Aug  2 06:33:18 2012
New Revision: 1368362

URL: http://svn.apache.org/viewvc?rev=1368362&view=rev
Log:
FLUME-1389. Flume gives opaque error if interceptor type not specified.

(Patrick Wendell via Hari Shreedharan)

Modified:
    
flume/trunk/flume-ng-core/src/main/java/org/apache/flume/channel/ChannelProcessor.java

Modified: 
flume/trunk/flume-ng-core/src/main/java/org/apache/flume/channel/ChannelProcessor.java
URL: 
http://svn.apache.org/viewvc/flume/trunk/flume-ng-core/src/main/java/org/apache/flume/channel/ChannelProcessor.java?rev=1368362&r1=1368361&r2=1368362&view=diff
==============================================================================
--- 
flume/trunk/flume-ng-core/src/main/java/org/apache/flume/channel/ChannelProcessor.java
 (original)
+++ 
flume/trunk/flume-ng-core/src/main/java/org/apache/flume/channel/ChannelProcessor.java
 Thu Aug  2 06:33:18 2012
@@ -100,6 +100,11 @@ public class ChannelProcessor implements
       Context interceptorContext = new Context(
           interceptorContexts.getSubProperties(interceptorName + "."));
       String type = interceptorContext.getString("type");
+      if (type == null) {
+        LOG.error("Type not specified for interceptor " + interceptorName);
+        throw new FlumeException("Interceptor.Type not specified for " +
+          interceptorName);
+      }
       try {
         Interceptor.Builder builder = factory.newInstance(type);
         builder.configure(interceptorContext);