ZeroMq HighWaterMark socket option

[overplumbum]

Allows to specify zeromq_hwm socket option to prevent uncontrolled memory consumption during network failure in push mode.

[josegonzalez]

This needs to also be in beaver_config with a default...

[overplumbum]

ok, i've added config entry

[josegonzalez]

The int conversion should be done at https://github.com/overplumbum/beaver/blob/5933cfa69ea443b624d711679190dc0a636de2c3/beaver/config.py#L181

[overplumbum]

fixed. btw code contains other "misplaced" conversions:

beaver/queue.py:26:                    if failure_count > int(beaver_config.get('max_failure')):
beaver/queue.py:27:                        failure_count = int(beaver_config.get('max_failure'))
beaver/queue.py:29:                    sleep_time = int(beaver_config.get('respawn_delay')) ** failure_count
beaver/rabbitmq_transport.py:24:            port=int(beaver_config.get('rabbitmq_port')),
beaver/redis_transport.py:20:        self._redis = redis.StrictRedis(host=_url.hostname, port=_url.port, password=redis_password, db=int(_db), socket_timeout=10)
beaver/udp_transport.py:14:        self._address = (beaver_config.get('udp_host'), int(beaver_config.get('udp_port')))

[josegonzalez]

Okay, feel free to fix the mixplaced conversions! :)

[josegonzalez]

Merged, thanks for the pull request!