MCPcopy Create free account
hub / github.com/LockGit/gochat / Test_TestQueue

Function Test_TestQueue

task/queue_test.go:14–29  ·  view source on GitHub ↗
(t *testing.T)

Source from the content-addressed store, hash-verified

12)
13
14func Test_TestQueue(t *testing.T) {
15 redisOpt := tools.RedisOption{
16 Address: config.Conf.Common.CommonRedis.RedisAddress,
17 Password: config.Conf.Common.CommonRedis.RedisPassword,
18 Db: config.Conf.Common.CommonRedis.Db,
19 }
20 RedisClient = tools.GetRedisInstance(redisOpt)
21 result, err := RedisClient.BRPop(time.Second*10, config.QueueName).Result()
22 if err != nil {
23 t.Fail()
24 }
25 t.Log(result, len(result))
26 if len(result) >= 1 {
27 t.Log(result[1])
28 }
29}

Callers

nothing calls this directly

Calls 1

GetRedisInstanceFunction · 0.92

Tested by

no test coverage detected