enforce remote HDFS

cat-job/src/main/java/com/dianping/cat/job/build/ComponentsConfigurator.java

@@ -30,30 +30,20 @@ public class ComponentsConfigurator extends AbstractResourceConfigurator {
 	@Override
 	public List<Component> defineComponents() {
 		List<Component> all = new ArrayList<Component>();
+		String serverUri = property("serve-uri", "hdfs://192.168.7.43:9000/user/cat");
 
-		if (isEnv("dev") || property("env", null) == null) {
-			all.add(C(OutputChannel.class, DefaultOutputChannel.class).is(PER_LOOKUP) //
-			      .req(MessageCodec.class, "plain-text") //
-			      .config(E("maxSize").value(String.valueOf(2 * 1024 * 1024L))));
-			all.add(C(OutputChannelManager.class, DefaultOutputChannelManager.class) //
-			      .req(MessagePathBuilder.class));
-			all.add(C(InputChannel.class, DefaultInputChannel.class).is(PER_LOOKUP) //
-			      .req(MessageCodec.class, "plain-text"));
-			all.add(C(InputChannelManager.class, DefaultInputChannelManager.class));
-		} else {
-			all.add(C(OutputChannel.class, DefaultOutputChannel.class).is(PER_LOOKUP) //
-			      .req(MessageCodec.class, "plain-text") //
-			      .config(E("maxSize").value(String.valueOf(128 * 1024 * 1024L))));
-			all.add(C(OutputChannelManager.class, DefaultOutputChannelManager.class) //
-			      .req(MessagePathBuilder.class) //
-			      .config(E("baseDir").value("data"), //
-			            E("serverUri").value("hdfs://192.168.7.43:9000/user/cat/")));
-			all.add(C(InputChannel.class, DefaultInputChannel.class).is(PER_LOOKUP) //
-			      .req(MessageCodec.class, "plain-text"));
-			all.add(C(InputChannelManager.class, DefaultInputChannelManager.class) //
-			      .config(E("baseDir").value("data"), //
-			    		  E("serverUri").value("hdfs://192.168.7.43:9000/user/cat/")));
-		}
+		all.add(C(OutputChannel.class, DefaultOutputChannel.class).is(PER_LOOKUP) //
+		      .req(MessageCodec.class, "plain-text") //
+		      .config(E("maxSize").value(String.valueOf(128 * 1024 * 1024L))));
+		all.add(C(OutputChannelManager.class, DefaultOutputChannelManager.class) //
+		      .req(MessagePathBuilder.class) //
+		      .config(E("baseDir").value("data"), //
+		            E("serverUri").value(serverUri)));
+		all.add(C(InputChannel.class, DefaultInputChannel.class).is(PER_LOOKUP) //
+		      .req(MessageCodec.class, "plain-text"));
+		all.add(C(InputChannelManager.class, DefaultInputChannelManager.class) //
+		      .config(E("baseDir").value("data"), //
+		            E("serverUri").value(serverUri)));
 
 		all.add(C(MessageStorage.class, "hdfs", HdfsMessageStorage.class) //
 		      .req(OutputChannelManager.class));

cat-job/src/main/resources/META-INF/plexus/components.xml

@@ -5,7 +5,7 @@
 			<implementation>com.dianping.cat.job.hdfs.DefaultOutputChannel</implementation>
 			<instantiation-strategy>per-lookup</instantiation-strategy>
 			<configuration>
-				<maxSize>2097152</maxSize>
+				<maxSize>134217728</maxSize>
 			</configuration>
 			<requirements>
 				<requirement>
@@ -17,6 +17,10 @@
 		<component>
 			<role>com.dianping.cat.job.hdfs.OutputChannelManager</role>
 			<implementation>com.dianping.cat.job.hdfs.DefaultOutputChannelManager</implementation>
+			<configuration>
+				<baseDir>data</baseDir>
+				<serverUri>hdfs://192.168.7.43:9000/user/cat</serverUri>
+			</configuration>
 			<requirements>
 				<requirement>
 					<role>com.dianping.cat.message.spi.MessagePathBuilder</role>
@@ -37,6 +41,10 @@
 		<component>
 			<role>com.dianping.cat.job.hdfs.InputChannelManager</role>
 			<implementation>com.dianping.cat.job.hdfs.DefaultInputChannelManager</implementation>
+			<configuration>
+				<baseDir>data</baseDir>
+				<serverUri>hdfs://192.168.7.43:9000/user/cat</serverUri>
+			</configuration>
 		</component>
 		<component>
 			<role>com.dianping.cat.message.spi.MessageStorage</role>