1
0
Fork 0

Shorten conditions

This commit is contained in:
Gregory Eremin 2014-09-24 15:35:55 +04:00
parent 852661578c
commit 32121799b5
1 changed files with 2 additions and 5 deletions

View File

@ -71,8 +71,7 @@ func main() {
return
}
ok := bsq.Publish(msg)
if ok {
if ok := bsq.Publish(msg); ok {
fmt.Printf("Message successfully published to queue %q\n", msg.Queue)
} else {
fmt.Printf("Failed to publish message to queue %q\n", msg.Queue)
@ -83,9 +82,7 @@ func main() {
Name: "sub",
Usage: "Subscribe for message from queue",
Action: func(c *cli.Context) {
msg := bsq.Subscribe(c.Args()...)
if msg != nil {
if msg := bsq.Subscribe(c.Args()...); msg != nil {
fmt.Println(string(msg.Body))
} else {
fmt.Printf("Failed to recieve message from queues %s\n", strings.Join(c.Args(), ", "))