pynsq

pynsq copied to clipboard

failed to mpub (192.168.1.199:4150, ['123']), data is SendError: no open connections (None)

4

ghost

Client configured with deflate=true loses connection on Tornado 6

3

### Versions - nsqd v1.2.1 (built w/go1.16.7) - Python 3.9.7 - pynsq 0.9.0 - tornado 6.1 ### Issue Reader constantly loses connection with nsqd on large payloads when running on...

ayamnikovx

Reader keeps querying nsqlookupd after `reader.close()` if it's called too quickly

1

``` import nsq import tornado reader = nsq.Reader( lookupd_http_addresses=["localhost:4161"], topic="topic", channel="channel", message_handler=lambda msg: None, lookupd_poll_interval=5, lookupd_poll_jitter=1.0, ) ioloop = tornado.ioloop.IOLoop.current() # Very quick, but this needs to run after reader._run...

dettonijr

@mreiferson any way we can get a release of 0.9.1 now that https://github.com/nsqio/pynsq/pull/254 has been merged? i.e. `can we haz plz` 

danbf

add Writer.close() and Client.close(), improve Reader.close()

2

make Reader.close() prevent nsqd_tcp_addresses from reconnecting Writer.close() also closes conns and stops from reconnecting Client.close() stops the periodic _check_last_recv_timestamps() fixes #196

ploxiln

``` ERROR:tornado.application:Exception in callback functools.partial() Traceback (most recent call last): File "/Users/c/.pyenv/versions/script/lib/python3.7/site-packages/tornado/ioloop.py", line 605, in _run_callback ret = callback() File "/Users/c/.pyenv/versions/script/lib/python3.7/site-packages/tornado/stack_context.py", line 277, in null_wrapper return fn(*args, **kwargs) File "/Users/c/.pyenv/versions/script/lib/python3.7/site-packages/tornado/iostream.py",...

HaoweiCh

IDENTIFY still uses short_id and long_id instead of client_id

2

`nsq.async.AsyncConn._on_connect()` still sends `short_id` and `long_id` fields.

ashleywalsh

docs: difference between synchronous and async message handling

2

I'd like the documentation to explain what the differences between the synchronous and the async reader examples is. The might be obvious to those who developed pynsq, but aren't necessarily...

marians

reader: by default, archive failed messages to disk

4

This is a follow up to #134 and changes the default behaviour of `Reader.give_up()` to be less surprising by writing messages that are "given up on" to disk instead of...

jehiah

CLS command in pynsq

2

I found in TCP protocol spec message CLS but in pynsq there is no method for this message. ### CLS Cleanly close your connection (no more messages are sent) ```...

kolyanu4