diff options
| author | Gordon Sim <gsim@apache.org> | 2006-10-12 16:32:47 +0000 |
|---|---|---|
| committer | Gordon Sim <gsim@apache.org> | 2006-10-12 16:32:47 +0000 |
| commit | ed053ced80d3d8997420fd4f95e7c9bfbb561f40 (patch) | |
| tree | 146b812e055fce3259430ac9c6a147dfb3f03a54 /qpid/cpp/broker/src/TopicExchange.cpp | |
| parent | 0fa9f4026bade25610d8dbb697a52ccb821aef16 (diff) | |
| download | qpid-python-ed053ced80d3d8997420fd4f95e7c9bfbb561f40.tar.gz | |
Fixed ack.RecoverTest and ack.DisconnectAndRedeliverTest. These were failing due to a race condition
where the consumers queue was not bound by the time the publisher sent messages.
This is a result of the use of nowait=true for the declare/bind/consume cycle for a BasicMessageConsumer.
To work around this in tests like these that have two connections, one consuming & one publishing, I
added a declareExchangeSynch() method to AMQSession which allows a thread to block until the session it
invokes that method on has processed all the commands up to that point.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@463309 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/cpp/broker/src/TopicExchange.cpp')
0 files changed, 0 insertions, 0 deletions
