Function TestPublisher_serve_errors

publisher_test.go:209–255

(t *testing.T)

}

func TestPublisher_serve_errors(t *testing.T) {
	var (
		runSync          = make(chan bool)
		testErrChan      chan *amqp.Error
		testPublishErr   = errors.New("pub err")
		_deletePublisher bool
	)

	p := newTestPublisher()
	cli := &mqDeleterTest{
		_deletePublisher: func(*Publisher) {
			_deletePublisher = true
		},
	}

	ch1 := &mqChannelTest{
		_Close: func() error {
			return nil
		},
		_NotifyClose: func(errChan chan *amqp.Error) chan *amqp.Error {
			testErrChan = errChan
			return errChan
		},
		_Publish: func(string, string, bool, bool, amqp.Publishing) error {
			return testPublishErr
		},
	}

	go func() {
		<-runSync
		p.serve(cli, ch1)
		runSync <- true
	}()

	runSync <- true
	_, err := p.Write([]byte("test1"))
	close(testErrChan) // immitate amqp.Channel close
	<-runSync

	if err != testPublishErr {
		t.Error("should return correct error")
	}

	if _deletePublisher {
		t.Error("on errors should not delete publisher")
	}
}

func TestNewPublisher(t *testing.T) {
	var called bool