github.com/celery/py-amqp commits | Ecosyste.ms: OpenCollective

Make sure everything is cleaned up at Channel._do_close

c51bb564fcf373c4b66d8ba7a46446523218ce60 authored over 12 years ago

Support for publisher confirms

cc27c100a4929dcac43ca0ee7fc85ccb5decb7ce authored over 12 years ago

Updates Changelog

4bc156eacb6f53c48300d519b415d19b0d3937a4 authored over 12 years ago

Removes internal argument to exchange_declare

323136930db86f2920c89f67c87037ee39ff2762 authored over 12 years ago

out_of_band is deprecated

7d6525570fcd7c75e9b26df19a8a696163d1347e authored over 12 years ago

Removes Connection insist argument

06b37526b0fa4aab4eb2202c13356c7826ff0dbe authored over 12 years ago

Removes Channel alerts (removed in 0-9-1)

ebec35f6fb162a9578c46b49a223a54dadf4845b authored over 12 years ago

Adds basic_recover_async and _basic_recover_ok

c41ae7f19c5249fc540f8948948b754c1f0766ba authored over 12 years ago

basic_recover is now (60, 100) per 0-9-1

7ba61fb2e30fba58ee0c2df87c3c156567a334d4 authored over 12 years ago

Now emits DeperecationWarning if auto_delete enabled for exchange

dee54b0092cc76af4e10ce68468e15d9ae3a2899 authored over 12 years ago

Removes Connection.known_hosts (removed in amqp 0-9)

c829b36f5d0350d2cbda1969639b9402cc5b0e65 authored over 12 years ago

Renames tests/ to funtests and passing

c594db2d7592beb79027f68c06cd4ba8ac538ce2 authored over 12 years ago

Adds Sphinx docs

f6a3b9d90373d26bcc489a1c0559b6015bfa2836 authored over 12 years ago

Adds requirements directory

42a0470071c6d59c2305674cf8c456d496579ee5 authored over 12 years ago

0-9: Channel/Connection can receive a Close while waiting for CloseOk

f9395ed21a20f79e9a356fb55a7a6f47eeeb9c4c authored over 12 years ago

exchange argument to queue_bind can be empty in 0-9 (default exchange)

85f7f407e05c59399f9f6e22cf388065d6b1780c authored over 12 years ago

No longer any need to loop in Connection.__init__

9f595a8ce2b3209e4f3907c026b9c25248978b76 authored over 12 years ago

Removes the Access domain and the ticket argument to channel methods

775a2ab809cf4b8d7e1edb931ef53fbb6ea239c0 authored over 12 years ago

Only send consumer_cancel_notify capability if server supports it

82923597870536bafe10aab8d0669fdff5c7f40b authored over 12 years ago

Use AMQP 0.9.1 + support for consumer cancel notifications

ff67e5ee32b6467f0ec5f94e2c6a5de61d58dc9e authored over 12 years ago

Adds Connection.is_alive, .sock, .connection_errors, .channel_errors

9b4124de31d26e2c5401fe2fd94ab4742e272095 authored over 12 years ago

Adds Channel.no_ack_consumers: List of consumer tags that set no_ack=True

2daa747c2e945d69b0bf74bba726827d0d5ad6d8 authored over 12 years ago

Make sure Channel.close deletes Channel.connection

60d9c4828e5767082f81fdc75a84076a5f682ccb authored over 12 years ago

Adds Connection.drain_events and support for basic_return

4733dcd3ec56b09c370c3cee58cf40b0f2d8d054 authored over 12 years ago

Ignore socket errors when connection already closed from remote

92e02cb977268fa20b60435e931648f7c9892ba6 authored over 12 years ago

Ignore errors in Transport.__del__

0cf0e04a4a102de9cac445867b2c75877d1eb3fe authored over 12 years ago

Heartbeat support

e70d17b297ddc07c3f5f7ca3db60c8e536f7c76e authored over 12 years ago

Remove channel from Message.delivery_info

cf2b319789a03444f466f8a0b67e6433f988a3a8 authored over 12 years ago

Cosmetics (PEP8, etc)

16e39bab355f12755df6c1b1cf4475332ad90c8a authored over 12 years ago

Adds .gitignore

3629a9c0f67c8b2469c8de25be7762884b24582a authored over 12 years ago

Rename to amqp

7ba49c08e9631521783a0c3302ac19c2fc6e184d authored over 12 years ago

Added tag 1.0.2 for changeset 124bd71678e2

86c96341e080b66caf470656e4c6a6b792b54d21 authored over 13 years ago

Bump the version number to 1.0.2 for the packing fix for Windows

cdf31a512d1a10b89dacd8129cc0428791f19b0b authored over 13 years ago

Fix Issue 42 having to do with installing on Windows

09f8ff82a8f81aed499e7735bb1ec0aebc82e58b authored over 13 years ago

Oops, forgot to document what was changed in 1.0.1

bd6027441bb94ac74b15b77f492f92a88ed7cecc authored over 13 years ago

Added tag 1.0.1 for changeset cf8638fcc5c1

e136c36e59751d56cfe7040af53b479128efe4ee authored over 13 years ago

Fix Issue 41 relating to a minor problem some older versions of FreeBSD have with socket.getaddrinfo()

e0bce4b01f406c5e451b77dba35d7f17a3284f54 authored over 13 years ago

Add MANIFEST.in, so that demos, tests, docs are included in the

source distribution. Fixes Issue 36 , thanks to [email protected]
for the report and the patch

0848fec4e152e25b9bc253094bc76c11c4e5bb9b authored over 13 years ago

Add more Trove classifiers to help packagers, bump the version number for the next release

b2921c2c73bc23c61ecb1a80c96f070cae86be37 authored over 13 years ago

Added tag 1.0.0 for changeset 59dc52a3c871

480cb7d13ada8bb2eee1d71b19f86e7fe2916219 authored over 13 years ago

Wrap this thing up, call it 1.0.0 in celebration of OSCON 2011

ac1468cf6b61e1c7fb3f5a63307d69061abb93f1 authored over 13 years ago

Fix Issue 35 , comparing a Message to something else (such as None), raises an AttributeError

instead of returning false. Thanks to [email protected] for reporting this.

0484a8aac65921758a2330f425b1f5d8e58b84cd authored over 13 years ago

Process basic_return methods from the server whenever they're received, rather than queueing them up and basically ignoring them unless the user called wait(). (Issue 29, thanks to [email protected] for bringing up the issue and providing a patch)

4e9e2a13f4ef0bce33019d7e8c6296cd42c504fb authored over 13 years ago

Enable TCP keepalive (Issue 32, suggested by [email protected])

3d1262b4ea8f385fb516aa4ecb0eeea6f2665e8f authored over 13 years ago

Enable TCP_NODELAY, gives a nice little 6x speedup of the unittests at least.

e6c5674192c183015a92002a21505fccc615e827 authored over 13 years ago

Shutdown a socket before closing it, to ensure pending transmissions aren't discarded. (Issue 30, thanks to [email protected] for pointing this out).

3f70e4b3a50fa3b43ea6971aee0970c86dad7b7e authored over 13 years ago

Add support for IPv6, supporting literal addresses or domain names with AAAA records.

246ea61f39d30a6b6671565dfc2f058334f570e9 authored over 13 years ago

Add support for queue_unbind, which is supported by RabbitMQ as an extension to the 0-8 protocol.

Thanks to Hasan Alayli <halayli@...> for a patch.

71bc7ba79f6e1ddeb311d7ac986a55f14446faf5 authored almost 14 years ago

Alter one of the unittests skipped over for Python 3.x so that it can run and check the behavior we want even in 3.x

8d54e73814ae3d3ebe44d02dbc0a0d2ab67f9d45 authored almost 14 years ago

Add patch from Viktor Naoumov <vnaumov@r...> adding the ability on Python >= 2.6 to specify a dictionary of SSL options to pass to ssl.wrap_socket(), sock as specifying a client cert, a CA cert, and requiring the ca cert match.

c51c727fd03b32fa8fb418880a8b73a39ca0f191 authored almost 14 years ago

Since encoding of unicode message bodies has now moved from happening at Message creation time to transmission time, move the setting of a default content_encoding message property to happen at the same time. So they're both late behaviors now, instead of one being early and one being late.

03681f18eff97184005fd8f1e4504c48eccfbc7b authored almost 14 years ago

Python 3.x compatibility - code has been tweaked so that when the 2to3 utility is run

against the client library and the unittests, the unittests pass when run on
Python 3.0, 3.1, and...

b75288fd9da92213cbaf04e0895ffe9360bd99a0 authored almost 14 years ago

Fix Issue # 15 http://code.google.com/p/py-amqplib/issues/detail?id=15

which kept Message objects from being able to be pickled/unpickled. Add a unittest to
check for ...

520afbda19981b9667cc744d86cd48d620a7a93e authored almost 14 years ago

Fix for Issue #17 where connections were silently dropped if an unserializable object was present in a Message's application_header. Now a ValueError is raised, and the Connection is not disrupted by sending an incomplete message.

b7879d45416d8dc6e2e43a534d3479eae1b2c1e6 authored almost 14 years ago

amqplib has never been threadsafe, and frequently discussed on the rabbitmq mailing list, but somehow never mentioned in the included docs.

62115f8983c404e6b7a0dc1c1972bdb0261fa667 authored almost 14 years ago

Update the README to point to rabbitmq.org's nice list of other Python clients.

bcb60af2bf29298d4f9a87fe45ee48a605b09315 authored almost 14 years ago

Use setuptools if available, for enhanced functionality for packagers.

e976dedf164051f8908ce32e8d878a212548e109 authored almost 14 years ago

Huge speed improvement for large messages, suggested by a patch from [email protected]

97792c96d42e07923b7c63f32d5fcc1a1cfbba1e authored almost 14 years ago

Bump up the version number so we can tell this from the last released version.

4ce8c0fe425430d420cee9ef183936e43b944d8a authored about 15 years ago

The serialization layer was making hardcoded assumptions about how

short strings were encoded (utf-8). Add 'encoding' parameters
to AMQPWriter.write_shortstr() and...

df41fa920546859156be21cd18abf29874721a13 authored about 15 years ago

Minor tweak to ensure the Channel class is included in pydocs, no real change

in the client's behavior.

5978ba8170f034dd765eb56fe423ef7085855ce7 authored over 15 years ago

Added tag 0.6.1 for changeset 1f05ed5c599f

68d1e3d58aaa1eb7429247ef5706b6f0a9be9bbf authored over 15 years ago

Final minor changes to docs and version strings for 0.6.1

5d9864a01ddf8c7dd4e1d54af89b34b2fab6b70a authored over 15 years ago

Close TCP sockets when there's an error connecting, to keep file descriptors

from piling up. Thanks todmitriy.samovskiy@... for pointing this out.

9d2b3b976fbcf1d024789f61fdccd0591cbd857d authored over 15 years ago

Fix minor typo in docs

92b441777a970ac4b56ee80bcec810db87edbec3 authored over 15 years ago

denis.bilenko@... pointed out a couple try/except blocks that catch too much,

potentially preventing stop operations like KeyboardInterrupt from working.

e4f1014608757c8e35fe213128e4216f51888074 authored over 15 years ago

Make it so that the upper levels see the exceptions raised by the lower levels,

instead of nonsense exceptions like:
TypeError: 'NoneType' object is not iterable
when somethi...

6a44de962cfc5b98d732438cd59ffeba2ce73eda authored over 15 years ago

Get rid of the __del__ methods in Connection and Channel classes, which

allows them to be garbage collectible if references to them are lost, because
they form a cycle, ...

5aa5dd1748a7996906a88e5ae9f72843e0de3c30 authored over 15 years ago

Add unittests provided by majek04@... checking that objects from this

module are garbage-collectable if references to them are dropped.

cfdd3c9c908b8d0e84d78a6063236ae93e6ef043 authored over 15 years ago

Add some documentation about using 'with' statements.

99f643bc20ea81276a4424f1a947a42a34a9053c authored almost 16 years ago

Add support for using Connection and Channel objects in Python 'with'

statements.

e59dea2fb7cea05271d5272020dcf4fb951b298d authored almost 16 years ago

Document the recent changes and change the version number so as not to be confused

with the original 0.6 version.

ab84707f32fbcfa77d3f669518da3a7626a2a324 authored almost 16 years ago

Fix problem with dangling reference loops after Connections close. Thanks

to majek04@... for pointing this out.

e62a99c91cbaf5d0c37a75389bae1de93c30ea68 authored almost 16 years ago

Make sure any while loops in the transport module raise IOError exceptions

if a socket can't be read from or written to. i Thanks majek04@... for
pointing this out.

8ffb0dd7ee8830e1b1cbea3b7b917c4d0682d355 authored almost 16 years ago

Added tag 0.6 for changeset dbf98c6e962a

b61955af16678edf63534a1920890ce57d9e14cc authored about 16 years ago

Temporarily remove the thread-related development code, so the rest of

the improvements can be packaged as a new release.

c7d922ef95defe68c17311e5319295408f80a722 authored about 16 years ago

Polish up the docs a bit, including a warning to be sure to

close Connection or Channel objects otherwise you could
lose messages when the program ends.

3924e8241dcaee7a596d55501879a7b7e9e62674 authored about 16 years ago

Have the Connection initializer actually behave the way the docs

have implied for a long time - supplying default values for host
(localhost) userid and password ...

c7b341621f91e43da2ec2095654ec24296d5356f authored about 16 years ago

Combine the two different SSL transports, turns out they're not that different.

15b83e9f8e9785d4915cfca122af789d94c52c35 authored about 16 years ago

Add support for Python 2.6's ssl module, without this the

interpreter issues a deprecation warning if you make an SSL connection.

48e31ec9f125803736b10b2c029e5da04fcd7005 authored about 16 years ago

SSL support was broken, and also the new unittest for large messages

found a problem with large messages over SSL. Fixed both.

0ca0d8e7434fd0b5f7836947a2e1591ee9ec4e56 authored about 16 years ago

A little pylint cleanup, add a unittest for sending large messages

(with bodies of about 1.6K, 16K, and 160K bytes).

9b5ee6c9dea9d55573903cedc80c16190145fd80 authored about 16 years ago

Send frames to the TCP socket with a single call instead of 3, this small change

causes the unittests to run over 2x faster on my laptop.

5c2eccfe652dfad9d5122c01af381a57a5d6d693 authored about 16 years ago

Get rid of unused code, you can't really flush a TCP socket.

5921633b18a254be101d78e08d5d4f4b5130314b authored about 16 years ago

Fix problem reported by Brian Sullivan, where AMQP channel exceptions were

not being thrown, but instead queued up for later - which does no good.

d725854fc63930cfbc72ae82095e13fa556e77e3 authored about 16 years ago

Move lowest-level networking code into a separate module, untangling

it from the connection and serialization modules.

737fa589bfdea60d158ecceb8d388b0aba1a9164 authored about 16 years ago

Get rid of unused logging code.

51fd961b4929884f584d518f26e94ea14136e842 authored about 16 years ago

Remove unused array.

976173bdc61f2b6242b62d5bb7a81ab3f92c6a40 authored about 16 years ago

Need to add another item to setup.py for this to actually build and install.

f07bb0fd1db9149b09e8c37c20b8e119fad29e0b authored about 16 years ago

Show in the diagram, what exactly is flowing between

the various layers.

aa2f644ad1d6f0258ae704c4b95b89f8eac2102e authored about 16 years ago

Add a document describing how the Python code is arranged, for people interested

in hacking on it. Mention the use_threading option in the Connection constructor.

1e6786a8b7288b4d49c441739d4a22bcc099f13d authored about 16 years ago

Reorganize unittests, dividing them up into modules that correspond

with the various client_0_8 modules. Add a run_all.py script to
run all the unittests.

16507ca8e11a64dd36a01678b8bd7e06ba7b6cfe authored about 16 years ago

Pylint cleanup

7ba8ea4947a3d6bca898426852fc205935e304da authored about 16 years ago

Rename method.py to method_framing.py, which is a more descriptive name.

--HG--
rename : amqplib/client_0_8/method.py => amqplib/client_0_8/method_framing.py

62919f4de18b11bbbad57138316fcf6b1072bccb authored about 16 years ago

Combine two methods that no longer need to be separate.

ce5b0e83f7dbc68836c40ce930f94573c0d66c2b authored about 16 years ago

Fix a problem where deferred content methods would not have their bodies decoded

because a different path through wait() would be followed.

5fce558fadca9fc2165c54a67ca2294aaf7738ca authored about 16 years ago

Work on flow control, handling returned messages. Some minor cleanup too.

f1d51f7a37d30e2d724b03bae19239b3eb1704da authored about 16 years ago

The timeout for a wait() call should not be passed straight through

to a MethodReader.read_method() call, it may need to be adjusted
because read_method() may be cal...

73c9f745a70518aa3a950c3b82f02791b3b37b8f authored about 16 years ago

Provide a link to txAMQP in the README file

99bc3308ece98057f0f07ac8ba0a499aad3b47f1 authored about 16 years ago

Very minor comment cleanup.

c533c728f747434b5179fa4b57bfdd8522851ac9 authored about 16 years ago