Skip to content

Commit

Permalink
refactor(logging): change log-level for handlers
Browse files Browse the repository at this point in the history
  • Loading branch information
Th3Shadowbroker committed Feb 14, 2025
1 parent 061b126 commit eb569ce
Show file tree
Hide file tree
Showing 3 changed files with 4 additions and 4 deletions.
2 changes: 1 addition & 1 deletion internal/handler/delivering.go
Original file line number Diff line number Diff line change
Expand Up @@ -16,7 +16,7 @@ import (
)

func CheckDeliveringEvents() {
log.Info().Msgf("Republish messages in state DELIVERING")
log.Debug().Msgf("Republish messages in state DELIVERING")

var ctx = cache.HandlerCache.NewLockContext(context.Background())

Expand Down
2 changes: 1 addition & 1 deletion internal/handler/failed.go
Original file line number Diff line number Diff line change
Expand Up @@ -17,7 +17,7 @@ import (
)

func CheckFailedEvents() {
log.Info().Msgf("Republish messages in state FAILED")
log.Debug().Msgf("Republish messages in state FAILED")

var ctx = cache.HandlerCache.NewLockContext(context.Background())

Expand Down
4 changes: 2 additions & 2 deletions internal/handler/waiting.go
Original file line number Diff line number Diff line change
Expand Up @@ -29,7 +29,7 @@ var WaitingHandlerService WaitingHandlerInterface = new(waitingHandler)

// CheckWaitingEvents checks for events stuck in the WAITING state and creates a republishing entry if necessary.
func (waitingHandler *waitingHandler) CheckWaitingEvents() {
log.Info().Msgf("WaitingHandler: Republish messages stucked in state WAITING")
log.Debug().Msgf("WaitingHandler: Republish messages stucked in state WAITING")

minMessageAge := config.Current.WaitingHandler.MinMessageAge
maxMessageAge := config.Current.WaitingHandler.MaxMessageAge
Expand Down Expand Up @@ -98,7 +98,7 @@ func (waitingHandler *waitingHandler) CheckWaitingEvents() {
log.Debug().Msgf("WaitingHandler: Successfully created RepublishingCacheEntry entry for for events stucked in state WAITING. subscriptionId: %s republishingEntry: %+v", subscriptionId, republishingCacheEntry)
}
}
log.Info().Msgf("WaitingHandler: Finished republishing messages stucked in state WAITING")
log.Debug().Msgf("WaitingHandler: Finished republishing messages stucked in state WAITING")
}

// GetCircuitBreakerSubscriptionsMap returns a map of subscriptions with open circuit breaker entries.
Expand Down

0 comments on commit eb569ce

Please sign in to comment.