-
Notifications
You must be signed in to change notification settings - Fork 57
Closed
Description
Connection class constructor accepts only the uri and connects at once. There is no way to specify the socket timeout, so connecting to a non-existing host:port behind a firewall lead to hanging. That's why other libs like pika, amqp-storm, etc. include the timeout kwarg. The lack of this feature renders the lib unusable for our projects, unfortunately.
UPDATE: just noticed self._socket.settimeout(0) in io.py/def _connect. This does not allow hanging, but introduces another problem with slow connections and simultaneous services startup.
UPDATE 2: noticed the hardcoded 3 secs timeout during the connection. That won't do either.
Metadata
Metadata
Assignees
Labels
No labels