summaryrefslogtreecommitdiff
path: root/cpp/src/qpid/broker/SemanticState.cpp
diff options
context:
space:
mode:
authorGordon Sim <gsim@apache.org>2008-03-06 17:52:59 +0000
committerGordon Sim <gsim@apache.org>2008-03-06 17:52:59 +0000
commit9fd4909832e16734c47c13eebbe4aca66640b1b0 (patch)
tree6882efaaa8244086c0765f95ee1c1e9836bb088c /cpp/src/qpid/broker/SemanticState.cpp
parent19ad6741d3579b1ffce70a43271e4e4f804ad643 (diff)
downloadqpid-python-9fd4909832e16734c47c13eebbe4aca66640b1b0.tar.gz
Fixes to c++ broker:
- use final version of delivery properties where appropriate - start sequence numbering of outgoing messages at 0 - explicit accept-mode is now 0 (no more confirm-mode) - add default initialisers for numeric fields in methods Converted some more python tests to use final 0-10 client. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@634368 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'cpp/src/qpid/broker/SemanticState.cpp')
-rw-r--r--cpp/src/qpid/broker/SemanticState.cpp6
1 files changed, 3 insertions, 3 deletions
diff --git a/cpp/src/qpid/broker/SemanticState.cpp b/cpp/src/qpid/broker/SemanticState.cpp
index b56b152397..5851eeeafb 100644
--- a/cpp/src/qpid/broker/SemanticState.cpp
+++ b/cpp/src/qpid/broker/SemanticState.cpp
@@ -89,12 +89,12 @@ bool SemanticState::exists(const string& consumerTag){
}
void SemanticState::consume(DeliveryToken::shared_ptr token, string& tagInOut,
- Queue::shared_ptr queue, bool nolocal, bool acks, bool acquire,
- bool exclusive, const FieldTable*)
+ Queue::shared_ptr queue, bool nolocal, bool ackRequired, bool acquire,
+ bool exclusive, const FieldTable*)
{
if(tagInOut.empty())
tagInOut = tagGenerator.generate();
- std::auto_ptr<ConsumerImpl> c(new ConsumerImpl(this, token, tagInOut, queue, acks, nolocal, acquire));
+ std::auto_ptr<ConsumerImpl> c(new ConsumerImpl(this, token, tagInOut, queue, ackRequired, nolocal, acquire));
queue->consume(*c, exclusive);//may throw exception
outputTasks.addOutputTask(c.get());
consumers.insert(tagInOut, c.release());