Add support for no user:pass in amqp url

v3/integrations/nramqp/nramqp.go

@@ -35,14 +35,19 @@ func createProducerSegment(exchange, key string) *newrelic.MessageProducerSegmen
 }
 
 func GetHostAndPortFromURL(url string) (string, string) {
-	// url is of format amqp://user:password@host:port
-	// extract host from url after "@" symbol
-	parts := strings.Split(url, "@")
-	if len(parts) != 2 {
-		return "", ""
+	// url is of format amqp://user:password@host:port or amqp://host:port
+	var hostPortPart string
+
+	// extract the part after "@" symbol, if present
+	if parts := strings.Split(url, "@"); len(parts) == 2 {
+		hostPortPart = parts[1]
+	} else {
+		// assume the whole url after "amqp://" is the host:port part
+		hostPortPart = strings.TrimPrefix(url, "amqp://")
 	}
-	strippedURL := strings.Split(parts[1], ":")
 
+	// split the host:port part
+	strippedURL := strings.Split(hostPortPart, ":")
 	if len(strippedURL) != 2 {
 		return "", ""
 	}

v3/integrations/nramqp/nramqp_test.go

@@ -77,13 +77,6 @@ func TestCreateProducerSegment(t *testing.T) {
 
 }
 
-func TestPublishWithContext(t *testing.T) {
-	app := createTestApp()
-	txn := app.StartTransaction("test")
-	defer txn.End()
-
-}
-
 func TestHostAndPortParsing(t *testing.T) {
 	app := createTestApp()
 	txn := app.StartTransaction("test")
@@ -101,6 +94,17 @@ func TestHostAndPortParsing(t *testing.T) {
 			"host",
 			"port",
 		},
+		{
+			"amqp://host:port",
+			"host",
+			"port",
+		},
+		{
+			"aaa://host:port",
+			"",
+			"",
+		},
+
 		{
 			"amqp://user:password@host",
 			"",