parent
76aaeef758
commit
c2a12b880e
64
mq.go
64
mq.go
@ -37,40 +37,38 @@ func (s MQSession) Open() error {
|
|||||||
s.MQConnection.Close()
|
s.MQConnection.Close()
|
||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
/*
|
q, err = s.MQChannel.QueueDeclare(
|
||||||
q, err = s.MQChannel.QueueDeclare(
|
s.Queue, // name
|
||||||
s.Queue, // name
|
false, // durable
|
||||||
false, // durable
|
false, // delete when unused
|
||||||
false, // delete when unused
|
false, // exclusive
|
||||||
false, // exclusive
|
false, // no-wait
|
||||||
false, // no-wait
|
nil, // arguments
|
||||||
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
|
||||||
}
|
}
|
||||||
|
Loading…
Reference in New Issue
Block a user