fix: testcontainer bug

mehdihadeli · Sep 2, 2023 · 13f46b2 · 13f46b2
1 parent 77a8958
commit 13f46b2
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 6 deletions.
diff --git a/internal/pkg/rabbitmq/bus/rabbitmq-bus.go b/internal/pkg/rabbitmq/bus/rabbitmq-bus.go
@@ -239,6 +239,11 @@ func (r *rabbitmqBus) ConnectConsumerHandler(
 }
 
 func (r *rabbitmqBus) Start(ctx context.Context) error {
+	r.logger.Infof(
+		"rabbitmq is running on host: %s",
+		r.rabbitmqConnection.Raw().LocalAddr().String(),
+	)
+
 	for messageType, consumers := range r.messageTypeConsumers {
 		name := typeMapper.GetTypeNameByType(messageType)
 		r.logger.Info(fmt.Sprintf("consuming message type %s", name))

diff --git a/internal/pkg/test/containers/testcontainer/rabbitmq/rabbitmq_container.go b/internal/pkg/test/containers/testcontainer/rabbitmq/rabbitmq_container.go
@@ -98,12 +98,6 @@ func (g *rabbitmqTestContainers) CreatingContainerOptions(
 
 	isConnectable := IsConnectable(host, hostPort.Int(), t)
 	if isConnectable == false {
-		if dbContainer.IsRunning() {
-			if err := dbContainer.Terminate(ctx); err != nil {
-				t.Fatalf("failed to terminate container: %s", err)
-			}
-		}
-
 		return g.CreatingContainerOptions(context.Background(), t, options...)
 	}