We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 5331585 commit 50a212fCopy full SHA for 50a212f
amqp.go
@@ -178,17 +178,6 @@ func New(url url.URL) *Session {
178
return &session
179
}
180
181
-// newConnection will close the current connection, cleaning
182
-// up the go-routines and connections. Then attempt to reconnect
183
-func (session *Session) newConnection(url url.URL) {
184
- err := session.Close()
185
- if err != nil {
186
- log.Errorln("Failed to close session:", err)
187
- }
188
- session.url = url
189
- go session.handleReconnect()
190
-}
191
-
192
// handleReconnect will wait for a connection error on
193
// notifyConnClose, and then continuously attempt to reconnect.
194
func (session *Session) handleReconnect() {
0 commit comments