Merge pull request #138 from alraujo/fix-indentation-unnecessary-inst…

…ruction Fix indentation and remove unnecessary instructions
rabbitmq · Dec 1, 2022 · bab848e · bab848e
2 parents ccc85bc + 19d1276
commit bab848e
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 8 deletions.
diff --git a/channel.go b/channel.go
@@ -112,10 +112,7 @@ func (ch *Channel) shutdown(e *Error) {
 			for _, c := range ch.closes {
 				c <- e
 			}
-		}
-
-		// Notify RPC if we're selecting
-		if e != nil {
+			// Notify RPC if we're selecting
 			ch.errors <- e
 		}
 

diff --git a/connection.go b/connection.go
@@ -822,8 +822,8 @@ func (c *Connection) openTune(config Config, auth Authentication) error {
 	config.Properties["capabilities"] = Table{
 		"connection.blocked":     true,
 		"consumer_cancel_notify": true,
-		"basic.nack": true,
-		"publisher_confirms": true,
+		"basic.nack":             true,
+		"publisher_confirms":     true,
 	}
 
 	ok := &connectionStartOk{

diff --git a/uri.go b/uri.go
@@ -172,8 +172,6 @@ func (uri URI) String() string {
 		}
 	}
 
-	authority.Host = net.JoinHostPort(uri.Host, strconv.Itoa(uri.Port))
-
 	if defaultPort, found := schemePorts[uri.Scheme]; !found || defaultPort != uri.Port {
 		authority.Host = net.JoinHostPort(uri.Host, strconv.Itoa(uri.Port))
 	} else {