Implements collect for pyamqp transport.  Closes celery/celery#2312