Ecosyste.ms: OpenCollective
An open API service for software projects hosted on Open Collective.
github.com/celery/py-amqp
amqplib fork
https://github.com/celery/py-amqp
939b93fb88868c6a055fcab20b9d27897dd671e1 authored about 16 years ago
41ca384dc4535eafe477ba37c523df58320f110c authored about 16 years ago
when the user imports this library, or generates Pydocs.
081e85c4bab8d5964a1b9626598d6c56e5561970 authored about 16 years ago55550870f9eb94d8be77883a741b73d301d168fe authored about 16 years ago
41665e52ed0744cb86b4daab8179312acd623e11 authored about 16 years ago
34dd9e40a6874c1091fe7c3456457ed52e237684 authored about 16 years ago
the various layers, instead of a huge monolithic client.
--HG--
rename : tests/fake_redirect_0_8...
about the Queue.Empty exception.
b1294639f4948ea24b8e4bd5d7567a086516bd58 authored about 16 years ago279b41bcdc8da21d915bbbcca160d26fe6c4ecb7 authored about 16 years ago
has changed so much, and now has its own nonblocking feature.
4a08781ba07e87c10355c166cd6ef0099c76ad9e authored about 16 years agotimeout is not supported.
281a8977d7c12e3b0ff663bed774a174421a2aea authored about 16 years agofe6a306bc7b913a1bb5d8599502e6435eb48e6e1 authored about 16 years ago
run either single-threaded or with a helper thread.
--HG--
rename : amqplib/threaded_client_0_8....
db13c40bae1b7074813e08cc41aa1b3c5184b5a5 authored about 16 years ago
when the Connection is created.
77007b0c5f3da6c8c154c26ba12d053e9efe9ade authored about 16 years agoup a fair amount.
fd7be5b5703f2c97909df089e74505f5ad8085c5 authored about 16 years agowith the rest of the serializing/deserializing code.
38ed033d34406d8a6c6a053445a254c7023fd590 authored about 16 years agoa7b1e77586c49a88d7b70cf18e416fe72be6e1e7 authored about 16 years ago
is responsible for joining together the frames that make up content
methods - and what gets put i...
waiting for messages - and potentially support for flow-control.
766805bb410327ca7aab90edf1e1fdcc0a2639f6 authored about 16 years agocycles to allow garbage collection. Thanks for majek04@... for pointing
this out and generating ...
was originally generated from the spec file. The text was taken from
a different part of the spe...
instead of %s, because what it's printing may be binary data.
Thanks to majek04@... for the sugge...
9b59efc59a5cf29d7115261de25fd890099083ef authored about 16 years ago
demo, so as not to be confused with an exchange type.
c46d7fc602e932a25dde53dbc37312926b79b03a authored about 16 years agonot working with Python 2.4)
444ef4b8cdcaafa9ec33de12994b2f3a1f84129b authored over 16 years agowith older Pythons, don't use super() to call the superclass initializer for
AMQPException. Than...
small glitches.
52d7aaf1bc236a16ba30216b71542b31f355d9c0 authored over 16 years ago35468b9ed669ee4656b38e3a66e68b8cd51f0437 authored over 16 years ago
20c6ca32c2a86c4f027c80615b2c316387a20d74 authored over 16 years ago
to do some profiling to see if there were any bottlenecks, and found a huge
one due to misuse of ...
I had run and passed.
8cf84fd2b1e6944750ac7d7088d54733844278bf authored over 16 years agoe137424a358f2b8097bfb3ef81edec0f4325d85e authored over 16 years ago
if we can't close the old connection cleanly.
2409b818f0033510df0d7b46f2e366f63507305b authored over 16 years agoin Python 2.5 or higher. Thanks to Alexey Timanovsky for
pointing this out.
dee5df4fc04aa111f1862e28994942e09a3bf92c authored over 16 years ago
27293be1d67b74a0515c4887b7cc004efc62d49a authored over 16 years ago
frames/methods/messages are waited for and dispatched. Got
the inspiration from how Erlang's pro...
540b22d717f83e5c6dd6cc4ee15a6978285aae03 authored over 16 years ago
classes - by waiting until after the connection is made before putting
the socket into non-blocki...
with other modules.
93acf556b3e1b8c083aa6c8da564fc69c96246ab authored almost 17 years agoDmitriy Samovskiy <[email protected]>:
-----------------------
We put together an...
e2fdf63ee7891c6e6795b9cb8d50dfaa5629f2d3 authored almost 17 years ago1204a0063efb88218164c18279fd6efb54284e52 authored about 17 years ago
7a85d61fbfb3aacf475bee764c6c5913b6d69547 authored about 17 years ago
with that method being called with no callback argument
by quietly consuming the messages.
out of the spec file to put into Python docstrings.
Also make better use of textwrap module to re...
c7d949b2451bdd6b8f3441ffd714d2f9398d257c authored about 17 years ago
in the client module itself.
a6e18a641488f9474ff3ccd77612835b18edf859 authored about 17 years agothe last queue declared, and some can take an empty exhange name
meaning a default direct queue t...
66cc1fa76f7b8e23deeef52aa7ce6eea4e3393ce authored about 17 years ago
on the semantics of methods and parameters that was
present in the spec file.
the generated docstrings.
263716a47bd36997ae0854465ffd21a63e23aa4e authored about 17 years agoelements from the AMQP spec.
bd1bc8bbcafbf6fc70eab4a31d96a31517c05930 authored about 17 years ago54d302ec6af2fcdb27167c88450efaf79a93c248 authored about 17 years ago
94cc1bd6403bc2a2f85622a70e7debbb181adc1b authored about 17 years ago
babb188e1af2a6cec331a563b02a3717f00c6205 authored about 17 years ago
connections to another AMQP server. Made one small change to
the client_0_8 module to make redir...
to default to True. I found that declaring a queue and binding it
to an active exchange, and for...
a server. Need to find a way to actually test it, but at least
it doesn't interfere with a norma...
that you don't want to be redirected) available when creating the
Connection object. (Support fo...
5794dd6d3d5ee8b46e1d59f3ec0c6866e81acfe5 authored about 17 years ago
a13f350c2da49c98b00d1a36b7807aa37158f16c authored about 17 years ago
74d4deae11b124b60b2fda3f804a35f72bf23272 authored about 17 years ago
at regular intervals.
4fae632c55f2b74cc29dd443bc6c017b666b46f5 authored about 17 years agoif possible - but each channel has an 'auto_decode' attribute that
can be set to False to disable...
as Python exceptions. Put a hack in to make this work, but the
whole area of processing incoming...
instead of None, because AMQP doesn't distinguish
between a zero-length body and something else l...
4350c68ca32b8d24c8bab38d3fea07280d178893 authored about 17 years ago
889dd825f1370c2e8883809dae45d07e61a037a3 authored about 17 years ago
the repository - remove it and add a README
saying where to get it and how to use it.
messages to 'delivery_info', which seems like a better name.
When comparing messages, don't cons...
1fddf48d35c5d5a24a7cf15a23993e1b248d2b0d authored about 17 years agob03cedb483ff5c94ce384a80ca6ac134ef504e58 authored about 17 years ago
and putting the properties into a dictionary and storing
that dictionary as an attribute named 'p...
added to received messages.
a1a16bf876616dc722073f49cb70d28d40897493 authored about 17 years agoiterate over just the AMQP basic-content message properties.
18856eb87f750fe32646cfb3a1da1a06576f4f69 authored about 17 years agois still the same.
298f80e0f5d99da6d66cf9e75267bf9bd8884fcd authored about 17 years agoaway with the 'properties' dictionary attribute, and placing
the properties right into the object...
Restore raising of exceptions when the server closes a channel or connection.
e1a3a9df54f57f877bba5d2d764e3100757cac1d authored about 17 years ago8c5a5a4d8f1d9c7f1ec09e5e534267cbaed591a2 authored about 17 years ago
The whole issue of timezones is a PITA.
270328c38997dea4e9f16d4566db7a9daf8663be authored about 17 years agoturned out to be broken, and fixed that.
d6e2e30cf60aa1c51789661a2e0c93206796bc4d authored about 17 years ago1177133df7ad3f5c390cf5ad9039229e8aea164f authored about 17 years ago
d800563c0bf09fbe19adceed8fcf47516e90edf8 authored about 17 years ago
be874d9cddd3b5d515ea5483538ee36d263b2ec3 authored about 17 years ago
13b1212e2c6727f48d01ec0f71539bc84b87b411 authored about 17 years ago
--HG--
rename : demos/demo_receive.py => demo/demo_receive.py
rename : demos/demo_send.py => dem...
0b01eb845e955e98ef6885906fa477603d563c17 authored about 17 years ago
8a603ebdc41118ec0b4f71d8fd27f4cb5ad9ee66 authored about 17 years ago
of a few things to help with future migration.
f3f5fa3537efadd183ab530acc9999c3b96730d5 authored about 17 years ago4c6f5769412a340517375e258eea5d5cfee45124 authored about 17 years ago
2bdb19980ee5d9cb60101ef401c36f665ebbfebe authored about 17 years ago
ones are 'public', and which are more internal - that shouldn't
show up in pydoc and such.
I can't really test or support at this time. Can always be
added back in later from the skeleton...
semi-hidden. They're already in another module than what the
library users will usually be using.
it's going to be pretty spec-specific.
--HG--
rename : amqplib/util.py => amqplib/util_0_8.py
Python packages like 'smtplib', 'imaplib', ..
--HG--
rename : amqp/__init__.py => amqplib/__init...
args and building up the login info dict if necessary.
11dc31e272a0dcd11a9e06697dbba0dd53dacef0 authored about 17 years agothem together as a tuple and call it method_sig.
When waiting for frame methods, allow for speci...
10b9c7d2342d16c2e4bd57a9cc2aa8e9dbb332f6 authored about 17 years agothe specs use.
3908f2b61b07ebeb93947423b1cc7e60ff5983e4 authored about 17 years agothe list of basic-content-properties are organized.
9699867e0ff24052e81ce6c699000c246b35418e authored about 17 years ago