Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- package main
- import (
- "encoding/json"
- "fmt"
- "log"
- "os"
- "github.com/ogier/pflag"
- "github.com/streadway/amqp"
- )
- func fatal(err error) {
- if err != nil {
- log.Print(err)
- os.Exit(-1)
- }
- }
- func main() {
- address := pflag.String("address", "127.0.0.1", "rabbitmq address")
- port := pflag.Int("port", 5672, "rabbitmq port")
- user := pflag.StringP("user", "u", "guest", "rabbitmq user")
- password := pflag.StringP("password", "p", "guest", "rabbitmq password")
- queue := pflag.StringP("queue", "q", "", "rabbitmq queue")
- pflag.Parse()
- conn, err := amqp.Dial(fmt.Sprintf("amqp://%s:%s@%s:%d/", *user, *password, *address, *port))
- fatal(err)
- channel, err := conn.Channel()
- fatal(err)
- q, err := channel.QueueInspect(*queue)
- fatal(err)
- data, err := json.MarshalIndent(q, "", "\t")
- fatal(err)
- fmt.Println(string(data))
- }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement