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
}