mq

var Cmd = &cobra.Command{
	Use:   "mq",
	Short: "mq admin",
	RunE: func(cmd *cobra.Command, args []string) error {
		var bc *clap.YamlConfig
		bc, err := clap.LoadConfigFile(cfgFile)
		if err != nil {
			return err
		}
		admin := rabbitmq.MustNewAdmin(bc.Conn)
		for _, name := range bc.Names {
			if err := createQueue(bc, admin, name); err != nil {
				log.Error(err)
			}
		}
		return nil
	},
}