func()

in sender/ConnectionWrapper.go [117:134]

• 16 lines of code
• 3 McCabe index (conditional complexity)

func (w *ConnectionWrapperImpl) Finish() []connectionPoolMessage {
	closeErr := w.amqpChannel.Close()
	if closeErr != nil {
		log.Print("ERROR ConnectionWrapper.Finish could not close broker channel: ", closeErr)
	}

	log.Print("DEBUG ConnectionWrapper.Finish waiting for confirm receive routine to terminate")
	w.terminationChannel <- true
	w.terminationWaiter.Wait()
	log.Printf("DEBUG ConnectionWrapper.Finish done.")
	pendingMessages := make([]connectionPoolMessage, len(w.awaitingConfirmation))
	i := 0
	for _, msg := range w.awaitingConfirmation {
		pendingMessages[i] = msg
	}

	return pendingMessages
}