Revert "test"

This reverts commit f5a5d34620.
This commit is contained in:
shoopea 2019-06-28 15:56:11 +08:00
parent 3cd1e6f94a
commit 58153cf3d4

2
mq.go
View File

@ -12,7 +12,7 @@ func (s MQSession) Open() error {
err error err error
conn *amqp.Connection conn *amqp.Connection
ch *amqp.Channel ch *amqp.Channel
q amqp.Queue q *amqp.Queue
) )
if s.isConnected { if s.isConnected {
return errors.New("Session is already connected.") return errors.New("Session is already connected.")