From c3000493d19fbb7539155bcc1cbb0cd74636fde4 Mon Sep 17 00:00:00 2001 From: Mario Date: Sat, 4 Jun 2022 17:44:15 +0200 Subject: [PATCH] Refactoring Factory RabbitMQ --- main.go | 19 +++++++------------ 1 file changed, 7 insertions(+), 12 deletions(-) diff --git a/main.go b/main.go index 3e6bb5b..3b28ee7 100644 --- a/main.go +++ b/main.go @@ -33,9 +33,13 @@ func main() { if !configured { rabbitMQURI = coreConfigurations.Core.Tracing.RabbitMQURI } - conn, channel := buildRabbitMQ(rabbitMQURI) - defer channel.Close() + conn, err := amqp.Dial(rabbitMQURI) + failOnError(err, "Failed to connect to RabbitMQ") defer conn.Close() + + channel, err = conn.Channel() + failOnError(err, "Failed to open a channel") + defer channel.Close() } // Init Protocol strategies @@ -77,6 +81,7 @@ func traceStrategyStdoutAndRabbitMQ(event tracer.Event) { }).Info("New Event") if channel != nil { + log.Debug("Push Event on queue") eventJSON, err := json.Marshal(event) failOnError(err, "Failed to Marshal Event") @@ -122,13 +127,3 @@ func configureLoggingByConfigurations(configurations parser.Logging) *os.File { } return file } - -func buildRabbitMQ(rabbitMQURI string) (*amqp.Connection, *amqp.Channel) { - conn, err := amqp.Dial(rabbitMQURI) - failOnError(err, "Failed to init Dial rabbitMQ") - - channel, err := conn.Channel() - failOnError(err, "Failed to connect on Channel") - - return conn, channel -}