Skip to content
Open
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension


Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 1 addition & 1 deletion setup.py
Original file line number Diff line number Diff line change
Expand Up @@ -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',
Expand Down
11 changes: 11 additions & 0 deletions zmqrpc/ZmqExceptions.py
Original file line number Diff line number Diff line change
@@ -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
3 changes: 2 additions & 1 deletion zmqrpc/ZmqSender.py
Original file line number Diff line number Diff line change
Expand Up @@ -10,6 +10,7 @@
import time

import zmq
from .ZmqExceptions import ZmqTimeoutException

logger = logging.getLogger("zmqrpc")

Expand Down Expand Up @@ -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
Expand Down