By default, the virtual host configured in the uri is used

rabbitmq · Jan 5, 2024 · 0c1b4d5 · 0c1b4d5
1 parent a6fa7f7
commit 0c1b4d5
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/_examples/producer/producer.go b/_examples/producer/producer.go
@@ -6,12 +6,13 @@ package main
 import (
 	"context"
 	"flag"
-	amqp "github.com/rabbitmq/amqp091-go"
 	"log"
 	"os"
 	"os/signal"
 	"syscall"
 	"time"
+
+	amqp "github.com/rabbitmq/amqp091-go"
 )
 
 var (
@@ -58,7 +59,6 @@ func setupCloseHandler(exitCh chan struct{}) {
 
 func publish(ctx context.Context, publishOkCh <-chan struct{}, confirmsCh chan<- *amqp.DeferredConfirmation, confirmsDoneCh <-chan struct{}, exitCh chan struct{}) {
 	config := amqp.Config{
-		Vhost:      "/",
 		Properties: amqp.NewConnectionProperties(),
 	}
 	config.Properties.SetClientConnectionName("producer-with-confirms")