MockMessageBuilderTest.java
3.51 KB
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
package com.dianping.cat.message.internal;
import junit.framework.Assert;
import org.junit.Test;
import com.dianping.cat.message.Message;
public class MockMessageBuilderTest {
@Test
public void test() {
Message message = new MockMessageBuilder() {
@Override
public MessageHolder define() {
TransactionHolder t = t("WEB CLUSTER", "GET", 112819) //
.at(1348374838231L) //
.after(1300).child(t("QUICKIE SERVICE", "gimme_stuff", 1571)) //
.after(100).child(e("SERVICE", "event1")) //
.after(100).child(h("SERVICE", "heartbeat1")) //
.after(100).child(t("WEB SERVER", "GET", 109358) //
.after(1000).child(t("SOME SERVICE", "get", 4345) //
.after(4000).child(t("MEMCACHED", "Get", 279))) //
.mark().after(200).child(t("MEMCACHED", "Inc", 319)) //
.reset().after(500).child(t("BIG ASS SERVICE", "getThemDatar", 97155) //
.after(1000).mark().child(t("SERVICE", "getStuff", 3760)) //
.reset().child(t("DATAR", "findThings", 94537)) //
.after(200).child(t("THINGIE", "getMoar", 1435)) //
) //
.after(100).mark().child(t("OTHER DATA SERVICE", "get", 4394) //
.after(1000).mark().child(t("MEMCACHED", "Get", 378)) //
.reset().child(t("MEMCACHED", "Get", 3496)) //
) //
.reset().child(t("FINAL DATA SERVICE", "get", 4394) //
.after(1000).mark().child(t("MEMCACHED", "Get", 386)) //
.reset().child(t("MEMCACHED", "Get", 322)) //
.reset().child(t("MEMCACHED", "Get", 322)) //
) //
) //
;
return t;
}
}.build();
Assert.assertEquals("t2012-09-23 12:33:58.231 WEB CLUSTER GET \n" + //
"A2012-09-23 12:33:58.232 QUICKIE SERVICE gimme_stuff 0 1571us \n" + //
"E2012-09-23 12:33:58.233 SERVICE event1 0 \n" + //
"H2012-09-23 12:33:58.234 SERVICE heartbeat1 0 \n" + //
"t2012-09-23 12:33:58.234 WEB SERVER GET \n" + //
"t2012-09-23 12:33:58.235 SOME SERVICE get \n" + //
"A2012-09-23 12:33:58.239 MEMCACHED Get 0 279us \n" + //
"T2012-09-23 12:33:58.239 SOME SERVICE get 0 4345us \n" + //
"A2012-09-23 12:33:58.239 MEMCACHED Inc 0 319us \n" + //
"t2012-09-23 12:33:58.240 BIG ASS SERVICE getThemDatar \n" + //
"A2012-09-23 12:33:58.241 SERVICE getStuff 0 3760us \n" + //
"A2012-09-23 12:33:58.241 DATAR findThings 0 94537us \n" + //
"A2012-09-23 12:33:58.335 THINGIE getMoar 0 1435us \n" + //
"T2012-09-23 12:33:58.337 BIG ASS SERVICE getThemDatar 0 97155us \n" + //
"t2012-09-23 12:33:58.337 OTHER DATA SERVICE get \n" + //
"A2012-09-23 12:33:58.338 MEMCACHED Get 0 378us \n" + //
"A2012-09-23 12:33:58.338 MEMCACHED Get 0 3496us \n" + //
"T2012-09-23 12:33:58.341 OTHER DATA SERVICE get 0 4394us \n" + //
"t2012-09-23 12:33:58.337 FINAL DATA SERVICE get \n" + //
"A2012-09-23 12:33:58.338 MEMCACHED Get 0 386us \n" + //
"A2012-09-23 12:33:58.338 MEMCACHED Get 0 322us \n" + //
"A2012-09-23 12:33:58.338 MEMCACHED Get 0 322us \n" + //
"T2012-09-23 12:33:58.341 FINAL DATA SERVICE get 0 4394us \n" + //
"T2012-09-23 12:33:58.343 WEB SERVER GET 0 109358us \n" + //
"T2012-09-23 12:33:58.343 WEB CLUSTER GET 0 112819us \n" + //
"", message.toString().replace("\r", ""));
}
}