@@ -30,7 +30,7 @@ func Example_direct_exchange() {
3030 queue .WithWorker (w1 ),
3131 )
3232 if err != nil {
33- w1 .opts .logger .Error (err )
33+ w1 .opts .logger .Fatal (err )
3434 }
3535 q1 .Start ()
3636
@@ -50,7 +50,7 @@ func Example_direct_exchange() {
5050 queue .WithWorker (w2 ),
5151 )
5252 if err != nil {
53- w2 .opts .logger .Error (err )
53+ w2 .opts .logger .Fatal (err )
5454 }
5555 q2 .Start ()
5656
@@ -64,14 +64,22 @@ func Example_direct_exchange() {
6464 queue .WithWorker (w ),
6565 )
6666 if err != nil {
67- w .opts .logger .Error (err )
67+ w .opts .logger .Fatal (err )
6868 }
6969
7070 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+ }
7583 time .Sleep (200 * time .Millisecond )
7684 q .Release ()
7785 q1 .Release ()
@@ -103,7 +111,7 @@ func Example_fanout_exchange() {
103111 queue .WithWorker (w1 ),
104112 )
105113 if err != nil {
106- w1 .opts .logger .Error (err )
114+ w1 .opts .logger .Fatal (err )
107115 }
108116 q1 .Start ()
109117
@@ -121,7 +129,7 @@ func Example_fanout_exchange() {
121129 queue .WithWorker (w2 ),
122130 )
123131 if err != nil {
124- w2 .opts .logger .Error (err )
132+ w2 .opts .logger .Fatal (err )
125133 }
126134 q2 .Start ()
127135
@@ -134,11 +142,13 @@ func Example_fanout_exchange() {
134142 queue .WithWorker (w ),
135143 )
136144 if err != nil {
137- w .opts .logger .Error (err )
145+ w .opts .logger .Fatal (err )
138146 }
139147
140148 time .Sleep (200 * time .Millisecond )
141- q .Queue (m )
149+ if err := q .Queue (m ); err != nil {
150+ w .opts .logger .Fatal (err )
151+ }
142152 time .Sleep (200 * time .Millisecond )
143153 q .Release ()
144154 q1 .Release ()
0 commit comments