ironmq_test.go

package taskq_test

import (
	"testing"

	iron_config "github.com/iron-io/iron_go3/config"

	"github.com/vmihailenco/taskq/v3"
	"github.com/vmihailenco/taskq/v3/ironmq"
)

func ironmqFactory() taskq.Factory {
	settings := iron_config.Config("iron_mq")
	return ironmq.NewFactory(&settings)
}

func TestIronmqConsumer(t *testing.T) {
	testConsumer(t, ironmqFactory(), &taskq.QueueOptions{
		Name: queueName("ironmq-consumer"),
	})
}

func TestIronmqUnknownTask(t *testing.T) {
	testUnknownTask(t, ironmqFactory(), &taskq.QueueOptions{
		Name: queueName("ironmq-unknown-task"),
	})
}

func TestIronmqFallback(t *testing.T) {
	testFallback(t, ironmqFactory(), &taskq.QueueOptions{
		Name: queueName("ironmq-fallback"),
	})
}

func TestIronmqDelay(t *testing.T) {
	testDelay(t, ironmqFactory(), &taskq.QueueOptions{
		Name: queueName("ironmq-delay"),
	})
}

func TestIronmqRetry(t *testing.T) {
	testRetry(t, ironmqFactory(), &taskq.QueueOptions{
		Name: queueName("ironmq-retry"),
	})
}

func TestIronmqNamedMessage(t *testing.T) {
	testNamedMessage(t, ironmqFactory(), &taskq.QueueOptions{
		Name: queueName("ironmq-named-message"),
	})
}

func TestIronmqCallOnce(t *testing.T) {
	testCallOnce(t, ironmqFactory(), &taskq.QueueOptions{
		Name: queueName("ironmq-call-once"),
	})
}

func TestIronmqLen(t *testing.T) {
	testLen(t, ironmqFactory(), &taskq.QueueOptions{
		Name: queueName("ironmq-len"),
	})
}

func TestIronmqRateLimit(t *testing.T) {
	testRateLimit(t, ironmqFactory(), &taskq.QueueOptions{
		Name: queueName("ironmq-rate-limit"),
	})
}

func TestIronmqErrorDelay(t *testing.T) {
	testErrorDelay(t, ironmqFactory(), &taskq.QueueOptions{
		Name: queueName("ironmq-delayer"),
	})
}

func TestIronmqWorkerLimit(t *testing.T) {
	testWorkerLimit(t, ironmqFactory(), &taskq.QueueOptions{
		Name: queueName("ironmq-worker-limit"),
	})
}

func TestIronmqInvalidCredentials(t *testing.T) {
	settings := &iron_config.Settings{
		ProjectId: "123",
	}
	factory := ironmq.NewFactory(settings)
	testInvalidCredentials(t, factory, &taskq.QueueOptions{
		Name: queueName("ironmq-invalid-credentials"),
	})
}