You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by gs...@apache.org on 2010/04/09 18:27:36 UTC
svn commit: r932490 - in /qpid/trunk/qpid/cpp: include/qpid/messaging/
src/qpid/client/amqp0_10/ src/qpid/messaging/ src/tests/
Author: gsim
Date: Fri Apr 9 16:27:35 2010
New Revision: 932490
URL: http://svn.apache.org/viewvc?rev=932490&view=rev
Log:
QPID-664: changed pending to unsettled; added available to sender; minor update to address doc
Modified:
qpid/trunk/qpid/cpp/include/qpid/messaging/Address.h
qpid/trunk/qpid/cpp/include/qpid/messaging/Receiver.h
qpid/trunk/qpid/cpp/include/qpid/messaging/Sender.h
qpid/trunk/qpid/cpp/include/qpid/messaging/Session.h
qpid/trunk/qpid/cpp/src/qpid/client/amqp0_10/ReceiverImpl.cpp
qpid/trunk/qpid/cpp/src/qpid/client/amqp0_10/ReceiverImpl.h
qpid/trunk/qpid/cpp/src/qpid/client/amqp0_10/SenderImpl.cpp
qpid/trunk/qpid/cpp/src/qpid/client/amqp0_10/SenderImpl.h
qpid/trunk/qpid/cpp/src/qpid/client/amqp0_10/SessionImpl.cpp
qpid/trunk/qpid/cpp/src/qpid/client/amqp0_10/SessionImpl.h
qpid/trunk/qpid/cpp/src/qpid/messaging/Receiver.cpp
qpid/trunk/qpid/cpp/src/qpid/messaging/ReceiverImpl.h
qpid/trunk/qpid/cpp/src/qpid/messaging/Sender.cpp
qpid/trunk/qpid/cpp/src/qpid/messaging/SenderImpl.h
qpid/trunk/qpid/cpp/src/qpid/messaging/Session.cpp
qpid/trunk/qpid/cpp/src/qpid/messaging/SessionImpl.h
qpid/trunk/qpid/cpp/src/tests/MessagingSessionTests.cpp
Modified: qpid/trunk/qpid/cpp/include/qpid/messaging/Address.h
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/cpp/include/qpid/messaging/Address.h?rev=932490&r1=932489&r2=932490&view=diff
==============================================================================
--- qpid/trunk/qpid/cpp/include/qpid/messaging/Address.h (original)
+++ qpid/trunk/qpid/cpp/include/qpid/messaging/Address.h Fri Apr 9 16:27:35 2010
@@ -84,9 +84,16 @@ class AddressImpl;
*
* <tr valign=top>
* <td>node</td>
+
* <td>A nested map describing properties of the addressed
* node. Current properties supported are type (topic or queue),
- * durable (boolean), x-declare and x-bindings.
+ * durable (boolean), x-declare and x-bindings. The x-declare
+ * option is a nested map in whcih protocol amqp 0-10 specific
+ * options for queue or exchange declare can be specified. The
+ * x-bindings option is a nested list, each element of which can
+ * specify a queue, an exchange, a binding-key and arguments,
+ * which are used to establish a binding on create. The node
+ * will be used if queue or exchange values are not specified.
* </td>
* </tr>
*
Modified: qpid/trunk/qpid/cpp/include/qpid/messaging/Receiver.h
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/cpp/include/qpid/messaging/Receiver.h?rev=932490&r1=932489&r2=932490&view=diff
==============================================================================
--- qpid/trunk/qpid/cpp/include/qpid/messaging/Receiver.h (original)
+++ qpid/trunk/qpid/cpp/include/qpid/messaging/Receiver.h Fri Apr 9 16:27:35 2010
@@ -104,7 +104,7 @@ class Receiver : public qpid::messaging:
* acknowledgement has not yet been confirmed as processed by the
* server.
*/
- QPID_CLIENT_EXTERN uint32_t getPendingAck();
+ QPID_CLIENT_EXTERN uint32_t getUnsettled();
/**
* Cancels this receiver.
Modified: qpid/trunk/qpid/cpp/include/qpid/messaging/Sender.h
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/cpp/include/qpid/messaging/Sender.h?rev=932490&r1=932489&r2=932490&view=diff
==============================================================================
--- qpid/trunk/qpid/cpp/include/qpid/messaging/Sender.h (original)
+++ qpid/trunk/qpid/cpp/include/qpid/messaging/Sender.h Fri Apr 9 16:27:35 2010
@@ -70,8 +70,12 @@ class Sender : public qpid::messaging::H
* Returns the number of sent messages pending confirmation of
* receipt by the broker. (These are the 'in-doubt' messages).
*/
- QPID_CLIENT_EXTERN uint32_t getPending();
-
+ QPID_CLIENT_EXTERN uint32_t getUnsettled();
+ /**
+ * Returns the number of messages for which there is available
+ * capacity.
+ */
+ QPID_CLIENT_EXTERN uint32_t getAvailable();
/**
* Returns the name of this sender.
*/
Modified: qpid/trunk/qpid/cpp/include/qpid/messaging/Session.h
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/cpp/include/qpid/messaging/Session.h?rev=932490&r1=932489&r2=932490&view=diff
==============================================================================
--- qpid/trunk/qpid/cpp/include/qpid/messaging/Session.h (original)
+++ qpid/trunk/qpid/cpp/include/qpid/messaging/Session.h Fri Apr 9 16:27:35 2010
@@ -96,15 +96,17 @@ class Session : public qpid::messaging::
/**
* Returns the total number of messages received and waiting to be
- * fetched by all Receivers belonging to this session.
+ * fetched by all Receivers belonging to this session. This is the
+ * total number of available messages across all receivers on this
+ * session.
*/
- QPID_CLIENT_EXTERN uint32_t getAvailable();
+ QPID_CLIENT_EXTERN uint32_t getReceivable();
/**
* Returns a count of the number of messages received this session
* that have been acknowledged, but for which that acknowledgement
* has not yet been confirmed as processed by the server.
*/
- QPID_CLIENT_EXTERN uint32_t getPendingAck();
+ QPID_CLIENT_EXTERN uint32_t getUnsettledAcks();
/**
* Retrieves the receiver for the next available message. If there
* are no available messages at present the call will block for up
Modified: qpid/trunk/qpid/cpp/src/qpid/client/amqp0_10/ReceiverImpl.cpp
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/cpp/src/qpid/client/amqp0_10/ReceiverImpl.cpp?rev=932490&r1=932489&r2=932490&view=diff
==============================================================================
--- qpid/trunk/qpid/cpp/src/qpid/client/amqp0_10/ReceiverImpl.cpp (original)
+++ qpid/trunk/qpid/cpp/src/qpid/client/amqp0_10/ReceiverImpl.cpp Fri Apr 9 16:27:35 2010
@@ -130,14 +130,14 @@ uint32_t ReceiverImpl::getCapacity()
return capacity;
}
-uint32_t ReceiverImpl::available()
+uint32_t ReceiverImpl::getAvailable()
{
- return parent->available(destination);
+ return parent->getReceivable(destination);
}
-uint32_t ReceiverImpl::pendingAck()
+uint32_t ReceiverImpl::getUnsettled()
{
- return parent->pendingAck(destination);
+ return parent->getUnsettledAcks(destination);
}
ReceiverImpl::ReceiverImpl(SessionImpl& p, const std::string& name,
Modified: qpid/trunk/qpid/cpp/src/qpid/client/amqp0_10/ReceiverImpl.h
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/cpp/src/qpid/client/amqp0_10/ReceiverImpl.h?rev=932490&r1=932489&r2=932490&view=diff
==============================================================================
--- qpid/trunk/qpid/cpp/src/qpid/client/amqp0_10/ReceiverImpl.h (original)
+++ qpid/trunk/qpid/cpp/src/qpid/client/amqp0_10/ReceiverImpl.h Fri Apr 9 16:27:35 2010
@@ -60,8 +60,8 @@ class ReceiverImpl : public qpid::messag
const std::string& getName() const;
void setCapacity(uint32_t);
uint32_t getCapacity();
- uint32_t available();
- uint32_t pendingAck();
+ uint32_t getAvailable();
+ uint32_t getUnsettled();
void received(qpid::messaging::Message& message);
qpid::messaging::Session getSession() const;
private:
Modified: qpid/trunk/qpid/cpp/src/qpid/client/amqp0_10/SenderImpl.cpp
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/cpp/src/qpid/client/amqp0_10/SenderImpl.cpp?rev=932490&r1=932489&r2=932490&view=diff
==============================================================================
--- qpid/trunk/qpid/cpp/src/qpid/client/amqp0_10/SenderImpl.cpp (original)
+++ qpid/trunk/qpid/cpp/src/qpid/client/amqp0_10/SenderImpl.cpp Fri Apr 9 16:27:35 2010
@@ -58,7 +58,7 @@ void SenderImpl::setCapacity(uint32_t c)
execute1<CheckPendingSends>(flush);
}
uint32_t SenderImpl::getCapacity() { return capacity; }
-uint32_t SenderImpl::pending()
+uint32_t SenderImpl::getUnsettled()
{
CheckPendingSends f(*this, false);
parent->execute(f);
Modified: qpid/trunk/qpid/cpp/src/qpid/client/amqp0_10/SenderImpl.h
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/cpp/src/qpid/client/amqp0_10/SenderImpl.h?rev=932490&r1=932489&r2=932490&view=diff
==============================================================================
--- qpid/trunk/qpid/cpp/src/qpid/client/amqp0_10/SenderImpl.h (original)
+++ qpid/trunk/qpid/cpp/src/qpid/client/amqp0_10/SenderImpl.h Fri Apr 9 16:27:35 2010
@@ -52,7 +52,7 @@ class SenderImpl : public qpid::messagin
void close();
void setCapacity(uint32_t);
uint32_t getCapacity();
- uint32_t pending();
+ uint32_t getUnsettled();
void init(qpid::client::AsyncSession, AddressResolution&);
const std::string& getName() const;
qpid::messaging::Session getSession() const;
Modified: qpid/trunk/qpid/cpp/src/qpid/client/amqp0_10/SessionImpl.cpp
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/cpp/src/qpid/client/amqp0_10/SessionImpl.cpp?rev=932490&r1=932489&r2=932490&view=diff
==============================================================================
--- qpid/trunk/qpid/cpp/src/qpid/client/amqp0_10/SessionImpl.cpp (original)
+++ qpid/trunk/qpid/cpp/src/qpid/client/amqp0_10/SessionImpl.cpp Fri Apr 9 16:27:35 2010
@@ -341,25 +341,25 @@ qpid::messaging::Receiver SessionImpl::n
return receiver;
}
-uint32_t SessionImpl::available()
+uint32_t SessionImpl::getReceivable()
{
- return get1<Available, uint32_t>((const std::string*) 0);
+ return get1<Receivable, uint32_t>((const std::string*) 0);
}
-uint32_t SessionImpl::available(const std::string& destination)
+uint32_t SessionImpl::getReceivable(const std::string& destination)
{
- return get1<Available, uint32_t>(&destination);
+ return get1<Receivable, uint32_t>(&destination);
}
-struct SessionImpl::Available : Command
+struct SessionImpl::Receivable : Command
{
const std::string* destination;
uint32_t result;
- Available(SessionImpl& i, const std::string* d) : Command(i), destination(d), result(0) {}
- void operator()() { result = impl.availableImpl(destination); }
+ Receivable(SessionImpl& i, const std::string* d) : Command(i), destination(d), result(0) {}
+ void operator()() { result = impl.getReceivableImpl(destination); }
};
-uint32_t SessionImpl::availableImpl(const std::string* destination)
+uint32_t SessionImpl::getReceivableImpl(const std::string* destination)
{
if (destination) {
return incoming.available(*destination);
@@ -368,26 +368,26 @@ uint32_t SessionImpl::availableImpl(cons
}
}
-uint32_t SessionImpl::pendingAck()
+uint32_t SessionImpl::getUnsettledAcks()
{
- return get1<PendingAck, uint32_t>((const std::string*) 0);
+ return get1<UnsettledAcks, uint32_t>((const std::string*) 0);
}
-uint32_t SessionImpl::pendingAck(const std::string& destination)
+uint32_t SessionImpl::getUnsettledAcks(const std::string& destination)
{
- return get1<PendingAck, uint32_t>(&destination);
+ return get1<UnsettledAcks, uint32_t>(&destination);
}
-struct SessionImpl::PendingAck : Command
+struct SessionImpl::UnsettledAcks : Command
{
const std::string* destination;
uint32_t result;
- PendingAck(SessionImpl& i, const std::string* d) : Command(i), destination(d), result(0) {}
- void operator()() { result = impl.pendingAckImpl(destination); }
+ UnsettledAcks(SessionImpl& i, const std::string* d) : Command(i), destination(d), result(0) {}
+ void operator()() { result = impl.getUnsettledAcksImpl(destination); }
};
-uint32_t SessionImpl::pendingAckImpl(const std::string* destination)
+uint32_t SessionImpl::getUnsettledAcksImpl(const std::string* destination)
{
if (destination) {
return incoming.pendingAccept(*destination);
Modified: qpid/trunk/qpid/cpp/src/qpid/client/amqp0_10/SessionImpl.h
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/cpp/src/qpid/client/amqp0_10/SessionImpl.h?rev=932490&r1=932489&r2=932490&view=diff
==============================================================================
--- qpid/trunk/qpid/cpp/src/qpid/client/amqp0_10/SessionImpl.h (original)
+++ qpid/trunk/qpid/cpp/src/qpid/client/amqp0_10/SessionImpl.h Fri Apr 9 16:27:35 2010
@@ -82,11 +82,11 @@ class SessionImpl : public qpid::messagi
void receiverCancelled(const std::string& name);
void senderCancelled(const std::string& name);
- uint32_t available();
- uint32_t available(const std::string& destination);
+ uint32_t getReceivable();
+ uint32_t getReceivable(const std::string& destination);
- uint32_t pendingAck();
- uint32_t pendingAck(const std::string& destination);
+ uint32_t getUnsettledAcks();
+ uint32_t getUnsettledAcks(const std::string& destination);
void setSession(qpid::client::Session);
@@ -143,8 +143,8 @@ class SessionImpl : public qpid::messagi
void syncImpl(bool block);
qpid::messaging::Sender createSenderImpl(const qpid::messaging::Address& address);
qpid::messaging::Receiver createReceiverImpl(const qpid::messaging::Address& address);
- uint32_t availableImpl(const std::string* destination);
- uint32_t pendingAckImpl(const std::string* destination);
+ uint32_t getReceivableImpl(const std::string* destination);
+ uint32_t getUnsettledAcksImpl(const std::string* destination);
//functors for public facing methods (allows locking and retry
//logic to be centralised)
@@ -203,8 +203,8 @@ class SessionImpl : public qpid::messagi
struct CreateSender;
struct CreateReceiver;
- struct PendingAck;
- struct Available;
+ struct UnsettledAcks;
+ struct Receivable;
//helper templates for some common patterns
template <class F> bool execute()
Modified: qpid/trunk/qpid/cpp/src/qpid/messaging/Receiver.cpp
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/cpp/src/qpid/messaging/Receiver.cpp?rev=932490&r1=932489&r2=932490&view=diff
==============================================================================
--- qpid/trunk/qpid/cpp/src/qpid/messaging/Receiver.cpp (original)
+++ qpid/trunk/qpid/cpp/src/qpid/messaging/Receiver.cpp Fri Apr 9 16:27:35 2010
@@ -39,8 +39,8 @@ bool Receiver::fetch(Message& message, D
Message Receiver::fetch(Duration timeout) { return impl->fetch(timeout); }
void Receiver::setCapacity(uint32_t c) { impl->setCapacity(c); }
uint32_t Receiver::getCapacity() { return impl->getCapacity(); }
-uint32_t Receiver::getAvailable() { return impl->available(); }
-uint32_t Receiver::getPendingAck() { return impl->pendingAck(); }
+uint32_t Receiver::getAvailable() { return impl->getAvailable(); }
+uint32_t Receiver::getUnsettled() { return impl->getUnsettled(); }
void Receiver::close() { impl->close(); }
const std::string& Receiver::getName() const { return impl->getName(); }
Session Receiver::getSession() const { return impl->getSession(); }
Modified: qpid/trunk/qpid/cpp/src/qpid/messaging/ReceiverImpl.h
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/cpp/src/qpid/messaging/ReceiverImpl.h?rev=932490&r1=932489&r2=932490&view=diff
==============================================================================
--- qpid/trunk/qpid/cpp/src/qpid/messaging/ReceiverImpl.h (original)
+++ qpid/trunk/qpid/cpp/src/qpid/messaging/ReceiverImpl.h Fri Apr 9 16:27:35 2010
@@ -40,8 +40,8 @@ class ReceiverImpl : public virtual qpid
virtual Message fetch(Duration timeout) = 0;
virtual void setCapacity(uint32_t) = 0;
virtual uint32_t getCapacity() = 0;
- virtual uint32_t available() = 0;
- virtual uint32_t pendingAck() = 0;
+ virtual uint32_t getAvailable() = 0;
+ virtual uint32_t getUnsettled() = 0;
virtual void close() = 0;
virtual const std::string& getName() const = 0;
virtual Session getSession() const = 0;
Modified: qpid/trunk/qpid/cpp/src/qpid/messaging/Sender.cpp
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/cpp/src/qpid/messaging/Sender.cpp?rev=932490&r1=932489&r2=932490&view=diff
==============================================================================
--- qpid/trunk/qpid/cpp/src/qpid/messaging/Sender.cpp (original)
+++ qpid/trunk/qpid/cpp/src/qpid/messaging/Sender.cpp Fri Apr 9 16:27:35 2010
@@ -36,7 +36,8 @@ void Sender::send(const Message& message
void Sender::close() { impl->close(); }
void Sender::setCapacity(uint32_t c) { impl->setCapacity(c); }
uint32_t Sender::getCapacity() { return impl->getCapacity(); }
-uint32_t Sender::getPending() { return impl->pending(); }
+uint32_t Sender::getUnsettled() { return impl->getUnsettled(); }
+uint32_t Sender::getAvailable() { return getCapacity() - getUnsettled(); }
const std::string& Sender::getName() const { return impl->getName(); }
Session Sender::getSession() const { return impl->getSession(); }
Modified: qpid/trunk/qpid/cpp/src/qpid/messaging/SenderImpl.h
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/cpp/src/qpid/messaging/SenderImpl.h?rev=932490&r1=932489&r2=932490&view=diff
==============================================================================
--- qpid/trunk/qpid/cpp/src/qpid/messaging/SenderImpl.h (original)
+++ qpid/trunk/qpid/cpp/src/qpid/messaging/SenderImpl.h Fri Apr 9 16:27:35 2010
@@ -37,7 +37,7 @@ class SenderImpl : public virtual qpid::
virtual void close() = 0;
virtual void setCapacity(uint32_t) = 0;
virtual uint32_t getCapacity() = 0;
- virtual uint32_t pending() = 0;
+ virtual uint32_t getUnsettled() = 0;
virtual const std::string& getName() const = 0;
virtual Session getSession() const = 0;
private:
Modified: qpid/trunk/qpid/cpp/src/qpid/messaging/Session.cpp
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/cpp/src/qpid/messaging/Session.cpp?rev=932490&r1=932489&r2=932490&view=diff
==============================================================================
--- qpid/trunk/qpid/cpp/src/qpid/messaging/Session.cpp (original)
+++ qpid/trunk/qpid/cpp/src/qpid/messaging/Session.cpp Fri Apr 9 16:27:35 2010
@@ -77,8 +77,8 @@ Receiver Session::nextReceiver(Duration
return impl->nextReceiver(timeout);
}
-uint32_t Session::getAvailable() { return impl->available(); }
-uint32_t Session::getPendingAck() { return impl->pendingAck(); }
+uint32_t Session::getReceivable() { return impl->getReceivable(); }
+uint32_t Session::getUnsettledAcks() { return impl->getUnsettledAcks(); }
Sender Session::getSender(const std::string& name) const
{
Modified: qpid/trunk/qpid/cpp/src/qpid/messaging/SessionImpl.h
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/cpp/src/qpid/messaging/SessionImpl.h?rev=932490&r1=932489&r2=932490&view=diff
==============================================================================
--- qpid/trunk/qpid/cpp/src/qpid/messaging/SessionImpl.h (original)
+++ qpid/trunk/qpid/cpp/src/qpid/messaging/SessionImpl.h Fri Apr 9 16:27:35 2010
@@ -49,8 +49,8 @@ class SessionImpl : public virtual qpid:
virtual Receiver createReceiver(const Address& address) = 0;
virtual bool nextReceiver(Receiver& receiver, Duration timeout) = 0;
virtual Receiver nextReceiver(Duration timeout) = 0;
- virtual uint32_t available() = 0;
- virtual uint32_t pendingAck() = 0;
+ virtual uint32_t getReceivable() = 0;
+ virtual uint32_t getUnsettledAcks() = 0;
virtual Sender getSender(const std::string& name) const = 0;
virtual Receiver getReceiver(const std::string& name) const = 0;
virtual Connection getConnection() const = 0;
Modified: qpid/trunk/qpid/cpp/src/tests/MessagingSessionTests.cpp
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/cpp/src/tests/MessagingSessionTests.cpp?rev=932490&r1=932489&r2=932490&view=diff
==============================================================================
--- qpid/trunk/qpid/cpp/src/tests/MessagingSessionTests.cpp (original)
+++ qpid/trunk/qpid/cpp/src/tests/MessagingSessionTests.cpp Fri Apr 9 16:27:35 2010
@@ -491,7 +491,7 @@ QPID_AUTO_TEST_CASE(testAvailable)
}
qpid::sys::sleep(1);//is there any avoid an arbitrary sleep while waiting for messages to be dispatched?
for (uint i = 0; i < 5; ++i) {
- BOOST_CHECK_EQUAL(fix.session.getAvailable(), 15u - 2*i);
+ BOOST_CHECK_EQUAL(fix.session.getReceivable(), 15u - 2*i);
BOOST_CHECK_EQUAL(r1.getAvailable(), 10u - i);
BOOST_CHECK_EQUAL(r1.fetch().getContent(), (boost::format("A_%1%") % (i+1)).str());
BOOST_CHECK_EQUAL(r2.getAvailable(), 5u - i);
@@ -499,13 +499,13 @@ QPID_AUTO_TEST_CASE(testAvailable)
fix.session.acknowledge();
}
for (uint i = 5; i < 10; ++i) {
- BOOST_CHECK_EQUAL(fix.session.getAvailable(), 10u - i);
+ BOOST_CHECK_EQUAL(fix.session.getReceivable(), 10u - i);
BOOST_CHECK_EQUAL(r1.getAvailable(), 10u - i);
BOOST_CHECK_EQUAL(r1.fetch().getContent(), (boost::format("A_%1%") % (i+1)).str());
}
}
-QPID_AUTO_TEST_CASE(testPendingAck)
+QPID_AUTO_TEST_CASE(testUnsettledAcks)
{
QueueFixture fix;
Sender sender = fix.session.createSender(fix.queue);
@@ -516,14 +516,14 @@ QPID_AUTO_TEST_CASE(testPendingAck)
for (uint i = 0; i < 10; ++i) {
BOOST_CHECK_EQUAL(receiver.fetch().getContent(), (boost::format("Message_%1%") % (i+1)).str());
}
- BOOST_CHECK_EQUAL(fix.session.getPendingAck(), 0u);
+ BOOST_CHECK_EQUAL(fix.session.getUnsettledAcks(), 0u);
fix.session.acknowledge();
- BOOST_CHECK_EQUAL(fix.session.getPendingAck(), 10u);
+ BOOST_CHECK_EQUAL(fix.session.getUnsettledAcks(), 10u);
fix.session.sync();
- BOOST_CHECK_EQUAL(fix.session.getPendingAck(), 0u);
+ BOOST_CHECK_EQUAL(fix.session.getUnsettledAcks(), 0u);
}
-QPID_AUTO_TEST_CASE(testPendingSend)
+QPID_AUTO_TEST_CASE(testUnsettledSend)
{
QueueFixture fix;
Sender sender = fix.session.createSender(fix.queue);
@@ -532,9 +532,9 @@ QPID_AUTO_TEST_CASE(testPendingSend)
//implementation and the fact that the simple test case makes it
//possible to predict when completion information will be sent to
//the client. TODO: is there a better way of testing this?
- BOOST_CHECK_EQUAL(sender.getPending(), 10u);
+ BOOST_CHECK_EQUAL(sender.getUnsettled(), 10u);
fix.session.sync();
- BOOST_CHECK_EQUAL(sender.getPending(), 0u);
+ BOOST_CHECK_EQUAL(sender.getUnsettled(), 0u);
Receiver receiver = fix.session.createReceiver(fix.queue);
receive(receiver, 10);
---------------------------------------------------------------------
Apache Qpid - AMQP Messaging Implementation
Project: http://qpid.apache.org
Use/Interact: mailto:commits-subscribe@qpid.apache.org