Incorrect implement

[small-pineapple]

This is a race condition, only valid if Channel variable is volatile(Java keyword) or atomic

go-amqp-reconnect/rabbitmq/rabbitmq.go

Line 48 in e71660a

channel.Channel = ch

[jmvermeulen]

I don't get the issue, can you recommend a better approach?

[small-pineapple]

type Wrap struct {
	connection           atomic.Value
}

func (this *Wrap) Connect(addr string) error {
	conn, err := amqp.Dial(addr)
	if err != nil {
		return err
	}

	this.connection.Store(conn)

	go func() {
		<-ch.NotifyClose(make(chan *amqp.Error))
                if this.Connect(addr) != nil {
                     time.AfterFunc(time.Second*3, func() {
                         if this.Connect(addr) != nil {
                             time.AfterFunc(time.Second*10, func() {
                                 if this.Connect(addr) != nil {
                                     // report a error?
                                 }
                             })
                         }
                     })
                 }
	}()

	return nil
}

connection will be concurrently access by different goroutine, that need protect by synchronzation.
Also you can do endless reconect if you like, however that is meaningless. A several times connect to amqp failure basically means the machine or network gets serious problem.
Notice that the amqp's model of connection and channel is not suitable for golang, and the driver do nothing on this also. It is hardly to say there is a general wrap way