mirror of
https://git.rwth-aachen.de/acs/public/villas/web-backend-go/
synced 2025-03-30 00:00:12 +01:00
Re-activate AMQP related parts of healthz test
This commit is contained in:
parent
d7586a91cf
commit
c1c28e7e19
1 changed files with 6 additions and 6 deletions
|
@ -22,6 +22,7 @@
|
||||||
package healthz
|
package healthz
|
||||||
|
|
||||||
import (
|
import (
|
||||||
|
"git.rwth-aachen.de/acs/public/villas/web-backend-go/amqp"
|
||||||
"git.rwth-aachen.de/acs/public/villas/web-backend-go/configuration"
|
"git.rwth-aachen.de/acs/public/villas/web-backend-go/configuration"
|
||||||
"git.rwth-aachen.de/acs/public/villas/web-backend-go/database"
|
"git.rwth-aachen.de/acs/public/villas/web-backend-go/database"
|
||||||
"git.rwth-aachen.de/acs/public/villas/web-backend-go/helper"
|
"git.rwth-aachen.de/acs/public/villas/web-backend-go/helper"
|
||||||
|
@ -77,12 +78,11 @@ func TestHealthz(t *testing.T) {
|
||||||
amqpURI := "amqp://" + user + ":" + pass + "@" + host
|
amqpURI := "amqp://" + user + ":" + pass + "@" + host
|
||||||
log.Println("AMQP URI is", amqpURI)
|
log.Println("AMQP URI is", amqpURI)
|
||||||
|
|
||||||
//TODO find a solution how testing can work here if receive loop of AMQP channel never exits
|
err = amqp.ConnectAMQP(amqpURI)
|
||||||
//err = amqp.ConnectAMQP(amqpURI)
|
assert.NoError(t, err)
|
||||||
//assert.NoError(t, err)
|
|
||||||
|
|
||||||
// test healthz endpoint for connected DB and AMQP client
|
// test healthz endpoint for connected DB and AMQP client
|
||||||
//code, resp, err = helper.TestEndpoint(router, "", "healthz", http.MethodGet, nil)
|
code, resp, err = helper.TestEndpoint(router, "", "healthz", http.MethodGet, nil)
|
||||||
//assert.NoError(t, err)
|
assert.NoError(t, err)
|
||||||
//assert.Equalf(t, 200, code, "Response body: \n%v\n", resp)
|
assert.Equalf(t, 200, code, "Response body: \n%v\n", resp)
|
||||||
}
|
}
|
||||||
|
|
Loading…
Add table
Reference in a new issue