Function TestEnqueueWithAsynqClientEnqueueError

queue_test.go:146–177

(t *testing.T)

}

func TestEnqueueWithAsynqClientEnqueueError(t *testing.T) {
	conf := &config.Configuration{
		Redis: config.RedisConfig{
			Dns: testRedisAddr(),
		},
		Queue: config.QueueConfig{
			WebhookQueue:   "webhook_queue",
			NumberOfQueues: 1,
		},
	}

	client := asynq.NewClient(asynq.RedisClientOpt{Addr: testRedisAddr()})
	inspector := asynq.NewInspector(asynq.RedisClientOpt{Addr: testRedisAddr()})

	q := NewQueue(conf, client)
	q.Inspector = inspector

	transaction := getTransactionMock(100, false)

	_, err := json.Marshal(transaction)
	assert.NoError(t, err)

	err = q.Enqueue(context.Background(), &transaction)
	assert.NoError(t, err)

	task, err := inspector.GetTaskInfo(conf.Queue.WebhookQueue, "tx_1235")
	if err != nil {
		return
	}

	assert.Equal(t, "tx_123", task.ID)
}