when raise MQ connection lost, skip iconservice close (#70)

* when raise MQ connection lost skip iconservice close * typo fix
icon-project · Jan 10, 2019 · cb8cf57 · cb8cf57
1 parent 8e1e5e2
commit cb8cf57
Show file tree

Hide file tree

Showing 3 changed files with 12 additions and 6 deletions.
diff --git a/VERSION b/VERSION
@@ -1 +1 @@
-1.1.2.11
+1.1.2.12
diff --git a/iconservice/icon_inner_service.py b/iconservice/icon_inner_service.py
@@ -257,8 +257,11 @@ class IconScoreInnerService(MessageQueueService[IconScoreInnerTask]):
     TaskType = IconScoreInnerTask
 
     def _callback_connection_lost_callback(self, connection: 'RobustConnection'):
-        Logger.error("MQ Connection lost.")
-        self.clean_close()
+        Logger.error("MQ Connection lost. [Service]")
+        # self.clean_close()
+
+    def _callback_connection_reconnect_callback(self, connection: 'RobustConnection'):
+        Logger.error("MQ Connection reconnect. [Service]")
 
     def clean_close(self):
         self._task._close()
@@ -268,5 +271,8 @@ class IconScoreInnerStub(MessageQueueStub[IconScoreInnerTask]):
     TaskType = IconScoreInnerTask
 
     def _callback_connection_lost_callback(self, connection: 'RobustConnection'):
-        Logger.error("MQ Connection lost.")
-        self._task._close()
+        Logger.error("MQ Connection lost. [Stub]")
+        # self._task._close()
+
+    def _callback_connection_reconnect_callback(self, connection: 'RobustConnection'):
+        Logger.error("MQ Connection reconnect. [Service]")
diff --git a/iconservice/icon_service.py b/iconservice/icon_service.py
@@ -140,7 +140,7 @@ def run_in_foreground(conf: 'IconConfig'):
 
 
 def _run_async(async_func):
-    loop = asyncio.new_event_loop()
+    loop = MessageQueueService.loop
     return loop.run_until_complete(async_func)