diff --git a/setup.py b/setup.py index 820d6ec..04c94bc 100644 --- a/setup.py +++ b/setup.py @@ -3,7 +3,7 @@ setup( name='pyzmqrpc', packages=['zmqrpc'], - version='2.0.0', + version='2.0.1', include_package_data=True, description='A simple ZMQ RPC extension with JSON for message serialization', author='J Verhoeven', diff --git a/zmqrpc/ZmqExceptions.py b/zmqrpc/ZmqExceptions.py new file mode 100644 index 0000000..bb18fbc --- /dev/null +++ b/zmqrpc/ZmqExceptions.py @@ -0,0 +1,11 @@ +''' +Created on Dec 10, 2017 + +@author: Pieter Eendebak + +@copyright: MIT license, see http://opensource.org/licenses/MIT +''' + + +class ZmqTimeoutException(Exception): + pass diff --git a/zmqrpc/ZmqSender.py b/zmqrpc/ZmqSender.py index 874d13b..66ce44e 100644 --- a/zmqrpc/ZmqSender.py +++ b/zmqrpc/ZmqSender.py @@ -10,6 +10,7 @@ import time import zmq +from .ZmqExceptions import ZmqTimeoutException logger = logging.getLogger("zmqrpc") @@ -178,7 +179,7 @@ def _send_over_req_socket(self, message, time_out_waiting_for_response_in_sec=10 return self.handle_response(response_message_json) # Some unexpected socket related error occurred. Recreate the REQ socket. self.recreate_req_socket = True - raise Exception("No response received on ZMQ Request to end point {0} in {1} seconds. Discarding message. Marking REQ socket to be recreated on next try.".format(self.zmq_req_endpoints, time_out_waiting_for_response_in_sec)) + raise ZmqTimeoutException("No response received on ZMQ Request to end point {0} in {1} seconds. Discarding message. Marking REQ socket to be recreated on next try.".format(self.zmq_req_endpoints, time_out_waiting_for_response_in_sec)) def send(self, message, time_out_waiting_for_response_in_sec=60): # Create sockets if needed. Raise an exception if any problems are encountered