8000 Merge pull request #32 from umisama/master · web2solutions/rabbitmq-tutorials@5c0bfb1 · GitHub
[go: up one dir, main page]
Skip to content

Commit 5c0bfb1

Browse files
michaelklishinmichaelklishin
committed
Merge pull request rabbitmq#32 from umisama/master
Optimization for golang
2 parents 27df5ef + 479c04c commit 5c0bfb1

File tree

5 files changed

+11
-30
lines changed

5 files changed

+11
-30
lines changed

‎go/receive.go

Lines changed: 2 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -38,20 +38,16 @@ func main() {
3838
failOnError(err, "Failed to register a consumer")
3939

4040
done := make(chan bool)
41-
var d amqp.Delivery
4241

4342
go func() {
44-
for d = range msgs {
43+
for d := range msgs {
4544
log.Printf("Received a message: %s", d.Body)
4645
done <- true
4746
}
4847
}()
4948

5049
log.Printf(" [*] Waiting for messages. To exit press CTRL+C")
51-
select {
52-
case <-done:
53-
break
54-
}
50+
<-done
5551
log.Printf("Done")
5652

5753
os.Exit(0)

‎go/receive_logs.go

Lines changed: 2 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -43,20 +43,16 @@ func main() {
4343
msgs, err := ch.Consume(q.Name, "", true, false, false, false, nil)
4444

4545
done := make(chan bool)
46-
var d amqp.Delivery
4746

4847
go func() {
49-
for d = range msgs {
48+
for d := range msgs {
5049
log.Printf(" [x] %s", d.Body)
5150
done <- true
5251
}
5352
}()
5453

5554
log.Printf(" [*] Waiting for logs. To exit press CTRL+C")
56-
select {
57-
case <-done:
58-
break
59-
}
55+
<-done
6056
log.Printf("Done")
6157

6258
os.Exit(0)

‎go/receive_logs_direct.go

Lines changed: 3 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -43,8 +43,7 @@ func main() {
4343
)
4444
failOnError(err, "Failed to declare a queue")
4545

46-
var s string
47-
for _, s = range os.Args {
46+
for _, s := range os.Args {
4847
log.Printf("Binding queue %s to exchange %s with routing key %s", q.Name, "logs_direct", s)
4948
err = ch.QueueBind(
5049
q.Name, // queue name
@@ -58,20 +57,16 @@ func main() {
5857
msgs, err := ch.Consume(q.Name, "", true, false, false, false, nil)
5958

6059
done := make(chan bool)
61-
var d amqp.Delivery
6260

6361
go func() {
64-
for d = range msgs {
62+
for d := range msgs {
6563
log.Printf(" [x] %s", d.Body)
6664
done <- true
6765
}
6866
}()
6967

7068
log.Printf(" [*] Waiting for logs. To exit press CTRL+C")
71-
select {
72-
case <-done:
73-
break
74-
}
69+
<-done
7570
log.Printf("Done")
7671

7772
os.Exit(0)

‎go/receive_logs_topic.go

Lines changed: 2 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -43,8 +43,7 @@ func main() {
4343
)
4444
failOnError(err, "Failed to declare a queue")
4545

46-
var s string
47-
for _, s = range os.Args {
46+
for _, s := range os.Args {
4847
log.Printf("Binding queue %s to exchange %s with routing key %s", q.Name, "logs_topic", s)
4948
err = ch.QueueBind(
5049
q.Name, // queue name
@@ -58,10 +57,9 @@ func main() {
5857
msgs, err := ch.Consume(q.Name, "", true, false, false, false, nil)
5958

6059
done := make(chan bool)
61-
var d amqp.Delivery
6260

6361
go func() {
64-
for d = range msgs {
62+
for d := range msgs {
6563
log.Printf(" [x] %s", d.Body)
6664
done <- true
6765
}

‎go/worker.go

Lines changed: 2 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -40,21 +40,17 @@ func main() {
4040
failOnError(err, "Failed to register a consumer")
4141

4242
done := make(chan bool)
43-
var d amqp.Delivery
4443

4544
go func() {
46-
for d = range msgs {
45+
for d := range msgs {
4746
log.Printf("Received a message: %s", d.Body)
4847
d.Ack(false)
4948
done <- true
5049
}
5150
}()
5251

5352
log.Printf(" [*] Waiting for messages. To exit press CTRL+C")
54-
select {
55-
case <-done:
56-
break
57-
}
53+
<-done
5854
log.Printf("Done")
5955

6056
os.Exit(0)

0 commit comments

Comments
 (0)
0