package com.dianping.cat.demo;
import org.junit.Test;
import org.unidal.helper.Threads;
import com.dianping.cat.Cat;
import com.dianping.cat.message.Event;
import com.dianping.cat.message.Transaction;
public class ThreadTest {
@Test
public void test() throws InterruptedException {
Transaction t = Cat.newTransaction("test3", "test3");
String id= Cat.getProducer().createMessageId();
Threads.forGroup("cat").start(new Task(id));
Cat.logEvent("RemoteLink", "ChildThread3", Event.SUCCESS, id);
t.complete();
Thread.sleep(1000);
}
public static class Task implements Runnable{
private String m_messageId;
public Task(String id){
m_messageId = id;
}
@Override
public void run() {
Transaction t = Cat.newTransaction("test2", "test2");
Cat.getManager().getThreadLocalMessageTree().setMessageId(m_messageId);
t.complete();
}
}
}