HackerExperience · umamaistempo · Mar 27, 2015 · May 6, 2015 · May 6, 2015 · May 6, 2015
diff --git a/.gitattributes b/.gitattributes
@@ -0,0 +1,2 @@
+# Auto detect text files and perform LF normalization
+* text=auto
diff --git a/.gitignore b/.gitignore
@@ -1,56 +1,57 @@
-# Byte-compiled / optimized / DLL files
-__pycache__/
-*.py[cod]
-
-# C extensions
-*.so
-
-# Distribution / packaging
-.Python
-env/
-bin/
-build/
-develop-eggs/
-dist/
-eggs/
-lib/
-lib64/
-parts/
-sdist/
-var/
-*.egg-info/
-.installed.cfg
-*.egg
-
-# Installer logs
-pip-log.txt
-pip-delete-this-directory.txt
-
-# Unit test / coverage reports
-htmlcov/
-.tox/
-.coverage
-.cache
-nosetests.xml
-coverage.xml
-
-# Translations
-*.mo
-
-# Mr Developer
-.mr.developer.cfg
-.project
-.pydevproject
-
-# Rope
-.ropeproject
-
-# Django stuff:
-*.log
-*.pot
-
-# Sphinx documentation
-doc/_build/
-
-*.sublime-workspace
-.ipynb_checkpoints
+# Byte-compiled / optimized / DLL files
+__pycache__/
+*.py[cod]
+
+# C extensions
+*.so
+
+# Distribution / packaging
+.Python
+env/
+bin/
+build/
+develop-eggs/
+dist/
+eggs/
+lib/
+lib64/
+parts/
+sdist/
+var/
+*.egg-info/
+.installed.cfg
+*.egg
+
+# Installer logs
+pip-log.txt
+pip-delete-this-directory.txt
+
+# Unit test / coverage reports
+htmlcov/
+.tox/
+.coverage
+.cache
+nosetests.xml
+coverage.xml
+
+# Translations
+*.mo
+
+# Mr Developer
+.mr.developer.cfg
+.project
+.pydevproject
+
+# Rope
+.ropeproject
+
+# Django stuff:
+*.log
+*.pot
+
+# Sphinx documentation
+doc/_build/
+
+*.sublime-workspace
+.ipynb_checkpoints
+.DS_Store
diff --git a/.travis.yml b/.travis.yml
@@ -1,16 +1,25 @@
+sudo: false
+
 language: python
 
-python: 3.4
+python:
+  - 3.4
+  - 3.5
+  - 3.6
 
 services: rabbitmq
 
 install:
-  - pip install contexts colorama sphinx
-  - python setup.py install
+  - pip install -r requirements.txt
+  - python setup.py develop
 
 script:
-  - run-contexts -v
-  - cd doc && make html
+  - flake8 src test --ignore=E501,W503,E722
+  - coverage run --source=src -m contexts -v
+  - pushd doc && make html && popd
+
+after_success:
+  coveralls
 
 deploy:
   provider: pypi
@@ -21,6 +30,3 @@ deploy:
     tags: true
     all_branches: true
   distributions: "sdist bdist_wheel bdist_egg"
-
-after_deploy:
-  - curl -X POST http://readthedocs.org/build/asynqp
diff --git a/CHANGELOG.md b/CHANGELOG.md
@@ -0,0 +1,35 @@
+What's new in `asynqp`
+======================
+
+
+v0.5
+----
+* Channels will no longer break if their calls are cancelled. Issue #52.
+* Fixed message properties decoding without `content_type`. Pull request #66.
+* Added `nowait` argument to Exchange and Queue declarations.
+* Added `passive` argument to Exchange and Queue declarations.
+* Added `on_error` and `on_cancel` callbacks for Consumer. Issue #34
+* Changed the closing scheme for Channel/Connection. Proper exceptions are now
+always propagated to user. Issues #57, #58
+* Complete internals refactor and cleanup. Rull requests #48, #49, #50. 
+* Add NO_DELAY option for socket. Issue #40. (Thanks to @socketpair for PR #41)
+* Change heartbeat to be a proper background task. Issue #45. 
+* `loop` is now proparly passed to all components from open_connection call. Pull request #42.
+* Add support for Python up to 3.5.
+
+v0.4
+----
+
+* Improved error handling.
+  * When the connection to the server is lost, any futures awaiting communication
+    from the server will now be cancelled.
+    (Thanks to @lenzenmi, in pull request #19)
+  * More detailed exceptions on channel closure.
+* Support for custom RabbitMQ extensions by an `arguments` keyword parameter for a number of methods.
+  (Thanks to @fweisel, in pull request #27)
+* Improved compatibility with RabbitMQ's implementation of the
+  wire protocol, including better support for tables.
+  (Thanks to @fweisel, in pull requests #24, #25, #26, #28)
+* Support for a `sock` keyword argument to `asynqp.connect`.
+  (Thanks to @urbaniak, in pull request #14)
+
diff --git a/CONTRIBUTING.md b/CONTRIBUTING.md
@@ -5,6 +5,10 @@ To contribute to this project, submit a [pull request](https://help.github.com/a
 3. [Open a pull request](https://help.github.com/articles/creating-a-pull-request) in this repo to merge your topic branch into the mainstream
 4. I'll review your changes and merge your pull request as soon as possible
 
+If you want to contribute to the project, but are not sure what you want to work on,
+I am always happy for help on any of the [open issues](https://github.com/benjamin-hodgson/asynqp/issues)
+in the GitHub tracker.
+
 This project is built using Test-Driven-Development.
 So if you're planning to contribute a feature or bugfix, please **ensure that
 it is covered by tests** before submitting it for review. Use your best judgment to

diff --git a/LICENSE b/LICENSE
@@ -1,6 +1,6 @@
 The MIT License (MIT)
 
-Copyright (c) 2013-2014 Benjamin Hodgson
+Copyright (c) 2013-2015 Benjamin Hodgson
 
 Permission is hereby granted, free of charge, to any person obtaining a copy
 of this software and associated documentation files (the "Software"), to deal

diff --git a/README.md b/README.md
@@ -2,7 +2,9 @@ asynqp
 ======
 
 [![Build Status](https://travis-ci.org/benjamin-hodgson/asynqp.svg?branch=master)](https://travis-ci.org/benjamin-hodgson/asynqp)
-[![Documentation Status](https://readthedocs.org/projects/asynqp/badge/?version=v0.3)](https://readthedocs.org/projects/asynqp/?badge=v0.3)
+[![Documentation Status](https://readthedocs.org/projects/asynqp/badge/?version=v0.4)](https://readthedocs.org/projects/asynqp/?badge=v0.4)
+[![Coverage Status](https://coveralls.io/repos/benjamin-hodgson/asynqp/badge.svg?branch=master&service=github)](https://coveralls.io/github/benjamin-hodgson/asynqp?branch=master)
+[![Requirements Status](https://requires.io/github/benjamin-hodgson/asynqp/requirements.svg?branch=master)](https://requires.io/github/benjamin-hodgson/asynqp/requirements/?branch=master)
 
 `asynqp` is an AMQP (aka [RabbitMQ](rabbitmq.com)) client library for
 Python 3.4's new [`asyncio`](https://docs.python.org/3.4/library/asyncio.html) module.
@@ -19,7 +21,10 @@ import asynqp
 
 
 @asyncio.coroutine
-def send_and_receive():
+def hello_world():
+    """
+    Sends a 'hello world' message and then reads it from the queue.
+    """
     # connect to the RabbitMQ broker
     connection = yield from asynqp.connect('localhost', 5672, username='guest', password='guest')
 
@@ -34,7 +39,7 @@ def send_and_receive():
     yield from queue.bind(exchange, 'routing.key')
 
     # If you pass in a dict it will be automatically converted to JSON
-    msg = asynqp.Message({'test_body': 'content'})
+    msg = asynqp.Message({'hello': 'world'})
     exchange.publish(msg, 'routing.key')
 
     # Synchronously get a message from the queue
@@ -50,7 +55,7 @@ def send_and_receive():
 
 if __name__ == "__main__":
     loop = asyncio.get_event_loop()
-    loop.run_until_complete(send_and_receive())
+    loop.run_until_complete(hello_world())
 ```
 
 

diff --git a/RELEASING b/RELEASING
@@ -1,8 +1,8 @@
-1. Check Travis is green on the latest commit
-2. Increment the version in setup.py
-3. Increment the version in doc/conf.py
-4. Commit and tag
-5. Push using --follow-tags
-6. Check that the tests passed on Travis and it published to the Cheese Shop
-6a. If it failed to publish to the cheese shop for some reason, run `python setup.py register` followed by `python setup.py sdist bdist_egg bdist_wheel upload`
-7. Build the docs at readthedocs.org and increment the latest version
+1. Check Travis is green on the latest commit
+2. Increment the version in setup.py
+3. Increment the version in doc/conf.py
+4. Commit and tag
+5. Push using --follow-tags
+6. Check that the tests passed on Travis and it published to the Cheese Shop
+6a. If it failed to publish to the cheese shop for some reason, run `python setup.py register` followed by `python setup.py sdist bdist_egg bdist_wheel upload`
+7. Build the docs at readthedocs.org and increment the latest version
diff --git a/TODO b/TODO
@@ -1,7 +1,7 @@
 API design issues
 
     Public implementation-related fields in public classes (even though they're not documented)
-    Threading issues
+    Threading issues?
     Load testing?
 
 
@@ -41,6 +41,5 @@ Unimplemented methods:
 Unimplemented functions
 
     Customise connection-tune response
-    General exception handling
     Passive declares
     No-wait flags
diff --git a/doc/conf.py b/doc/conf.py
@@ -51,16 +51,16 @@
 
 # General information about the project.
 project = 'asynqp'
-copyright = '2014, Benjamin Hodgson'
+copyright = '2014-2015, Benjamin Hodgson'
 
 # The version info for the project you're documenting, acts as replacement for
 # |version| and |release|, also used in various other places throughout the
 # built documents.
 #
 # The short X.Y version.
-version = '0.3'
+version = '0.6'
 # The full version, including alpha/beta/rc tags.
-release = '0.3'
+release = '0.6'
 
 
 def hide_class_constructor(app, what, name, obj, options, signature, return_annotation):

diff --git a/doc/conformance.rst b/doc/conformance.rst
@@ -46,7 +46,7 @@ that are currently supported by ``asynqp``.
 +------------+----------------------+-------------------+-------------------------------------------+-----------------------------------------+
 | exchange   |                      | :orange:`partial` | :class:`asynqp.Exchange`                  |                                         |
 +------------+----------------------+-------------------+-------------------------------------------+-----------------------------------------+
-|            | declare/declare-ok   | :orange:`partial` | :meth:`asynqp.Channel.declare_exchange`   | Not all parameters presently supported  |
+|            | declare/declare-ok   | :green:`full`     | :meth:`asynqp.Channel.declare_exchange`   |                                         |
 +------------+----------------------+-------------------+-------------------------------------------+-----------------------------------------+
 |            | delete/delete-ok     | :green:`full`     | :meth:`asynqp.Exchange.delete`            |                                         |
 +------------+----------------------+-------------------+-------------------------------------------+-----------------------------------------+
@@ -56,7 +56,7 @@ that are currently supported by ``asynqp``.
 +------------+----------------------+-------------------+-------------------------------------------+-----------------------------------------+
 | queue      |                      | :orange:`partial` | :class:`asynqp.Queue`                     |                                         |
 +------------+----------------------+-------------------+-------------------------------------------+-----------------------------------------+
-|            | declare/declare-ok   | :orange:`partial` | :meth:`asynqp.Channel.declare_queue`      | Not all parameters presently supported  |
+|            | declare/declare-ok   | :green:`full`     | :meth:`asynqp.Channel.declare_queue`      |                                         |
 +------------+----------------------+-------------------+-------------------------------------------+-----------------------------------------+
 |            | bind/bind-ok         | :orange:`partial` | :meth:`asynqp.Queue.bind`                 | Not all parameters presently supported  |
 +------------+----------------------+-------------------+-------------------------------------------+-----------------------------------------+

diff --git a/doc/examples.rst b/doc/examples.rst
@@ -0,0 +1,14 @@
+Examples
+========
+
+
+Hello World
+-----------
+.. literalinclude:: /examples/helloworld.py
+   :language: python
+
+
+Reconnecting
+------------
+.. literalinclude:: /examples/reconnecting.py
+   :language: python
diff --git a/doc/examples/helloworld.py b/doc/examples/helloworld.py
@@ -0,0 +1,40 @@
+import asyncio
+import asynqp
+
+
+@asyncio.coroutine
+def hello_world():
+    """
+    Sends a 'hello world' message and then reads it from the queue.
+    """
+    # connect to the RabbitMQ broker
+    connection = yield from asynqp.connect('localhost', 5672, username='guest', password='guest')
+
+    # Open a communications channel
+    channel = yield from connection.open_channel()
+
+    # Create a queue and an exchange on the broker
+    exchange = yield from channel.declare_exchange('test.exchange', 'direct')
+    queue = yield from channel.declare_queue('test.queue')
+
+    # Bind the queue to the exchange, so the queue will get messages published to the exchange
+    yield from queue.bind(exchange, 'routing.key')
+
+    # If you pass in a dict it will be automatically converted to JSON
+    msg = asynqp.Message({'hello': 'world'})
+    exchange.publish(msg, 'routing.key')
+
+    # Synchronously get a message from the queue
+    received_message = yield from queue.get()
+    print(received_message.json())  # get JSON from incoming messages easily
+
+    # Acknowledge a delivered message
+    received_message.ack()
+
+    yield from channel.close()
+    yield from connection.close()
+
+
+if __name__ == "__main__":
+    loop = asyncio.get_event_loop()
+    loop.run_until_complete(hello_world())