adds unbind queue test

connection_test.go

@@ -35,6 +35,8 @@ func TestRabbit(t *testing.T) {
 	createExchangeTest(t, rabbit, exchange, "direct")
 	bindQueueTest(t, rabbit, exchange, queue)
 	publishAndConsume(t, ctx, rabbit, exchange, queue, msg)
+	unbindQueueTest(t, rabbit, exchange, queue)
+	publishAndConsume(t, ctx, rabbit, "", queue, msg)
 	if *waitFlag {
 		t.Logf("waiting 60 seconds. Go to %s for rabbit UI", uiURL)
 		time.Sleep(time.Second * 60)

go.mod

@@ -3,6 +3,7 @@ module github.com/gbeletti/rabbitmq
 go 1.18
 
 require (
+	github.com/google/go-cmp v0.5.5
 	github.com/rabbitmq/amqp091-go v1.3.4
 	github.com/testcontainers/testcontainers-go v0.13.0
 )

queue_test.go

@@ -34,3 +34,15 @@ func bindQueueTest(t *testing.T, rabbit rabbitmq.QueueBinder, exchange, queue st
 		t.Errorf("exchange [%s] queue [%s] error binding queue: %s\n", exchange, queue, err)
 	}
 }
+
+func unbindQueueTest(t *testing.T, rabbit rabbitmq.QueueBinder, exchange, queue string) {
+	config := rabbitmq.ConfigBindQueue{
+		QueueName:  queue,
+		RoutingKey: queue,
+		Exchange:   exchange,
+	}
+	err := rabbit.UnbindQueueExchange(config)
+	if err != nil {
+		t.Errorf("exchange [%s] queue [%s] error unbinding queue: %s\n", exchange, queue, err)
+	}
+}