8000 Merge pull request #94 from hnakamur/modify_go_examples · syk-coder/rabbitmq-tutorials@31fe04e · GitHub
[go: up one dir, main page]
Skip to content

Commit 31fe04e

Browse files
michaelklishinmichaelklishin
authored
Merge pull request rabbitmq#94 from hnakamur/modify_go_examples
Modify go examples
2 parents 5d8200d + b877dbd commit 31fe04e

12 files changed

+5
-27
lines changed

‎go/emit_log.go

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,6 @@
11
package main
22

33
import (
4-
"fmt"
54
"log"
65
"os"
76
"strings"
@@ -12,7 +11,6 @@ import (
1211
func failOnError(err error, msg string) {
1312
if err != nil {
1413
log.Fatalf("%s: %s", msg, err)
15-
panic(fmt.Sprintf("%s: %s", msg, err))
1614
}
1715
}
1816

‎go/emit_log_direct.go

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,6 @@
11
package main
22

33
import (
4-
"fmt"
54
"log"
65
"os"
76
"strings"
@@ -12,7 +11,6 @@ import (
1211
func failOnError(err error, msg string) {
1312
if err != nil {
1413
log.Fatalf("%s: %s", msg, err)
15-
panic(fmt.Sprintf("%s: %s", msg, err))
1614
}
1715
}
1816

‎go/emit_log_topic.go

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,6 @@
11
package main
22

33
import (
4-
"fmt"
54
"log"
65
"os"
76
"strings"

‎go/new_task.go

Lines changed: 3 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,6 @@
11
package main
22

33
import (
4-
"fmt"
54
"log"
65
"os"
76
"strings"
@@ -12,7 +11,6 @@ import (
1211
func failOnError(err error, msg string) {
1312
if err != nil {
1413
log.Fatalf("%s: %s", msg, err)
15-
panic(fmt.Sprintf("%s: %s", msg, err))
1614
}
1715
}
1816

@@ -37,9 +35,9 @@ func main() {
3735

3836
body := bodyFrom(os.Args)
3937
err = ch.Publish(
40-
"", // exchange
41-
q.Name, // routing key
42-
false, // mandatory
38+
"", // exchange
39+
q.Name, // routing key
40+
false, // mandatory
4341
false,
4442
amqp.Publishing{
4543
DeliveryMode: amqp.Persistent,

‎go/receive.go

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,6 @@
11
package main
22

33
import (
4-
"fmt"
54
"log"
65

76
"github.com/streadway/amqp"
@@ -10,7 +9,6 @@ import (
109
func failOnError(err error, msg string) {
1110
if err != nil {
1211
log.Fatalf("%s: %s", msg, err)
13-
panic(fmt.Sprintf("%s: %s", msg, err))
1412
}
1513
}
1614

‎go/receive_logs.go

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,6 @@
11
package main
22

33
import (
4-
"fmt"
54
"log"
65

76
"github.com/streadway/amqp"
@@ -10,7 +9,6 @@ import (
109
func failOnError(err error, msg string) {
1110
if err != nil {
1211
log.Fatalf("%s: %s", msg, err)
13-
panic(fmt.Sprintf("%s: %s", msg, err))
1412
}
1513
}
1614

‎go/receive_logs_direct.go

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,6 @@
11
package main
22

33
import (
4-
"fmt"
54
"log"
65
"os"
76

@@ -11,7 +10,6 @@ import (
1110
func failOnError(err error, msg string) {
1211
if err != nil {
1312
log.Fatalf("%s: %s", msg, err)
14-
panic(fmt.Sprintf("%s: %s", msg, err))
1513
}
1614
}
1715

‎go/receive_logs_topic.go

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,6 @@
11
package main
22

33
import (
4-
"fmt"
54
"log"
65
"os"
76

@@ -11,7 +10,6 @@ import (
1110
func failOnError(err error, msg string) {
1211
if err != nil {
1312
log.Fatalf("%s: %s", msg, err)
14-
panic(fmt.Sprintf("%s: %s", msg, err))
1513
}
1614
}
1715

‎go/rpc_client.go

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,6 @@
11
package main
22

33
import (
4-
"fmt"
54
"log"
65
"math/rand"
76
"os"
@@ -15,7 +14,6 @@ import (
1514
func failOnError(err error, msg string) {
1615
if err != nil {
1716
log.Fatalf("%s: %s", msg, err)
18-
panic(fmt.Sprintf("%s: %s", msg, err))
1917
}
2018
}
2119

‎go/rpc_server.go

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,6 @@
11
package main
22

33
import (
4-
"fmt"
54
"log"
65
"strconv"
76

@@ -11,7 +10,6 @@ import (
1110
func failOnError(err error, msg string) {
1211
if err != nil {
1312
log.Fatalf("%s: %s", msg, err)
14-
panic(fmt.Sprintf("%s: %s", msg, err))
1513
}
1614
}
1715

‎go/send.go

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,6 @@
11
package main
22

33
import (
4-
"fmt"
54
"log"
65

76
"github.com/streadway/amqp"
@@ -10,7 +9,6 @@ import (
109
func failOnError(err error, msg string) {
1110
if err != nil {
1211
log.Fatalf("%s: %s", msg, err)
13-
panic(fmt.Sprintf("%s: %s", msg, err))
1412
}
1513
}
1614

‎go/worker.go

Lines changed: 2 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -2,16 +2,15 @@ package main
22

33
import (
44
"bytes"
5-
"fmt"
6-
"github.com/streadway/amqp"
75
"log"
86
"time"
7+
8+
"github.com/streadway/amqp"
99
)
1010

1111
func failOnError(err error, msg string) {
1212
if err != nil {
1313
log.Fatalf("%s: %s", msg, err)
14-
panic(fmt.Sprintf("%s: %s", msg, err))
1514
}
1615
}
1716

0 commit comments

Comments
 (0)
0