@@ -30,7 +30,7 @@ func Example_direct_exchange() {
30
30
queue .WithWorker (w1 ),
31
31
)
32
32
if err != nil {
33
- w1 .opts .logger .Error (err )
33
+ w1 .opts .logger .Fatal (err )
34
34
}
35
35
q1 .Start ()
36
36
@@ -50,7 +50,7 @@ func Example_direct_exchange() {
50
50
queue .WithWorker (w2 ),
51
51
)
52
52
if err != nil {
53
- w2 .opts .logger .Error (err )
53
+ w2 .opts .logger .Fatal (err )
54
54
}
55
55
q2 .Start ()
56
56
@@ -64,14 +64,22 @@ func Example_direct_exchange() {
64
64
queue .WithWorker (w ),
65
65
)
66
66
if err != nil {
67
- w .opts .logger .Error (err )
67
+ w .opts .logger .Fatal (err )
68
68
}
69
69
70
70
time .Sleep (200 * time .Millisecond )
71
- q .Queue (m )
72
- q .Queue (m )
73
- q .Queue (m )
74
- q .Queue (m )
71
+ if err := q .Queue (m ); err != nil {
72
+ w .opts .logger .Fatal (err )
73
+ }
74
+ if err := q .Queue (m ); err != nil {
75
+ w .opts .logger .Fatal (err )
76
+ }
77
+ if err := q .Queue (m ); err != nil {
78
+ w .opts .logger .Fatal (err )
79
+ }
80
+ if err := q .Queue (m ); err != nil {
81
+ w .opts .logger .Fatal (err )
82
+ }
75
83
time .Sleep (200 * time .Millisecond )
76
84
q .Release ()
77
85
q1 .Release ()
@@ -103,7 +111,7 @@ func Example_fanout_exchange() {
103
111
queue .WithWorker (w1 ),
104
112
)
105
113
if err != nil {
106
- w1 .opts .logger .Error (err )
114
+ w1 .opts .logger .Fatal (err )
107
115
}
108
116
q1 .Start ()
109
117
@@ -121,7 +129,7 @@ func Example_fanout_exchange() {
121
129
queue .WithWorker (w2 ),
122
130
)
123
131
if err != nil {
124
- w2 .opts .logger .Error (err )
132
+ w2 .opts .logger .Fatal (err )
125
133
}
126
134
q2 .Start ()
127
135
@@ -134,11 +142,13 @@ func Example_fanout_exchange() {
134
142
queue .WithWorker (w ),
135
143
)
136
144
if err != nil {
137
- w .opts .logger .Error (err )
145
+ w .opts .logger .Fatal (err )
138
146
}
139
147
140
148
time .Sleep (200 * time .Millisecond )
141
- q .Queue (m )
149
+ if err := q .Queue (m ); err != nil {
150
+ w .opts .logger .Fatal (err )
151
+ }
142
152
time .Sleep (200 * time .Millisecond )
143
153
q .Release ()
144
154
q1 .Release ()
0 commit comments