diff --git a/mq.go b/mq.go index b4d1264..15b2b8e 100644 --- a/mq.go +++ b/mq.go @@ -12,7 +12,7 @@ func (s MQSession) Open() error { err error conn *amqp.Connection ch *amqp.Channel - //q amqp.Queue + q amqp.Queue ) if s.isConnected { return errors.New("Session is already connected.")