bugfix

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

@@ -50,7 +50,7 @@ public class ComponentsConfigurator extends AbstractResourceConfigurator {
 			      .config(E("baseDir").value("dump"), //
 			            E("serverUri").value(serverUri)));
 		all.add(C(MessageStorage.class, "hdfs", HdfsMessageStorage.class) //
-		      .req(OutputChannelManager.class, "dump"));
+		      .req(OutputChannelManager.class, "dump").req(MessagePathBuilder.class));
 		all.add(C(MessageConsumer.class, DumpToHdfsConsumer.ID, DumpToHdfsConsumer.class) //
 		      .req(MessageStorage.class, "hdfs"));
 

cat-job/src/main/java/com/dianping/cat/job/hdfs/HdfsMessageStorage.java

 package com.dianping.cat.job.hdfs;
 
 import java.io.IOException;
+import java.net.InetAddress;
+import java.util.Date;
 import java.util.concurrent.BlockingQueue;
 import java.util.concurrent.LinkedBlockingQueue;
 import java.util.concurrent.TimeUnit;
@@ -87,7 +89,10 @@ public class HdfsMessageStorage implements MessageStorage, Initializable, Dispos
 
 		private void handle(MessageTree tree) {
 			try {
-				OutputChannel channel = m_manager.openChannel(tree, false);
+				String tmp = m_builder.getMessagePath(tree.getDomain(), new Date(tree.getMessage().getTimestamp()));
+				String ipAddress = InetAddress.getLocalHost().getHostAddress();
+				String path = tmp + "-" + ipAddress;
+				OutputChannel channel = m_manager.openChannel(path, false);
 				int length = channel.write(tree);
 
 				if (length <= 0) {
@@ -151,19 +156,16 @@ public class HdfsMessageStorage implements MessageStorage, Initializable, Dispos
 	}
 
 	public MessageTree get(String messageId) {
-		// TODO
-		return null;
+		throw new UnsupportedOperationException();
 	}
 
 	@Override
 	public MessageTree next(String messageId, String tag) {
-		// TODO Auto-generated method stub
-		return null;
+		throw new UnsupportedOperationException();
 	}
 
 	@Override
 	public MessageTree previous(String messageId, String tag) {
-		// TODO Auto-generated method stub
-		return null;
+		throw new UnsupportedOperationException();
 	}
 }

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

@@ -69,6 +69,9 @@
 					<role>com.dianping.cat.job.hdfs.OutputChannelManager</role>
 					<role-hint>dump</role-hint>
 				</requirement>
+				<requirement>
+					<role>com.dianping.cat.message.spi.MessagePathBuilder</role>
+				</requirement>
 			</requirements>
 		</component>
 		<component>