modify the cat message tree upload

cat-consumer/src/main/java/com/dianping/cat/consumer/dump/DumpAnalyzer.java

@@ -151,9 +151,9 @@ public class DumpAnalyzer extends AbstractMessageAnalyzer<Object> implements Ini
 
 		if (!m_localMode) {
 			m_uploader.start();
-
-			Threads.forGroup("Cat").start(new WriteMessageTree());
 		}
+
+		Threads.forGroup("Cat").start(new WriteMessageTree());
 	}
 
 	public class WriteMessageTree implements Task {

cat-consumer/src/test/resources/com/dianping/cat/consumer/sql/sql.xml

+<sql-report domain="MobileApi" startTime="2012-06-18 14:00:00"
+	endTime="2012-06-18 14:59:59">
+	<domain>Cat</domain>
+	<domain>MobileApi</domain>
+	<ip>10.1.77.193</ip>
+	<ip>10.1.77.194</ip>
+	<local id="10.1.77.193">
+		<remote id="10.1.77.194" role="Pigeon.Client">
+			<type id="PigeonCall" totalCount="111507" failCount="0" failPercent="0.00"
+				avg="0.0" sum="1937.0" sum2="34333.7" std="0.0" tps="0.00">
+				<name id="GroupService:GroupClass:GroupMethod" totalCount="1"
+				</name>
+				<name id="GroupService:GroupClass:GroupMethod1" totalCount="1"
+					failCount="0" failPercent="0.00" avg="0.0" sum="0.9" sum2="0.8"
+					std="0.0" tps="0.00">
+				</name>
+			</type>
+		</remote>
+		<remote id="10.1.77.194:8080" role="Pigeon.Server">
+			<type id="PigeonCall" totalCount="111 507" failCount="0" failPercent="0.00"
+				avg="0.0" sum="1937.0" sum2="34333.7" std="0.0" tps="0.00">
+				<name id="GroupService:GroupClass:GroupMethod" totalCount="1"
+					failCount="0" failPercent="0.00" avg="0.0" sum="13.3" tps="0.00">
+				</name>
+				<name id="GroupService:GroupClass:GroupMethod1" totalCount="1"
+					failCount="0" failPercent="0.00" avg="0.0" sum="0.9" tps="0.00">
+				</name>
+			</type>
+		</remote>
+		<remote></remote>
+	</local>
+</sql-report>
+

cat-core/src/main/java/com/dianping/cat/storage/dump/LocalMessageBucketManager.java

@@ -248,7 +248,7 @@ public class LocalMessageBucketManager extends ContainerHolder implements Messag
 
 					try {
 						closeIdleBuckets();
-					} catch (IOException e) {
+					} catch (Throwable e) {
 						Cat.getProducer().logError(e);
 					}
 				}

cat-home/src/main/java/com/dianping/cat/report/task/transaction/TransactionMerger.java

@@ -11,6 +11,7 @@ import com.dianping.cat.Cat;
 import com.dianping.cat.consumer.transaction.model.entity.TransactionReport;
 import com.dianping.cat.consumer.transaction.model.transform.DefaultSaxParser;
 import com.dianping.cat.hadoop.dal.Report;
+import com.dianping.cat.message.Event;
 import com.dianping.cat.report.page.model.transaction.TransactionReportMerger;
 import com.dianping.cat.report.task.ReportMerger;
 import com.dianping.cat.report.task.TaskHelper;
@@ -32,6 +33,10 @@ public class TransactionMerger implements ReportMerger<TransactionReport> {
 				model.accept(merger);
 			} catch (Exception e) {
 				Cat.logError(e);
+				
+				Event event = Cat.getProducer().newEvent("Transaction", "XML");
+				event.setStatus(Event.SUCCESS);
+				event.addData(xml);
 			}
 		}