> On July 3, 2013, 7:21 p.m., Kenneth Giusti wrote: > > /trunk/qpid/cpp/src/qpid/broker/QueueSettings.cpp, line 270 > > <https://reviews.apache.org/r/12249/diff/1/?file=317954#file317954line270> > > > > No DELETE_ON_CLOSE check? > > > > Gordon Sim wrote: > I didn't think that made as much sense for 0-10 or for 'shared' queues > more generally (which would be where the verify method was called). In 1.0 it > means delete the queue when the link that caused it to be created is closed. > I suppose I could interpret that to mean the session that created it in 0-10. > That would be like autodelete+exclusive, but without locking other users out > entirely as exclusive does...
Ah, I understand. I thought it may have been an oversight, but this make sense. I'd mark the issue closed, but I can't seem to do it :( > On July 3, 2013, 7:21 p.m., Kenneth Giusti wrote: > > /trunk/qpid/cpp/src/tests/QueueTest.cpp, line 431 > > <https://reviews.apache.org/r/12249/diff/1/?file=317968#file317968line431> > > > > Ah, interesting... should the test have called queue->consume() on c3 > > originally? > > Gordon Sim wrote: > Well, its not strictly required, but if consume() is not called then > cancel() certainly shouldn't be either. This was originally my oversight - I'd recommend adding the missing consume() to be more consistent with the broker's treatment of clients [actually, both tests in that file seem to have the same issue!] - Kenneth ----------------------------------------------------------- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/12249/#review22731 ----------------------------------------------------------- On July 3, 2013, 3:22 p.m., Gordon Sim wrote: > > ----------------------------------------------------------- > This is an automatically generated e-mail. To reply, visit: > https://reviews.apache.org/r/12249/ > ----------------------------------------------------------- > > (Updated July 3, 2013, 3:22 p.m.) > > > Review request for qpid, Alan Conway and Kenneth Giusti. > > > Bugs: QPID-4976 > https://issues.apache.org/jira/browse/QPID-4976 > > > Repository: qpid > > > Description > ------- > > This adds the ability to have queue autodeleted when no longer used, when > empty or when both no longer used and empty as specified in the standard > lifetime policies for AMQP 1.0. The ability to only delete if unused and > empty is useful for 0-10 also so I've allowed these to be set there as well. > > The basic change is to have an optional policy specified that dictates what > autodelete means. The default is to autodelete when not used. A queue is in > use if it is being consumed or browsed, or if in 0-10 it has been declared as > an exclusive queue and the declaring session is still active. Additionally > over 1.0 the queue is in use if there is any sender attached to it. > Autodeletion is now triggered automatically by the queue when some other > operation moves it to a state eligible for deletion. To avoid this on a > backup in ha, the queue replicator flags the replica as in use. > > > Diffs > ----- > > /trunk/qpid/cpp/src/qpid/amqp/descriptors.h 1497827 > /trunk/qpid/cpp/src/qpid/broker/LossyQueue.cpp 1497827 > /trunk/qpid/cpp/src/qpid/broker/Lvq.cpp 1497827 > /trunk/qpid/cpp/src/qpid/broker/Queue.h 1497827 > /trunk/qpid/cpp/src/qpid/broker/Queue.cpp 1497827 > /trunk/qpid/cpp/src/qpid/broker/QueueSettings.h 1497827 > /trunk/qpid/cpp/src/qpid/broker/QueueSettings.cpp 1497827 > /trunk/qpid/cpp/src/qpid/broker/SemanticState.cpp 1497827 > /trunk/qpid/cpp/src/qpid/broker/SessionAdapter.cpp 1497827 > /trunk/qpid/cpp/src/qpid/broker/amqp/Connection.cpp 1497827 > /trunk/qpid/cpp/src/qpid/broker/amqp/DataReader.cpp 1497827 > /trunk/qpid/cpp/src/qpid/broker/amqp/NodeProperties.h 1497827 > /trunk/qpid/cpp/src/qpid/broker/amqp/NodeProperties.cpp 1497827 > /trunk/qpid/cpp/src/qpid/broker/amqp/Outgoing.h 1497827 > /trunk/qpid/cpp/src/qpid/broker/amqp/Outgoing.cpp 1497827 > /trunk/qpid/cpp/src/qpid/broker/amqp/Session.h 1497827 > /trunk/qpid/cpp/src/qpid/broker/amqp/Session.cpp 1497827 > /trunk/qpid/cpp/src/qpid/ha/BrokerReplicator.cpp 1497827 > /trunk/qpid/cpp/src/qpid/ha/QueueReplicator.cpp 1497827 > /trunk/qpid/cpp/src/qpid/messaging/amqp/AddressHelper.cpp 1497827 > /trunk/qpid/cpp/src/tests/QueueTest.cpp 1497827 > > Diff: https://reviews.apache.org/r/12249/diff/ > > > Testing > ------- > > > Thanks, > > Gordon Sim > >
