Skip to content

Commit

Permalink
Refactor healcheck ibm-mq
Browse files Browse the repository at this point in the history
  • Loading branch information
pnhattuan committed May 16, 2021
1 parent 837a9f7 commit d7d7db5
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions ibm-mq/health_checker.go
Original file line number Diff line number Diff line change
Expand Up @@ -33,10 +33,10 @@ func NewHealthChecker(connection *ibmmq.MQQueueManager, topic string, options ..
} else {
name = "ibmmq"
}
return NewIBMMQHealthChecker(connection, topic, name, 4*time.Second)
return NewHealthCheckerWithTimeout(connection, topic, name, 4*time.Second)
}

func NewIBMMQHealthChecker(connection *ibmmq.MQQueueManager, topic string, name string, timeouts ...time.Duration) *HealthChecker {
func NewHealthCheckerWithTimeout(connection *ibmmq.MQQueueManager, topic string, name string, timeouts ...time.Duration) *HealthChecker {
var timeout time.Duration
if len(timeouts) >= 1 {
timeout = timeouts[0]
Expand Down

0 comments on commit d7d7db5

Please sign in to comment.