Skip to content

Commit 061f591

Browse files
Merge pull request rabbitmq#316 from SimonAlling/clarify-forever-channels
Clarify `forever` channel declarations
2 parents acec142 + bd2c06f commit 061f591

7 files changed

+7
-7
lines changed

go/publisher_confirms.go

+1-1
Original file line numberDiff line numberDiff line change
@@ -52,7 +52,7 @@ func main() {
5252
publish(ch, q.Name, "hello")
5353

5454
log.Printf(" [*] Waiting for messages. To exit press CTRL+C")
55-
forever := make(chan bool)
55+
var forever chan struct{}
5656
<-forever
5757
}
5858

go/receive.go

+1-1
Original file line numberDiff line numberDiff line change
@@ -42,7 +42,7 @@ func main() {
4242
)
4343
failOnError(err, "Failed to register a consumer")
4444

45-
forever := make(chan bool)
45+
var forever chan struct{}
4646

4747
go func() {
4848
for d := range msgs {

go/receive_logs.go

+1-1
Original file line numberDiff line numberDiff line change
@@ -61,7 +61,7 @@ func main() {
6161
)
6262
failOnError(err, "Failed to register a consumer")
6363

64-
forever := make(chan bool)
64+
var forever chan struct{}
6565

6666
go func() {
6767
for d := range msgs {

go/receive_logs_direct.go

+1-1
Original file line numberDiff line numberDiff line change
@@ -69,7 +69,7 @@ func main() {
6969
)
7070
failOnError(err, "Failed to register a consumer")
7171

72-
forever := make(chan bool)
72+
var forever chan struct{}
7373

7474
go func() {
7575
for d := range msgs {

go/receive_logs_topic.go

+1-1
Original file line numberDiff line numberDiff line change
@@ -69,7 +69,7 @@ func main() {
6969
)
7070
failOnError(err, "Failed to register a consumer")
7171

72-
forever := make(chan bool)
72+
var forever chan struct{}
7373

7474
go func() {
7575
for d := range msgs {

go/rpc_server.go

+1-1
Original file line numberDiff line numberDiff line change
@@ -60,7 +60,7 @@ func main() {
6060
)
6161
failOnError(err, "Failed to register a consumer")
6262

63-
forever := make(chan bool)
63+
var forever chan struct{}
6464

6565
go func() {
6666
for d := range msgs {

go/worker.go

+1-1
Original file line numberDiff line numberDiff line change
@@ -51,7 +51,7 @@ func main() {
5151
)
5252
failOnError(err, "Failed to register a consumer")
5353

54-
forever := make(chan bool)
54+
var forever chan struct{}
5555

5656
go func() {
5757
for d := range msgs {

0 commit comments

Comments
 (0)