diff --git a/src/connectors/connectorRIS.js b/src/connectors/connectorRIS.js
index 3a8735c8..b9b89a8f 100644
--- a/src/connectors/connectorRIS.js
+++ b/src/connectors/connectorRIS.js
@@ -79,10 +79,6 @@ export default class ConnectorRIS extends Connector {
                 instance: this.instanceId
             }
         });
-
-        if (this._shouldCanaryMonitoringStart()) { // The canary feature may impact performance if you are planning to get all the possible updates of RIS
-            this._startCanaryInterval = setInterval(this._startCanary, 60000);
-        }
     };
 
     _shouldCanaryMonitoringStart = () => {
@@ -283,7 +279,10 @@ export default class ConnectorRIS extends Connector {
                 }))
                 .then(() => {
                     this._checkCanary();
-                    clearInterval(this._startCanaryInterval);
+                    this.logger.log({
+                        level: 'info',
+                        message: "Subscribed to beacons"
+                    });
                 })
                 .catch(() => {
                     this.logger.log({
@@ -298,7 +297,7 @@ export default class ConnectorRIS extends Connector {
         clearTimeout(this._timerCheckCanary);
         if (!this.connected) {
             this.logger.log({
-                level: 'error',
+                level: 'info',
                 message: "RIS connected again, the streaming session is working properly"
             });
         }
@@ -355,6 +354,16 @@ export default class ConnectorRIS extends Connector {
         return (this.params.carefulSubscription
             ? Promise.all([this._subscribeToPrefixes(input), this._subscribeToASns(input)])
             : this._subscribeToAll(input))
+            .then(() => {
+                    this.logger.log({
+                        level: 'info',
+                        message: "Subscribed to monitored resources"
+                    });
+                    if (this._shouldCanaryMonitoringStart()) {
+                        this._startCanary();
+                    }
+                }
+            )
             .then(() => {
                 this.onInputChange(input);