bootstrap_test.go

package dispatcher

import (
	"errors"
	"github.com/streadway/amqp"
	"os"
	"testing"
)

func Test_bootstrapExchanges1(t *testing.T) {

	con, _ := amqp.Dial(os.Getenv("DISPATCHER_AMQP_CON"))
	defer con.Close()

	ch, _ := con.Channel()
	defer ch.Close()

	err := bootstrap(ch, "test_exchange_1", []Queue{
		{"queue_1", []string{"key_1"}},
	})
	if err != nil {
		t.Error(err)
		return
	}

	ch.ExchangeDelete("test_exchange_1", false, false)

}

func Test_bootstrapExchanges2(t *testing.T) {

	con, _ := amqp.Dial(os.Getenv("DISPATCHER_AMQP_CON"))
	defer con.Close()

	ch, _ := con.Channel()
	defer ch.Close()

	err := bootstrap(ch, "", []Queue{
		{"queue_1", []string{"key_1"}},
	})
	if err == nil {
		t.Error(errors.New("No error returned, but exchange was empty"))
		return
	}

	ch.ExchangeDelete("test_exchange_1", false, false)

}

func Test_bootstrapExchanges3(t *testing.T) {

	con, _ := amqp.Dial(os.Getenv("DISPATCHER_AMQP_CON"))
	defer con.Close()

	ch, _ := con.Channel()
	defer ch.Close()

	err := bootstrap(ch, "test_exchange_1", []Queue{
		{"", []string{"key_1"}},
	})
	if err == nil {
		t.Error(errors.New("No error returned, but queue was empty"))
		return
	}

	ch.ExchangeDelete("test_exchange_1", false, false)

}

func Test_bootstrapExchanges4(t *testing.T) {

	con, _ := amqp.Dial(os.Getenv("DISPATCHER_AMQP_CON"))
	defer con.Close()

	ch, _ := con.Channel()
	defer ch.Close()

	err := bootstrap(ch, "test_exchange_1", []Queue{
		{"queue_1", []string{""}},
	})
	if err == nil {
		t.Error(errors.New("No error returned, but binding key was empty"))
		return
	}

	ch.ExchangeDelete("test_exchange_1", false, false)

}