- Fix #112
- Add default params for RPC.cereate()
- Fix InvalidStateError when connection lost
- Fix: RPC stuck when response deserialization error
- Drop python 3.4 support
- prevent
set_results
on cancelled future #133 - Added asynchronous context manager support for channels #130
- BUGFIX: ChannelClosed exception was never retrieved
- BUGFIX: handle coroutine double wrapping for Python 3.4
- added example for URL which contains ssl required options.
ssl_options
for coonect and connect_robust- default ports for
amqp
andamqps
- python 3.4 fix
- Add
message_kwargs
for worker pattern
- Added
timeout
parameter forExchange.declare
- QueueEmpty exception public added to the module
__all__
- Ability to reconnect on Channel.Close
- Ability to reconnect on Channel.Cancel
- Rollback to pika==0.10 because new one had issues.
- Feature: abillity to use ExternalCredentials with blank login.
- Bugfix: _on_getempty should delete _on_getok_callback #110. (thank's to @dhontecillas)
- Fixes for pyflakes
- Rework transactions
- Use pika's asyncio adapter
- Rework robust connector
- Ability to disable robustness for single queue in
rubust_connect
mode. - Ability to pass exchage by name.
- Added
python_requires=">3.4.*, <4",
instead ofif sys.version_info
in thesetup.py
- Change
TimeoutError
to theasyncio.TimeoutError
- Allow to bind queue by exchange name
- Added
extras_require = {':python_version': 'typing >= 3.5.3',
to thesetup.py
aio_pika.patterns
submoduleaio_pika.patterns.RPC
- RPC patternaio_pika.patterns.Master
- Master/Worker pattern
passive
argument for excahnge
Channel.is_closed
propertyChannel.close
just returnNone
when channel already closedConnection
might be used inasync with
expressionQueue
might be used inasync with
and returnsQueueIterator
- Changing examples
Queue.iterator()
methodQueueIterator.close()
returnsasyncio.Future
instead ofasyncio.Task
- Ability to use
QueueIterator
inasync for
expression connect_robust
is acoroutine
instead of function which returns a coroutine (PyCharm type checking display warning instead)- add tests
- Improve documentation. Add examples for connection and channel
Conneciton.close
returnsasyncio.Task
instead coroutine.connect_robust
now is function instead ofpartial
.