Fixing race condition (#1190)

QuesmaOrg · Jan 15, 2025 · 4ffb5c9 · 4ffb5c9
1 parent 091eabb
commit 4ffb5c9
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/quesma/v2/core/quesma_builder.go b/quesma/v2/core/quesma_builder.go
@@ -145,7 +145,7 @@ func (quesma *Quesma) buildInternal() (QuesmaBuilder, error) {
 						if info.pipelineIndex == pipelineIndex && info.connIndex == connIndex {
 							continue
 						}
-						quesma.dependencies.Logger().Info().Msgf("Sharing frontend connector %v with %v", sharedFc.InstanceName(), conn.InstanceName())
+						quesma.dependencies.Logger().Info().Msgf("Sharing frontend connector %p with %p", sharedFc, pipeline.GetFrontendConnectors()[connIndex])
 						pipeline.GetFrontendConnectors()[connIndex] = sharedFc
 					}
 				}

diff --git a/quesma/v2/core/quesma_pipeline.go b/quesma/v2/core/quesma_pipeline.go
@@ -70,7 +70,7 @@ func (p *Pipeline) Start() {
 	// because we are copying routing table from all connectors
 	// however, bind error remains
 	for _, conn := range p.FrontendConnectors {
-		p.logger.Info().Msgf("Starting frontend connector %s", conn)
+		p.logger.Info().Msgf("Starting frontend connector %s", conn.GetEndpoint())
 		go conn.Listen()
 	}
 }