chore: disable mq health check

Signed-off-by: Firas Qutishat <firas.qutishat@securekey.com>
trustbloc · Jun 16, 2022 · af662a4 · af662a4
1 parent 2fd4f69
commit af662a4
Showing 1 changed file with 9 additions and 8 deletions.
diff --git a/pkg/pubsub/amqp/amqppubsub.go b/pkg/pubsub/amqp/amqppubsub.go
@@ -175,14 +175,15 @@ func (p *PubSub) Subscribe(ctx context.Context, topic string) (<-chan *message.M
 
 // IsConnected return error if not connected.
 func (p *PubSub) IsConnected() error {
-	connMgr, err := p.connMgr.getConnection(false)
-	if err != nil {
-		return err
-	}
-
-	if !connMgr.amqpConnection().IsConnected() {
-		return fmt.Errorf("mq not connected")
-	}
+	// TODO find way to check if mq is down
+	// connMgr, err := p.connMgr.getConnection(false)
+	// if err != nil {
+	//	return err
+	// }
+	//
+	// if !connMgr.amqpConnection().IsConnected() {
+	//	return fmt.Errorf("mq not connected")
+	// }
 
 	return nil
 }