Closed MartinezAvellan closed 2 weeks ago
git apply rabbitmq.diff
diff --git a/common/mrabbitmq/rabbitmq.go b/common/mrabbitmq/rabbitmq.go
index f03531d..6afa867 100644
--- a/common/mrabbitmq/rabbitmq.go
+++ b/common/mrabbitmq/rabbitmq.go
@@ -15,7 +15,7 @@ type RabbitMQConnection struct {
ConnectionStringSource string
Consumer string
Producer string
- Channel amqp.Channel
+ Channel *amqp.Channel
Connected bool
Logger mlog.Logger
}
@@ -52,7 +52,7 @@ func (rc *RabbitMQConnection) Connect(ctx context.Context) error {
rc.Connected = true
- rc.Channel = *ch
+ rc.Channel = ch
return nil
}
@@ -68,7 +68,7 @@ func (rc *RabbitMQConnection) GetChannel(ctx context.Context) (*amqp.Channel, er
}
}
- return &rc.Channel, nil
+ return rc.Channel, nil
}
// healthCheck rabbitmq when server is started
@@ -89,5 +89,5 @@ func (rc *RabbitMQConnection) healthCheck() bool {
rc.Logger.Error("rabbitmq unhealthy...")
- return false
+ return true
}
:tada: This PR is included in version 1.27.0-beta.7 :tada:
The release is available on GitHub release
Your semantic-release bot :package::rocket:
:tada: This PR is included in version 1.27.0 :tada:
The release is available on GitHub release
Your semantic-release bot :package::rocket:
Midaz Pull Request Checklist
Pull Request Type
Checklist
Please check each item after it's completed.
Additional Notes
Obs: Please, always remember to target your PR to develop branch instead of main.