Codebase list golang-github-streadway-amqp / b6433c24-0281-4988-9bc2-a0fe68ce7563/upstream delivery_test.go
b6433c24-0281-4988-9bc2-a0fe68ce7563/upstream

Tree @b6433c24-0281-4988-9bc2-a0fe68ce7563/upstream (Download .tar.gz)

delivery_test.go @b6433c24-0281-4988-9bc2-a0fe68ce7563/upstreamraw · history · blame

package amqp

import "testing"

func shouldNotPanic(t *testing.T) {
	if err := recover(); err != nil {
		t.Fatalf("should not panic, got: %s", err)
	}
}

// A closed delivery chan could produce zero value.  Ack/Nack/Reject on these
// deliveries can produce a nil pointer panic.  Instead return an error when
// the method can never be successful.
func TestAckZeroValueAcknowledgerDoesNotPanic(t *testing.T) {
	defer shouldNotPanic(t)
	if err := (Delivery{}).Ack(false); err == nil {
		t.Errorf("expected Delivery{}.Ack to error")
	}
}

func TestNackZeroValueAcknowledgerDoesNotPanic(t *testing.T) {
	defer shouldNotPanic(t)
	if err := (Delivery{}).Nack(false, false); err == nil {
		t.Errorf("expected Delivery{}.Ack to error")
	}
}

func TestRejectZeroValueAcknowledgerDoesNotPanic(t *testing.T) {
	defer shouldNotPanic(t)
	if err := (Delivery{}).Reject(false); err == nil {
		t.Errorf("expected Delivery{}.Ack to error")
	}
}