func()

in sender/ConnectionPool.go [49:59]


func (p *AmqpConnectionPoolImpl) setupWrapper(pendingMessages []connectionPoolMessage) error {
	p.mutex.Lock()
	newWrapper, createErr := NewConnnectionWrapper(p.connection, pendingMessages)
	if createErr != nil {
		log.Print("Could not create a connection wrapper: ", createErr)
		return createErr
	}
	p.amqpWrapper = newWrapper
	p.mutex.Unlock()
	return nil
}