summaryrefslogtreecommitdiff
path: root/qpid/python
Commit message (Collapse)AuthorAgeFilesLines
...
* File rename to better fit the pubsub nomenclature (from jrobie@redhat.com)Gordon Sim2007-12-192-25/+15
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@605599 13f79535-47bb-0310-9956-ffa450edef68
* patch from tross Carl C. Trieloff2007-12-143-18/+68
| | | | | | | | | | | QPID-706 Added implementation for the "Call" command to invoke methods on management objects. Fixed a bug in qpid/management.py caused by replies to methods with no arguments. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@604286 13f79535-47bb-0310-9956-ffa450edef68
* set executable propertyAlan Conway2007-12-111-0/+0
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@603242 13f79535-47bb-0310-9956-ffa450edef68
* Patches from Ted Ross <tross@redhat.com>Alan Conway2007-12-105-60/+1294
| | | | | | | | | | | | | | | | | | | QPID-697 Fixed access-rights constants for management schema. Added mutex to fix problems associated with concurrent invocation of accessors for queue statistics. Removed queue schema content that is not relevant to QPID. QPID-698 This patch creates a new subdirectory in python called "mgmt-cli". python/mgmt-cli/main.py can be executed from the shell. If no arguments are supplied, it attempts to connect to the broker at localhost:5672. The first argument is the hostname for the target broker and the second (optional) argument is the TCP port (defaults to 5672). It is assumed that the AMQP spec file is in the following location: /usr/share/amqp/amqp.0-10-preview.xml It is also required that the qpid/python directory be in the PYTHONPATH environment variable. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@603034 13f79535-47bb-0310-9956-ffa450edef68
* Reversed renamingGordon Sim2007-12-058-0/+0
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@601467 13f79535-47bb-0310-9956-ffa450edef68
* Renamed for consistency with c++Gordon Sim2007-12-058-0/+0
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@601394 13f79535-47bb-0310-9956-ffa450edef68
* Updates to examples from jonathan.robie@redhat.comGordon Sim2007-12-058-29/+18
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@601358 13f79535-47bb-0310-9956-ffa450edef68
* removed warnings on duplicate constants, the issue will go away with 0-10 finalRafael H. Schloming2007-12-041-1/+2
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@601112 13f79535-47bb-0310-9956-ffa450edef68
* Python examplesAlan Conway2007-11-3010-0/+782
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@599876 13f79535-47bb-0310-9956-ffa450edef68
* new fileArnaud Simon2007-11-271-0/+95
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@598684 13f79535-47bb-0310-9956-ffa450edef68
* Additional test covering the current hack for no-local used on exclusive queuesGordon Sim2007-11-161-0/+42
| | | | | | | | Additional check to second not-acquired test, asserting that messages aren't consumed git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@595636 13f79535-47bb-0310-9956-ffa450edef68
* QPID-687: comitted qpid-patch7-python.diff for real this time.Alan Conway2007-11-152-74/+190
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@595465 13f79535-47bb-0310-9956-ffa450edef68
* Fix to auto-rollback which didn't do what it was supposed to (i.e. rollback ↵Gordon Sim2007-11-151-3/+24
| | | | | | | | | | a session ended with an open transaction) Fix to rollback to stop flow for subscriptions before the rollback, and restart after. This prevents any out of order delivery as rollback requeues the messages and will be redundant once QPID-686 is fixed. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@595244 13f79535-47bb-0310-9956-ffa450edef68
* Get rid of basic_publish, no longer supported by c++ broker.Alan Conway2007-11-091-2/+2
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@593693 13f79535-47bb-0310-9956-ffa450edef68
* python API updatesRafael H. Schloming2007-11-074-45/+85
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@592927 13f79535-47bb-0310-9956-ffa450edef68
* Fix for QPID-639: c++ now includes sizes for all structs (enabled the same ↵Gordon Sim2007-11-071-2/+2
| | | | | | in python & java) git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@592895 13f79535-47bb-0310-9956-ffa450edef68
* added factory for structs, and made default spec loading based on AMQP_SPEC ↵Rafael H. Schloming2007-11-074-11/+44
| | | | | | environment variable git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@592888 13f79535-47bb-0310-9956-ffa450edef68
* Fix to QPID-640. The fields actually set/encoded are now tracked explicitly.Gordon Sim2007-11-071-1/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@592753 13f79535-47bb-0310-9956-ffa450edef68
* updated pack param, however nothing was broken because first param is 0Kim van der Riet2007-11-061-1/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@592556 13f79535-47bb-0310-9956-ffa450edef68
* Add support for array type to c++ (and python, decode only for now)Gordon Sim2007-11-063-12/+61
| | | | | | | | Change the type of the in-doubt field in dtx-coordination.recover to an array (to bring in line with amqp spec) git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@592494 13f79535-47bb-0310-9956-ffa450edef68
* applied patch from tross posted in QPID-666Rafael H. Schloming2007-10-292-2/+227
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@589889 13f79535-47bb-0310-9956-ffa450edef68
* Added empty stub in client.py for handling session acksKim van der Riet2007-10-291-0/+3
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@589711 13f79535-47bb-0310-9956-ffa450edef68
* Additional testing of subscriber in not-acquired modeGordon Sim2007-10-251-5/+34
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@588287 13f79535-47bb-0310-9956-ffa450edef68
* Fixed return of acquired message ranges (and added tests)Gordon Sim2007-10-181-2/+10
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@585952 13f79535-47bb-0310-9956-ffa450edef68
* Fix to headers exchanges bind: need to check the match value is present ↵Gordon Sim2007-10-171-0/+8
| | | | | | | | | | before dereferencing Added tests for this. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@585503 13f79535-47bb-0310-9956-ffa450edef68
* Implementation of 0-10 field tablesAndrew Stitcher2007-10-162-5/+7
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@585097 13f79535-47bb-0310-9956-ffa450edef68
* Remove default queue concept which is no longer applicable in 0-10.Gordon Sim2007-10-151-5/+2
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@584719 13f79535-47bb-0310-9956-ffa450edef68
* Enabled packed struct encoding in python, cpp, and java. Also fixed ↵Rafael H. Schloming2007-10-148-45/+170
| | | | | | computation of required byte credit in Message.cpp. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@584474 13f79535-47bb-0310-9956-ffa450edef68
* whitespace cleanupRafael H. Schloming2007-10-111-6/+6
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@583908 13f79535-47bb-0310-9956-ffa450edef68
* Exclusive no longer implies auto-delete on queue.declare.Gordon Sim2007-10-116-69/+69
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@583821 13f79535-47bb-0310-9956-ffa450edef68
* Ensure recovered messages have the redelivered flag setGordon Sim2007-10-111-0/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@583740 13f79535-47bb-0310-9956-ffa450edef68
* Additional tests and fixesGordon Sim2007-10-041-0/+23
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@581957 13f79535-47bb-0310-9956-ffa450edef68
* Added test for ordering of released messagesGordon Sim2007-10-041-0/+24
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@581880 13f79535-47bb-0310-9956-ffa450edef68
* Fixed recovery; unacked message records are now updated to hold the new ↵Gordon Sim2007-10-021-0/+46
| | | | | | | | | | command id when messages are resent. Added unit and python test as previous bug was not being picked up by the existing tests. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@581175 13f79535-47bb-0310-9956-ffa450edef68
* issue execution_sync rather than execution_flush prior to waiting for completionRafael H. Schloming2007-09-271-3/+3
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@580123 13f79535-47bb-0310-9956-ffa450edef68
* added support for 0-10 field table encodingRafael H. Schloming2007-09-273-23/+87
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@580122 13f79535-47bb-0310-9956-ffa450edef68
* Change to start execution mark at -1Gordon Sim2007-09-261-8/+12
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@579559 13f79535-47bb-0310-9956-ffa450edef68
* Moved c++ over to using the same preview file for 0-10 work as java.Gordon Sim2007-09-213-8/+14
| | | | | | | | | | Removed all channel class related code from broker as a result. Did the same for some python tests I missed earlier. Renamed ChannelAdapter to ChannelHandler. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@578167 13f79535-47bb-0310-9956-ffa450edef68
* Use octet each for class and method id (changed c++ and python)Gordon Sim2007-09-2113-71/+72
| | | | | | | | | | | | | | | | | | Modified indexes in xml for message.empty, message.offset and the c++ cluster class Fixed encoding for rfc1982-long-set in c++ and python (its a size not a count that is prepended) Fixed minor typo in configuration option help string Use session.open/close in python tests, handle session.closed Commented out the response tag in session.close due to pythons ambiguity as to whether session.closed is a response or not Disabled broker.test_closed_channel (due to above issue); broker behaves as expected but test fails; test_invalid_channel is safe enough for now. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@578053 13f79535-47bb-0310-9956-ffa450edef68
* Fixed (il)logic in timeout management when waiting for completion.Gordon Sim2007-09-191-2/+2
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@577321 13f79535-47bb-0310-9956-ffa450edef68
* Added routing key for more readable logs.Alan Conway2007-09-191-1/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@577295 13f79535-47bb-0310-9956-ffa450edef68
* made testlib use session_open for 0-10Rafael H. Schloming2007-09-181-1/+5
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@576873 13f79535-47bb-0310-9956-ffa450edef68
* Use frameset begin/end flags for determining frameset boundaries.Gordon Sim2007-09-131-1/+16
| | | | | | | | Set frameset & segment begin/end flags for content bearing methods (i.e. messages). git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@575377 13f79535-47bb-0310-9956-ffa450edef68
* In ClientChannel: Use subscribe and flush in place of get; use ↵Gordon Sim2007-09-129-52/+58
| | | | | | | | | | per-subscriber flow control for managing prefetches. In brokers Session: set credit to 0 when subscription is created (modified python tests accordingly) git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@574979 13f79535-47bb-0310-9956-ffa450edef68
* * Python: reinstated 0-8 framing in parallel with the new 0-10 framingAndrew Stitcher2007-09-121-3/+33
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@574936 13f79535-47bb-0310-9956-ffa450edef68
* * python/qpid/codec.pyAndrew Stitcher2007-09-122-4/+26
| | | | | | | | | | | | | | | | | Comment typo * cpp/src/qpid/broker/RecoveryManagerImpl.cpp Cruft removal * python/qpid/codec.py * python/qpid/connection.py * cpp/src/qpid/framing/AMQFrame.h * cpp/src/qpid/framing/AMQFrame.cpp Initial implementation of 0-10 framing - This uses the new 12 byte frame header, but doesn't support splitting segments/framesets over multiple frames yet. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@574735 13f79535-47bb-0310-9956-ffa450edef68
* Initial implementation (plus very simple tests) of message.acquire, ↵Gordon Sim2007-09-034-8/+75
| | | | | | message.release, message.reject and message.flush. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@572394 13f79535-47bb-0310-9956-ffa450edef68
* Fix for QPID-561Gordon Sim2007-09-031-1/+1
| | | | | | | | Renabled MessageBuilderTest git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@572264 13f79535-47bb-0310-9956-ffa450edef68
* Updated message.transfer encoding to use header and content segments ↵Gordon Sim2007-08-2814-863/+165
| | | | | | | | | | (including new structs). Unified more between the basic and message classes messages. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@570538 13f79535-47bb-0310-9956-ffa450edef68
* removed extraneous whitespaceRafael H. Schloming2007-08-231-21/+21
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@569134 13f79535-47bb-0310-9956-ffa450edef68