diff options
| author | Carl C. Trieloff <cctrieloff@apache.org> | 2007-06-29 21:16:17 +0000 |
|---|---|---|
| committer | Carl C. Trieloff <cctrieloff@apache.org> | 2007-06-29 21:16:17 +0000 |
| commit | c7b2714b6b6ad24da21e1956163e3f143457fa7f (patch) | |
| tree | 5c0feb1f4596e3b4a0592282f2e31cc97c418dba /cpp/src/qpid/broker/BrokerAdapter.cpp | |
| parent | a258bbcaf007d20d943669b7ee6223016dd08d66 (diff) | |
| download | qpid-python-c7b2714b6b6ad24da21e1956163e3f143457fa7f.tar.gz | |
Updated AutoDelete, now only run when auto delete queues exist and
additional auto delete queues being declared. cuts 1-3% of CPU time
for concurrent publisher run.
Could do with some more auto delete tests...
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@552037 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'cpp/src/qpid/broker/BrokerAdapter.cpp')
| -rw-r--r-- | cpp/src/qpid/broker/BrokerAdapter.cpp | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/cpp/src/qpid/broker/BrokerAdapter.cpp b/cpp/src/qpid/broker/BrokerAdapter.cpp index b7a61ababe..a0ab42592e 100644 --- a/cpp/src/qpid/broker/BrokerAdapter.cpp +++ b/cpp/src/qpid/broker/BrokerAdapter.cpp @@ -219,7 +219,6 @@ void BrokerAdapter::QueueHandlerImpl::declare(const MethodContext& context, uint assert(queue); if (queue_created.second) { // This is a new queue channel.setDefaultQueue(queue); - //apply settings & create persistent record if required queue_created.first->create(arguments); @@ -232,6 +231,7 @@ void BrokerAdapter::QueueHandlerImpl::declare(const MethodContext& context, uint connection.exclusiveQueues.push_back(queue); } else if(autoDelete){ broker.getCleaner().add(queue); + broker.getCleaner().clean(); // check if cleaning is needed } } } |
