summaryrefslogtreecommitdiff
Commit message (Collapse)AuthorAgeFilesLines
...
* Merged revisions 494553 via svnmerge from Alan Conway2007-03-130-0/+0
| | | | | | | | | | | | | | https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid ........ r494553 | cctrieloff | 2007-01-09 15:15:52 -0500 (Tue, 09 Jan 2007) | 4 lines code gen part of last change. requires bootstrap ........ git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@517826 13f79535-47bb-0310-9956-ffa450edef68
* Recorded merge of revisions 494540 via svnmerge from Alan Conway2007-03-130-0/+0
| | | | | | | | | | | | | | | https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid ........ r494540 | cctrieloff | 2007-01-09 14:44:50 -0500 (Tue, 09 Jan 2007) | 5 lines Most of remaining version changes for C++. Still need to deal with AMQFrame defualt constructor and do some clean up here and there.. ........ git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@517824 13f79535-47bb-0310-9956-ffa450edef68
* Merged revisions 493126-493151 via svnmerge from Alan Conway2007-03-094-7/+11
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid ........ r493126 | aconway | 2007-01-05 13:34:08 -0500 (Fri, 05 Jan 2007) | 2 lines Add refernece to prereqs in README-dist. ........ r493140 | aconway | 2007-01-05 14:09:10 -0500 (Fri, 05 Jan 2007) | 8 lines 2007-01-05 Jim Meyering <meyering@redhat.com> * gen/Makefile.am (gen-src.mk) [CAN_GENERATE_CODE]: Emit an empty dependency for each generated file, in case they are renamed, removed, or no longer generated. Otherwise, "./bootstrap --build" would fail with e.g., `*** No rule to make target ../../gentools/templ.cpp/AMQP_HighestVersion.cpp.tmpl'. ........ r493151 | aconway | 2007-01-05 14:25:32 -0500 (Fri, 05 Jan 2007) | 6 lines 2007-01-05 Jim Meyering <meyering@redhat.com> * lib/broker/Makefile.am (libqpidbroker_la_LIBADD): Define, so we link with libqpidcommon.la. * lib/client/Makefile.am (libqpidclient_la_LIBADD): Likewise. ........ git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@516489 13f79535-47bb-0310-9956-ffa450edef68
* Merged revisions 492756 via svnmerge from Alan Conway2007-03-094-29/+18
| | | | | | | | | | | | | https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid ........ r492756 | kpvdr | 2007-01-04 16:30:39 -0500 (Thu, 04 Jan 2007) | 1 line Fixed C++ client sending protocol version 0-0 over the wire. Minor fixes and tidy-up in related code. ........ git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@516485 13f79535-47bb-0310-9956-ffa450edef68
* Merged revisions 492641 via svnmerge from Alan Conway2007-03-090-0/+0
| | | | | | | | | | | | | https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid ........ r492641 | aconway | 2007-01-04 12:06:38 -0500 (Thu, 04 Jan 2007) | 2 lines Removed unused qpid/ subdirectory. ........ git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@516460 13f79535-47bb-0310-9956-ffa450edef68
* Merged revisions 492636 via svnmerge from Alan Conway2007-03-091-10/+5
| | | | | | | | | | | | | | https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid ........ r492636 | aconway | 2007-01-04 11:55:03 -0500 (Thu, 04 Jan 2007) | 3 lines Added "make check" to -build flag. Removed rpm build directories from svn. Create them during make. ........ git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@516459 13f79535-47bb-0310-9956-ffa450edef68
* r1278@fuschia: andrew | 2007-03-08 19:42:43 +0000Andrew Stitcher2007-03-082-4/+15
| | | | | | | | Correctly split reference messages into chunks shorter than the framesize git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@516157 13f79535-47bb-0310-9956-ffa450edef68
* Initialized merge tracking via "svnmerge" with revisions "1-492620" from Alan Conway2007-03-070-0/+0
| | | | | | | https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@515721 13f79535-47bb-0310-9956-ffa450edef68
* * python/qpid/peer.py (Channel.__init__): use reliable framing ifAlan Conway2007-03-063-14/+22
| | | | | | | | | | version >= 0-8. * python/qpid/spec.py (Spec.__init__): Remove unused parameter. * python/qpid/testlib.py (TestRunner._parseargs): Add --errata option, set default errata only if --spec is not present. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@515363 13f79535-47bb-0310-9956-ffa450edef68
* r1239@fuschia: andrew | 2007-02-26 10:58:52 +0000Andrew Stitcher2007-03-053-36/+63
| | | | | | | | | Refactored message transfer to extract commmonality from deliver/get r1242@fuschia: andrew | 2007-03-05 17:54:44 +0000 Turn oversize inline transfers into reference transfers git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@514751 13f79535-47bb-0310-9956-ffa450edef68
* Tidy-up of java templates to remove unused includes and declarations in ↵Kim van der Riet2007-02-232-8/+0
| | | | | | generated code git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@511004 13f79535-47bb-0310-9956-ffa450edef68
* r1237@fuschia: andrew | 2007-02-23 15:40:44 +0000Andrew Stitcher2007-02-231-3/+1
| | | | | | | Bug in acks - Small typo fixed git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@510986 13f79535-47bb-0310-9956-ffa450edef68
* Revised list of failing tests for java broker on this branchGordon Sim2007-02-231-7/+0
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@510913 13f79535-47bb-0310-9956-ffa450edef68
* Implementation of queue.unbind & message.getGordon Sim2007-02-2310-22/+199
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@510912 13f79535-47bb-0310-9956-ffa450edef68
* * cpp/lib/client/Basic.*, ClientChannel.*: Extracted Basic functionalityAlan Conway2007-02-2213-429/+592
| | | | | | | | from Channel into separate Basic class. * cpp/lib/client/*, cpp/test/*: Adjusted for new Channel::getBasic() API. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@510705 13f79535-47bb-0310-9956-ffa450edef68
* Added some more logging.Alan Conway2007-02-221-28/+31
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@510553 13f79535-47bb-0310-9956-ffa450edef68
* Fix spurious error message printed by client when broker closes connection.Alan Conway2007-02-212-5/+10
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@510180 13f79535-47bb-0310-9956-ffa450edef68
* Thread safety fixes for race conditions on incoming messages.Alan Conway2007-02-2118-445/+732
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | * cpp/lib/client/MessageListener.h: const correctness. * cpp/tests/*: MessageListener const change. * cpp/lib/broker/Content.h: Removed out-of-date FIXME comments. * cpp/lib/client/ClientChannel.h/ .cpp(): - added locking for consumers map and other member access. - refactored implementations of Basic get, deliver, return: most logic now encapsulted in IncomingMessage class. - fix channel close problems. * cpp/lib/client/ClientMessage.h/.cpp: - const correctness & API convenience fixes. - getMethod/setMethod/getHeader: for new IncomingMessage * cpp/lib/client/Connection.h/.cpp: - Fixes to channel closure. * cpp/lib/client/IncomingMessage.h/.cpp: - Encapsulate *all* incoming message handling for client. - Moved handling of BasicGetOk to IncomingMessage to fix race. - Thread safety fixes. * cpp/lib/client/ResponseHandler.h/.cpp: - added getResponse for ClientChannel. * cpp/lib/common/Exception.h: - added missing throwSelf implementations. - added ShutdownException as general purpose shut-down indicator. - added EmptyException as general purpose "empty" indicator. * cpp/lib/common/sys/Condition|Monitor|Mutex.h|.cpp: - Condition variable abstraction extracted from Monitor for situations where a single lock is associated with multiple conditions. * cpp/tests/ClientChannelTest.cpp: - Test incoming message transfer, get, consume etc. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@510161 13f79535-47bb-0310-9956-ffa450edef68
* Ensure socket is closed in tearDownGordon Sim2007-02-213-7/+22
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@510128 13f79535-47bb-0310-9956-ffa450edef68
* r1224@fuschia: andrew | 2007-02-21 17:20:59 +0000Andrew Stitcher2007-02-211-0/+4
| | | | | | | Updated expected cpp broker test failures git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@510114 13f79535-47bb-0310-9956-ffa450edef68
* Added the Session Adpater to the branch. It was taken from the trunkRajith Muditha Attapattu2007-02-214-3/+38
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@510107 13f79535-47bb-0310-9956-ffa450edef68
* Fixed bug in references where map wasn't qualified in closeGordon Sim2007-02-213-6/+9
| | | | | | | | | Attach reference to transfer, as it will be deleted on close Altered tests to get reference from the message on the queue rather than looking them up from channel as they are already gone there git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@510096 13f79535-47bb-0310-9956-ffa450edef68
* r1152@fuschia: andrew | 2007-02-17 21:14:42 +0000Andrew Stitcher2007-02-217-120/+156
| | | | | | | | | More support for references (and transfers of reference content) r1220@fuschia: andrew | 2007-02-21 00:22:53 +0000 Working version of delivering Message Transfers by reference git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@509834 13f79535-47bb-0310-9956-ffa450edef68
* Added simple transaction test with commit and rollback for message reference ↵Kim van der Riet2007-02-201-3/+3
| | | | | | transfers. There is plenty of scope for more sophisticated tests. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@509755 13f79535-47bb-0310-9956-ffa450edef68
* Added simple transaction test with commit and rollback for message reference ↵Kim van der Riet2007-02-202-0/+199
| | | | | | transfers. There is plenty of scope for more sophisticated tests. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@509754 13f79535-47bb-0310-9956-ffa450edef68
* Fixed the various Ref modes so that the new MessageRefTest passes all tests.Kim van der Riet2007-02-2014-144/+433
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@509738 13f79535-47bb-0310-9956-ffa450edef68
* Updated list of failing tests for java broker on this branch.Gordon Sim2007-02-201-4/+2
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@509617 13f79535-47bb-0310-9956-ffa450edef68
* Some fixes to get more python tests passing.Gordon Sim2007-02-209-138/+119
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@509616 13f79535-47bb-0310-9956-ffa450edef68
* Fixed bug where response id rather than request id was being used to get ↵Gordon Sim2007-02-201-1/+1
| | | | | | listener for response. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@509611 13f79535-47bb-0310-9956-ffa450edef68
* ClientChannel: removed server proxy, not used.Alan Conway2007-02-172-23/+2
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@508706 13f79535-47bb-0310-9956-ffa450edef68
* * cpp/lib/client/ClientMessage.h/.cpp: Added Message constructor taking data.Alan Conway2007-02-1722-124/+257
| | | | | | | | | | | | | | | | | * cpp/lib/client/IncomingMessage.cpp: Simplified message aggregation. * cpp/lib/common/framing/AMQ*Body.h: remove unnecessary virtual inheritance. * cpp/lib/common/framing/AMQMethodBody.h: add bool isRequest, isResponse * cpp/lib/common/sys/Mutex.h (class ScopedUnlock): Added ScopedUnlock * cpp/lib/common/sys/ThreadSafeQueue.h: Thread-safe queue template. * cpp/tests/BrokerChannelTest.cpp: Renamed from ChannelTest. * cpp/tests/ClientChannelTest.cpp: Test client API. * cpp/tests/RequestResponseTest.cpp: Removed empty test. * cpp/lib/client/Connection.h,.cpp: - non-static channelIdCounter - No close() in dtor. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@508705 13f79535-47bb-0310-9956-ffa450edef68
* Additions to allow refs to be sent from broker to client. Also some tidy-up.Kim van der Riet2007-02-1610-142/+109
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@508460 13f79535-47bb-0310-9956-ffa450edef68
* Fix: use message_resume not channel_resumeGordon Sim2007-02-161-1/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@508396 13f79535-47bb-0310-9956-ffa450edef68
* A few hacks and fixes to get the python tests running again.Gordon Sim2007-02-166-4/+8
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@508391 13f79535-47bb-0310-9956-ffa450edef68
* Altered exception thrown for unopened and reopened references.Gordon Sim2007-02-161-3/+2
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@508379 13f79535-47bb-0310-9956-ffa450edef68
* Updated failing list for java (some of these result in test suite blocking)Gordon Sim2007-02-162-1/+12
| | | | | | | | Added better error handling when connection closes without close method git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@508377 13f79535-47bb-0310-9956-ffa450edef68
* added support for reference caseRajith Muditha Attapattu2007-02-159-8/+44
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@508233 13f79535-47bb-0310-9956-ffa450edef68
* Constructor version argument defaults to highestProtocolVersion.Alan Conway2007-02-151-3/+7
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@508156 13f79535-47bb-0310-9956-ffa450edef68
* Fix for messages that stick around in unsubscribed queues after rollbackKim van der Riet2007-02-152-2/+7
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@508150 13f79535-47bb-0310-9956-ffa450edef68
* Adjusted mechanism for sending refs. (still in progress)Kim van der Riet2007-02-151-27/+33
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@508098 13f79535-47bb-0310-9956-ffa450edef68
* Fix for RecoverTest which was failing because the redelivered flag was ↵Kim van der Riet2007-02-154-5/+15
| | | | | | disconnected git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@507993 13f79535-47bb-0310-9956-ffa450edef68
* Fixes to get TransactedTest back, there are still unresolved issues with ↵Kim van der Riet2007-02-153-58/+52
| | | | | | rollback(), however. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@507960 13f79535-47bb-0310-9956-ffa450edef68
* First backmerge from trunk to 0-9 branch for Java. Not all java tests ↵Kim van der Riet2007-02-14490-10193/+19722
| | | | | | passing yet git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@507672 13f79535-47bb-0310-9956-ffa450edef68
* Added durability property to queues and pass this to broker on declare. ↵Gordon Sim2007-02-145-23/+63
| | | | | | | | | | (This change also applied on trunk) Minor update of accumulated ack and test. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@507622 13f79535-47bb-0310-9956-ffa450edef68
* r1127@fuschia: andrew | 2007-02-14 16:15:34 +0000Andrew Stitcher2007-02-142-10/+13
| | | | | | | Fixed tests, and fixed an exposed bug git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@507602 13f79535-47bb-0310-9956-ffa450edef68
* * cpp/lib/common/sys/ProducerConsumer.h:Alan Conway2007-02-1412-185/+684
| | | | | | | | | | | | | | | General-purpose producer-consumer synchronization. Anywhere we have producer/consumer threads in qpid we should re-use this sync object rather than re-inventing the synchronization each time. * cpp/lib/common/sys/AtomicCount.h: Separated ScopedIncrement/ScopedDecrement into ScopedIncrement.h * cpp/tests/InProcessBroker.h: Added class InProcessBrokerClient, a self contained in-process client + broker convenience for tests. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@507560 13f79535-47bb-0310-9956-ffa450edef68
* Expanded the use of batched acks to a few other places in tests.Gordon Sim2007-02-142-25/+10
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@507491 13f79535-47bb-0310-9956-ffa450edef68
* r1111@fuschia: andrew | 2007-02-09 15:51:10 +0000Andrew Stitcher2007-02-1312-58/+59
| | | | | | | | | | Removed currently unused request tracking logic r1125@fuschia: andrew | 2007-02-13 21:51:30 +0000 Implemented receiveing batched Message.ok in c++ broker Implemented batched response frames in python client code git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@507249 13f79535-47bb-0310-9956-ffa450edef68
* * gentools/templ.cpp/*Proxy*, CppGenerator.java: Changes to ProxyAlan Conway2007-02-1349-563/+798
| | | | | | | | | | | | | | | | | | | | | | | | | | | | classes to make them directly usable as an API for low-level AMQP access. - Proxies hold reference to a ChannelAdapter not just an output handler. - Removed MethodContext parameter, makes no sense on requester end. - Return RequestId from request methods so caller can correlate incoming responses. - Add RequestId parameter to response methods so caller can provide correlation for outgoing responses. - No longer inherit from *Operations classes as the signatures no longer match. Proxy is for caller (client/requester) and Operations is for callee (server/responder) * cpp/lib/client/ClientChannel.h: Channel provides a raw proxy to the broker. Normal users will still use the Channel API to deal with the broker, but advanced users (incl ourselves!) can use the raw API to directly send and receive any AMQP message. * cpp/lib/broker/BrokerChannel,BrokerAdapter: Refactor for new proxies. broker::Channel is also a ClientProxy * Sundry files: - Pass ProtcolVersion by value, it is only two bytes. - Misc. const correctness fixes. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@506823 13f79535-47bb-0310-9956-ffa450edef68
* Minor update to checkpoint testGordon Sim2007-02-121-2/+2
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@506566 13f79535-47bb-0310-9956-ffa450edef68