diff --git a/main.go b/main.go
index 436ef85..cfd611b 100644
--- a/main.go
+++ b/main.go
@@ -172,7 +172,7 @@ func main() {
 				},
 			},
 		},
-		DSN: fmt.Sprintf("amqp://%s:%s@%s/", mqUser, mqPass, mqHost),
+		DSN: fmt.Sprintf("amqp://%s:%s@%s", mqUser, mqPass, mqHost),
 	}
 
 	ctrl.SetLogger(zap.New(zap.UseFlagOptions(&opts)))