diff --git a/src/services/OrionAggregator/ws/index.ts b/src/services/OrionAggregator/ws/index.ts
index 5432043..5303ef6 100644
--- a/src/services/OrionAggregator/ws/index.ts
+++ b/src/services/OrionAggregator/ws/index.ts
@@ -262,6 +262,7 @@ class OrionAggregatorWS {
   }
 
   init(isReconnect = false) {
+    this.isClosedIntentionally = false;
     this.ws = new WebSocket(this.wsUrl);
     this.ws.onclose = () => {
       if (!this.isClosedIntentionally) this.init(true);
diff --git a/src/services/PriceFeed/ws/PriceFeedSubscription.ts b/src/services/PriceFeed/ws/PriceFeedSubscription.ts
index 116fe15..55bd87d 100644
--- a/src/services/PriceFeed/ws/PriceFeedSubscription.ts
+++ b/src/services/PriceFeed/ws/PriceFeedSubscription.ts
@@ -93,6 +93,8 @@ export default class PriceFeedSubscription<T extends SubscriptionType = Subscrip
   }
 
   init() {
+    this.isClosedIntentionally = false;
+
     const { payload, url, type } = this;
     this.ws = new WebSocket(`${url}/${type}${payload ? `/${payload.toString()}` : ''}`);