Ask Solem
84a8c28230
Update copyright headers to include 2011
2011-01-31 22:44:30 +01:00
Ask Solem
383373e623
Bumped version to 1.0.2
2011-01-31 22:31:47 +01:00
Ask Solem
ba766714ab
Ghettoq transport names are now aliases to the kombu ones
2011-01-31 22:31:06 +01:00
Ask Solem
5eac1a8643
Adds Anton Gyllenberg to AUTHORS
2011-01-29 13:32:33 +01:00
Anton Gyllenberg
7e51ce301a
Correctly pass properties to amqp.Message()
...
Fix transport.pyamqlib.Channel.prepare_message() to correctly
pass properties to amqp.Message(). amqp.Message() takes properties
as separate keyword arguments. Before this fix, prepare_message()
passed the properties as a dict in a single argument 'properties',
which was ignored by amqp.Message().
This issue has serious consequences. For example, as the 'delivery_mode'
property is dropped, all messages will be transient even if the documented
default is persistent and even if 'delivery_mode' is explicitely set
to persistent.
2011-01-29 08:47:33 +02:00
Ask Solem
572e709f9c
Documentation fixes
2011-01-28 22:45:20 +01:00
Ask Solem
a9b53e89bc
Fixed typo client -> c
2011-01-28 20:31:12 +01:00
Ask Solem
c39bf4606c
Bumped version to 1.0.1 and updated Changelog
2011-01-28 20:28:39 +01:00
Ask Solem
45e0086aed
Redis: Adds missing method _handle_message
2011-01-28 15:45:51 +01:00
Ask Solem
495fd9cba4
epoll.poll timeout can't be None, use -1 for infinity
2011-01-28 12:34:07 +01:00
Ask Solem
b7b625e0d8
eventio.epoll: Don't convert None to float
2011-01-28 11:49:10 +01:00
Ask Solem
008624b788
with Consumer() now works
2011-01-27 15:26:23 +01:00
Ask Solem
8cebb41955
Added connection.Pool.acquire_channel context manager.
2011-01-27 15:22:43 +01:00
Ask Solem
33a4a8579b
Version 1.0.0
2011-01-27 11:46:50 +01:00
Ask Solem
9bcbdd7977
PEP8ify
2011-01-27 11:46:29 +01:00
Ask Solem
56aa7fa21b
Load kombu root module lazily
2011-01-27 11:40:47 +01:00
Ask Solem
9c17749769
Import SimpleQueue/SimpleBuffer lazily
2011-01-27 11:40:30 +01:00
Ask Solem
b9a0b59590
kombu.utils.blocking renamed -> kombu.syn.blocking
2011-01-27 11:40:15 +01:00
Ask Solem
a92d125f09
Fixed typo __init___ -> __init__
2011-01-26 13:10:26 +01:00
Ask Solem
936ea9f5f1
epoll: Ignore socket.errors on _epoll.unregister
2011-01-26 13:03:44 +01:00
Ask Solem
5d4110190d
Tests passing on Jython
2011-01-25 13:54:59 +01:00
Ask Solem
3f28abcb58
gevent: Make sure synchronous calls are blocking
2011-01-25 12:54:22 +01:00
Ask Solem
4b50b6ba38
PEP8ify
2011-01-25 12:38:03 +01:00
Ask Solem
7aa313f61d
Added autodoc for librabbitmq transport
2011-01-25 12:37:56 +01:00
Ask Solem
2774c4c672
eventio: epoll timeout is float not ms
2011-01-25 12:33:45 +01:00
Ask Solem
4f4b872d05
Added librabbitmq transport (requires librabbitmq-c + pylibrabbitmq)
2011-01-24 13:40:34 +01:00
Ask Solem
f52511289a
The bz2 module does not exist on Jython
2011-01-23 14:28:05 +01:00
Ask Solem
499a6445eb
Added compiled jython files to gitignore
2011-01-23 14:27:52 +01:00
Ask Solem
60fad47bd9
Eventlet: Make sure synchronous methods are blocking
2011-01-23 01:51:01 +01:00
Ask Solem
529cb0fc33
Last change made test invalid
2011-01-21 12:19:18 +01:00
Ask Solem
2d08e34e50
virtual: must continue draining events even if no channels (yet) registered
2011-01-21 10:27:41 +01:00
Ask Solem
9689ea75af
rst in README was broken
2011-01-21 10:13:10 +01:00
Ask Solem
025f5fda3e
README.rst can't contain unicode (because of PyPI upload)
2011-01-20 12:20:16 +01:00
Ask Solem
0137df7f73
Bumped version to 1.0.0rc3
2011-01-20 12:19:13 +01:00
Ask Solem
f609fb1621
Ignore autodoc for kombu.utils.eventio
2011-01-20 12:18:27 +01:00
Ask Solem
67fc107396
Cleanup
2011-01-20 12:17:24 +01:00
Ask Solem
ab9f5eec51
Passes all tests again
2011-01-20 12:01:40 +01:00
Ask Solem
f16621fe8f
Merge branch 'master' into redis_epoll_consume
2011-01-19 21:20:15 +01:00
Ask Solem
27983aa776
Tests passes again. Thanks to salmon_
2011-01-19 13:44:39 +01:00
Ask Solem
501669fed3
amqplib: Set connection.client
2011-01-18 21:39:56 +01:00
Ask Solem
eab0680398
conn.SimpleQueue/SimpleBuffer: Pass kwargs
2011-01-18 21:39:06 +01:00
Ask Solem
d199df249c
Cosmetics
2011-01-18 21:38:09 +01:00
Ask Solem
9f7f71f586
kqueue accidentally disabled
2011-01-18 12:03:38 +01:00
Ask Solem
df265a49aa
remove left-over print statement
2011-01-18 11:53:38 +01:00
Ask Solem
65f1174d83
Redis: Consume now works with Eventlet
2011-01-18 11:52:59 +01:00
Ask Solem
1ade2c8d2b
Cleanup
2011-01-18 11:09:58 +01:00
Ask Solem
2cb7c11a59
Added transport comparison table
2011-01-18 09:20:13 +01:00
Ask Solem
abd25e9dca
Redis: Improved solution to drain_events (no longer needs threads), and using PUBLISH/SUBSCRIBE for broadcast exchanges!
...
Using epoll/kpoll/select to poll several Redis connections at once instead
of having one thread for each channel.
These changes drastically improves the responsitivity of both store-and-forward and
broadcast messaging using Redis. While the previous solution could have a
latency of 1 second per message, this solution can receive broadcast command
and send reply in ~0.006 seconds (~realtime)
2011-01-17 16:33:58 +01:00
Ask Solem
08ee10243b
FairCycle.get: Forward kwargs to callback
2011-01-17 16:33:35 +01:00
Ask Solem
8b09417dff
Keeps track of active_queues, instead of generating it need
2011-01-17 16:32:57 +01:00