This commit is contained in:
shoopea 2019-06-28 15:23:52 +08:00
parent b98069f4ba
commit c9e9dc397b

64
mq.go
View File

@ -37,38 +37,40 @@ func (s MQSession) Open() error {
s.MQConnection.Close() s.MQConnection.Close()
return err return err
} }
q, err = s.MQChannel.QueueDeclare( /*
s.Queue, // name q, err = s.MQChannel.QueueDeclare(
false, // durable s.Queue, // name
false, // delete when unused false, // durable
false, // exclusive false, // delete when unused
false, // no-wait false, // exclusive
nil, // arguments false, // no-wait
nil, // arguments
) )
s.MQQueue = &q s.MQQueue = &q
logOnError(err, "Open : Failed to declare queue") logOnError(err, "Open : Failed to declare queue")
if err != nil { if err != nil {
s.MQChannel.Close() s.MQChannel.Close()
s.MQConnection.Close() s.MQConnection.Close()
return err return err
} }
s.MQDelivery, err = s.MQChannel.Consume( s.MQDelivery, err = s.MQChannel.Consume(
s.MQQueue.Name, // queue s.MQQueue.Name, // queue
"", // consumer "", // consumer
true, // auto-ack true, // auto-ack
false, // exclusive false, // exclusive
false, // no-local false, // no-local
false, // no-wait false, // no-wait
nil, // args nil, // args
) )
logOnError(err, "Open : Failed to register a consumer") logOnError(err, "Open : Failed to register a consumer")
if err != nil { if err != nil {
s.MQChannel.Close() s.MQChannel.Close()
s.MQConnection.Close() s.MQConnection.Close()
return err return err
} }
//log.Printf("Open : MQ Connected to amqp://" + s.User + ":" + s.Password + "@" + s.Host + "/" + s.Path) //log.Printf("Open : MQ Connected to amqp://" + s.User + ":" + s.Password + "@" + s.Host + "/" + s.Path)
*/
s.isConnected = true s.isConnected = true
return nil return nil
} }