summaryrefslogtreecommitdiff
Commit message (Collapse)AuthorAgeFilesLines
* Improvements and cosmetics for Issue #281sqsoptsAsk Solem2013-12-132-83/+88
|
* Tests should not use the filesystemAsk Solem2013-12-121-126/+31
|
* Fix Python 3 unit tests in Travis CI.Matt Wise2013-12-033-7/+5
| | | | | | Python 3+ cannot even build/install Boto, so we need to have a separate test-ci3.txt file to define Python 3+ test requirements.
* Skip SQS unit tests in Python 3.3.Matt Wise2013-12-031-0/+6
| | | | | Boto does not yet support Python 3+, so these unit tests cannot run in Python 3.3
* Remove kombu.trasnport.SQS from the coverage report exclusion list.Matt Wise2013-12-031-1/+0
|
* Fix SQS tests in Python 3.3Matt Wise2013-12-031-2/+0
|
* Add boto to the requirements for TravisCI testsMatt Wise2013-12-031-0/+1
|
* Skip transport.SQS unit tests if Boto is not installedMatt Wise2013-12-031-2/+14
|
* Use the Amazon SQS Bulk Fetch API to implement the Kombu prefetch_count.Matt Wise2013-12-023-2/+185
| | | | | | | | | | | | This patch implements a new private method on the SQS Channel object named _get_bulk(). This method calls out to the QoS object to get a number of estimated messages its allowed to retrieve from SQS at any given moment, and then pulls them down and returns a list of these messages. An updated drain_events() method then stores these messages in a local cache object, and pops them off one by one as the drain_events() method is called by the Transport.drain_channel() method.
* Make _get() simpler, move most logic into private methods.Matt Wise2013-12-022-16/+94
| | | | | | | In preparation for building a _get_bulk() method to handle getting many messages from SQS at once, this commit moves most of the logic from _get() into separate methods that can be more easily unit tested and re-used.
* Use real Queue objects to test publishing/consuming messages in SQS tests.Matt Wise2013-12-021-12/+24
|
* More consistent test queue nameMatt Wise2013-12-021-1/+1
|
* Pyflakes cleanupMatt Wise2013-12-021-2/+2
|
* Add test_get_with_empty_list method to check that Empty is raisedMatt Wise2013-12-021-0/+4
|
* Pep8 cleanupMatt Wise2013-12-021-4/+15
|
* Revert "Add 'messages_to_fetch' option to kombu.transport.SQS. Default to 10."Matt Wise2013-12-022-163/+29
| | | | This reverts commit 8b3c74a9c3f415a1404a84446daa2c285632bba5.
* Add can_consume_max_estimate() method to QoS object.Matt Wise2013-12-021-0/+15
| | | | | | This method will be used by channels with bulk 'get' capabilities to improve performance of get calls by retrieving more than one message at a time.
* Add myself to the AUTHORS fileMatt Wise2013-11-221-0/+1
|
* Add 'messages_to_fetch' option to kombu.transport.SQS. Default to 10.Matt Wise2013-11-222-29/+163
| | | | | | | | | | | | Allow the user to specify the number of messages an individual Channel will fetch at a given time from SQS. Default this to Amazons max of 10 -- if there are less messages in the queue, Amazon will just return whats available. These messages are fetched and stored in a local _queue_message_cache deque object. When subsequent _get() calls are made, this queue is depleted until its empty before making another request to SQS for new messages.
* Add basic put/get unit tests for kombu.transport.SQSMatt Wise2013-11-212-9/+43
|
* Initial unit testing framework for kombu.transport.SQS package.Matt Wise2013-11-212-1/+207
|
* Fixes versionAsk Solem2013-11-211-1/+1
|
* Sets release-date for 3.0.6Ask Solem2013-11-211-1/+1
|
* Changes by -> release-byAsk Solem2013-11-211-86/+86
|
* Updates ChangelogAsk Solem2013-11-211-1/+11
|
* Bumps version to 3.0.6v3.0.6Ask Solem2013-11-211-1/+1
|
* Updates ChangelogAsk Solem2013-11-211-0/+4
|
* Tests passingAsk Solem2013-11-211-2/+2
|
* flakesAsk Solem2013-11-214-21/+39
|
* Redis transport: Make sure PUBSUB message does not crash the transport ↵Ask Solem2013-11-211-8/+11
| | | | (Issue celery/celery#1674)
* kombu.VERSION is now a namedtupleAsk Solem2013-11-202-3/+9
|
* Updates ChangelogAsk Solem2013-11-201-0/+19
|
* Timer: Do not hash on kwargs. Closes #275Ask Solem2013-11-201-1/+1
|
* Adds by field againAsk Solem2013-11-201-1/+69
|
* Adds Fabrice Rabaute to AUTHORSAsk Solem2013-11-201-0/+1
|
* Check against correct typesFabrice Rabaute2013-11-201-3/+5
|
* Importing kqueue should not fail because of a missing KQ_ constantAsk Solem2013-11-181-31/+27
|
* Redis Unixsocket: Support setting virtual host in queryAsk Solem2013-11-181-18/+26
| | | | | | | | Example url with virtual host set: redis+socket:///tmp/redis.sock?virtual_host=3 Related to Issue #238
* Bumps version to 3.0.5v3.0.5Ask Solem2013-11-152-2/+2
|
* Updates ChangelogAsk Solem2013-11-151-0/+23
|
* Now depends on amqp 1.3.3Ask Solem2013-11-152-2/+2
|
* Adds bitdeliAsk Solem2013-11-152-1/+4
|
* [Py3] anyjson.loads requires string argument. Closes #270Ask Solem2013-11-159-14/+20
|
* Avoid hardcoded path to CoreServices libraryAsk Solem2013-11-141-4/+3
|
* Merge branch '3.0'Ask Solem2013-11-141-0/+1
|\
| * Adds Victor Garcia to AUTHORSAsk Solem2013-11-141-0/+1
| |
* | Merge pull request #269 from dongweiming/modify_transport_mongodbAsk Solem Hoel2013-11-141-4/+1
|\ \ | |/ |/| Modify: transport/mongodb
| * Modify: transport/mongodbdongweiming2013-11-131-4/+1
| |
* | Merge pull request #273 from victorgp/masterAsk Solem Hoel2013-11-141-1/+1
|\ \ | | | | | | fixing small bug in prepare_message method: type object argument after *...
| * | fixing small bug in prepare_message method: type object argument after ** ↵Victor Garcia2013-11-131-1/+1
|/ / | | | | | | must be a mapping, not NoneType
View Lorry Controller Status