Error treatment at dispatcher.

pedrotgn · May 29, 2017 · 49d3ffc · 49d3ffc
1 parent 9a5370a
commit 49d3ffc
Show file tree

Hide file tree

Showing 4 changed files with 8 additions and 4 deletions.
diff --git a/doc/conf.py b/doc/conf.py
@@ -62,7 +62,7 @@
 # The short X.Y version.
 version = u'1.3'
 # The full version, including alpha/beta/rc tags.
-release = u'1.3.0'
+release = u'1.3.1'
 
 # The language for content autogenerated by Sphinx. Refer to documentation
 # for a list of supported languages.

diff --git a/pyactor/green_thread/rpcactor.py b/pyactor/green_thread/rpcactor.py
@@ -101,5 +101,7 @@ def on_message(self, msg):
                 if msg[RPC_ID] in self.pending.keys():
                     self.pending[msg[RPC_ID]].send(msg)
                     del self.pending[msg[RPC_ID]]
+        except KeyError, ke:
+            print "ERROR: The actor", ke, "is offline."
         except Exception, e:
-            print 'TCP ERROR:', e
+            print 'Connection ERROR:', e
diff --git a/pyactor/thread/rpcactor.py b/pyactor/thread/rpcactor.py
@@ -101,5 +101,7 @@ def on_message(self, msg):
                 if msg[RPC_ID] in self.pending.keys():
                     self.pending[msg[RPC_ID]].send(msg)
                     del self.pending[msg[RPC_ID]]
+        except KeyError, ke:
+            print "ERROR: The actor", ke, "is offline."
         except Exception, e:
-            print 'TCP ERROR:', e
+            print 'Connection ERROR:', e
diff --git a/setup.py b/setup.py
@@ -2,7 +2,7 @@
 
 setup(
     name='pyactor',
-    version='1.3.0',
+    version='1.3.1',
     author='Pedro Garcia Lopez & Daniel Barcelona Pons',
     author_email='pedro.garcia@urv.cat, daniel.barcelona@urv.cat',
     packages=find_packages(),