search

Polyconseil / aioamqp

AMQP implementation using asyncio
Other
280 stars 88 forks source link

Python3.8 #210

Closed nikita-davydov closed 4 years ago

nikita-davydov commented 4 years ago

Your example https://github.com/Polyconseil/aioamqp/blob/master/examples/send.py

Doesn't work with Python3.8

An open stream was garbage collected prior to establishing network connection; call "stream.close()" explicitly.

Traceback (most recent call last):
  File "hello.py", line 31, in <module>
    asyncio.get_event_loop().run_until_complete(send())
  File "/Users/apple/.pyenv/versions/3.8.0/lib/python3.8/asyncio/base_events.py", line 608, in run_until_complete
    return future.result()
  File "hello.py", line 14, in send
    transport, protocol = await aioamqp.connect(host="127.0.0.1", port=5672, login="guest", password="guest", login_method="PLAIN")
  File "/Users/apple/.virtualenvs/venv_380/lib/python3.8/site-packages/aioamqp/__init__.py", line 59, in connect
    sock.setsockopt(socket.IPPROTO_TCP, socket.TCP_NODELAY, 1)
  File "/Users/apple/.pyenv/versions/3.8.0/lib/python3.8/asyncio/trsock.py", line 82, in setsockopt
    self._sock.setsockopt(*args, **kwargs)

OSError: [Errno 9] Bad file descriptor

Got this error
Tried to research -- found nothing