package main

import (
	"github.com/streadway/amqp"
)

func (c *MQClient) Open() error {
	conn, err := amqp.Dial("amqp://" + c.User + ":" + c.Password + "@" + c.Host + "/" + c.Path)
	c.Connection = conn
	return null
}