delta/python-packages/qpid-python.git/cpp/lib/client, branch qpid.0-9

Changed u_int_t to uint_t for posix compliance.

2007-03-15T19:22:02+00:00

git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@518733 13f79535-47bb-0310-9956-ffa450edef68

Merged revisions 507582 via svnmerge from

2007-03-14T18:03:26+00:00

https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid

........
  r507582 | gsim | 2007-02-14 10:38:57 -0500 (Wed, 14 Feb 2007) | 3 lines
  
  Add durability property to queues and pass this to broker on declare.
........


git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@518246 13f79535-47bb-0310-9956-ffa450edef68

Merged revisions 506406 via svnmerge from

2007-03-14T16:27:56+00:00

https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid

........
  r506406 | gsim | 2007-02-12 05:32:56 -0500 (Mon, 12 Feb 2007) | 4 lines
  
  * lib/client/Connection.h - changed default virtual host from '/' to '' as per QPID-349
  * lib/client/ClientExchange.h - fixed typo in a comment
........


git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@518207 13f79535-47bb-0310-9956-ffa450edef68

Merged revisions 493126-493151 via svnmerge from

2007-03-09T18:15:02+00:00

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  
  
  	* 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  
  
  	* 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

* cpp/lib/client/Basic., ClientChannel.: Extracted Basic functionality

2007-02-22T23:23:52+00:00

  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

Fix spurious error message printed by client when broker closes connection.

2007-02-21T20:09:23+00:00

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.

2007-02-21T19:25:45+00:00

* 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

ClientChannel: removed server proxy, not used.

2007-02-17T03:54:15+00:00

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.

2007-02-17T03:46:44+00:00

* 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

Added durability property to queues and pass this to broker on declare. (This change also applied on trunk)

2007-02-14T16:58:52+00:00

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