This commit is contained in:
shoopea 2019-06-28 14:23:46 +08:00
parent ddf0207ae3
commit 81f17b3ad3

2
mq.go
View File

@ -41,7 +41,7 @@ func (s MQSession) Open() error {
nil, // arguments
)
s.MQQueue = q
s.MQQueue = &q
logOnError(err, "Open : Failed to declare queue")
if err != nil {
s.MQChannel.Close()