| Commit message (Collapse) | Author | Age | Files | Lines |
|
|
|
|
| |
Conflicts:
appveyor.yml
|
| |
|
|
|
| |
Fixes #273
|
| |
|
| |
|
| |
|
| |
|
|
|
|
|
|
|
|
|
|
| |
* Provide fix for #242, Option not supported by protocol on SunOS
It is not possible to set TCP_MAXSEG on illumos based distributions, which includes OmniOSce, SmartOS, OpenIndiana and more. The Oracle documentation provides information that the option could be set, but this isn't true based on the illumos source code: https://github.com/illumos/illumos-gate/blob/master/usr/src/uts/common/inet/tcp/tcp_opt_data.c#L93-L94
Removing this option for SunOS should be no problem, because the code would anyway set the same default value which is provided by the socket.
* Fix comment.
|
| |
|
|
|
|
|
|
|
|
|
|
|
|
| |
* Mark integration tests as flaky.
* pep8.
* Remove old compat code.
* Add __future__ imports.
* Remove outdated test.
|
| |
|
| |
|
| |
|
|
|
|
|
|
| |
* Use tox-docker in integration tests. Add more coverage.
* Readd PyPy2 & PyPy3 to the integration matrix.
|
| |
|
| |
|
| |
|
| |
|
| |
|
| |
|
|
|
| |
Add a test to verify that parsing two consecutive bitmaps does not fail.
|
|
|
|
| |
Python 3.7 to Appveyor configuration. (#261)
|
| |
|
|
|
|
|
|
|
|
|
|
|
|
| |
* for deserialisation, correct offset for bits
it needs to be increased only at the beginning and once every 8 bits
* Added a test.
* Autopep8.
* Verify result.
|
| |
|
| |
|
| |
|
| |
|
| |
|
| |
|
|
|
|
|
|
|
|
|
| |
py-amqp 2.4.0 caused a regression on Windows. Reading from a
non-blocking socket having the timeout set to 0 might raise a
WSAEWOULDBLOCK socket error instead of a timeout, which we're not
properly handling.
This change will make sure that we're just handling this as a
timeout.
|
|
|
|
|
|
|
|
|
| |
Without specifically handling this case, the socket.timeout()
was not raised sometimes causing the connection to lock up.
In the case we hit the errno was None, so the previous if
condition did not apply.
Co-Authored-By: aojeagarcia <aojeagarcia@suse.com>
|
|
|
|
|
|
|
|
| |
* support float read/write timeout
* test read_timeout/write_timeout settings
* fix lint "line too long" issue
|
|
|
|
| |
Reference:
https://github.com/celery/py-amqp/issues/249
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
| |
read_frame is using str.join to concatenate the payload if the received
frame is bigger than SIGNED_INT_MAX.
That's fine with python2, however in python3 documentation is stated
str.joinReturn a string which is the concatenation of the strings in the
iterable iterable. A TypeError will be raised if there are any
non-string values in iterable, including bytes objects. The separator
between elements is the string providing this method.
So we have to use the byte object join() method
Signed-off-by: aojeagarcia <aojeagarcia@suse.com>
|
|
|
| |
Signed-off-by: aojeagarcia <aojeagarcia@suse.com>
|
|
|
|
| |
capability (#244)
|
| |
|
| |
|
|
|
|
|
|
| |
* Bump PyPy to 6.0. Add PyPy3 to the build process.
* Add xenial dist to pypy builds in .travis.yml
|
| |
|
| |
|
| |
|
|
|
|
|
|
| |
* Improve return values in doc strings
* Added queue and exchange integration tests
|
| |
|
|
|
|
|
|
|
|
|
|
| |
* Don't return method signature from AbstractChannel::wait()
Commit f63f8fe9efbe3357741f32541ea2d7b063f7df09 added
new parameter `method_sig` for wait() callback. This change
breaks some parts of existing code. This commit handles this issue.
* Fix basic_publish integration test
|
|
|
|
|
|
|
|
|
|
|
|
| |
* Don't revive channel when connection is closing
* When connection is closing dont raise error when Channel.Close method is received
* Added unitests
* Fix flake8
* Fix typo
|
| |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
| |
* Use consumer tag sent by broker instead of using directly parameter value
* Added more unittests of basic_consume() method
* Make pep8 happy
* Split integration tests to connection tests and channel tests
* Added connection closed integration test
* Added integration tests for basic_consume()
* Fix typos
|
| |
|