@@ -9,58 +9,72 @@ var _ gbus.Message = &Reply2{}
9
9
var _ gbus.Message = & Event1 {}
10
10
var _ gbus.Message = & Event2 {}
11
11
12
+ //PoisonMessage is a malformed message to test posion pill scenarios
12
13
type PoisonMessage struct {
13
14
}
14
15
16
+ //SchemaName implementing gbus.Message
15
17
func (PoisonMessage ) SchemaName () string {
16
18
//an empty schema name will result in a message being treated as poison
17
19
return ""
18
20
}
19
21
22
+ //Command1 for testing
20
23
type Command1 struct {
21
24
Data string
22
25
}
23
26
27
+ //SchemaName implementing gbus.Message
24
28
func (Command1 ) SchemaName () string {
25
29
return "grabbit.tests.Command1"
26
30
}
27
31
32
+ //Command2 for testing
28
33
type Command2 struct {
29
34
Data string
30
35
}
31
36
37
+ //SchemaName implementing gbus.Message
32
38
func (Command2 ) SchemaName () string {
33
39
return "grabbit.tests.Command2"
34
40
}
35
41
42
+ //Reply1 for testing
36
43
type Reply1 struct {
37
44
Data string
38
45
}
39
46
47
+ //SchemaName implementing gbus.Message
40
48
func (Reply1 ) SchemaName () string {
41
49
return "grabbit.tests.Reply1"
42
50
}
43
51
52
+ //Reply2 for testing
44
53
type Reply2 struct {
45
54
Data string
46
55
}
47
56
57
+ //SchemaName implementing gbus.Message
48
58
func (Reply2 ) SchemaName () string {
49
59
return "grabbit.tests.Reply2"
50
60
}
51
61
62
+ //Event1 for testing
52
63
type Event1 struct {
53
64
Data string
54
65
}
55
66
67
+ //SchemaName implementing gbus.Message
56
68
func (Event1 ) SchemaName () string {
57
69
return "grabbit.tests.Event1"
58
70
}
59
71
72
+ //Event2 for testing
60
73
type Event2 struct {
61
74
Data string
62
75
}
63
76
77
+ //SchemaName implementing gbus.Message
64
78
func (Event2 ) SchemaName () string {
65
79
return "grabbit.tests.Event2"
66
80
}
0 commit comments