2 files changed, 3 insertions, 3 deletions
diff --git a/qpid/cpp/src/qpid/broker/amqp/Connection.cpp b/qpid/cpp/src/qpid/broker/amqp/Connection.cpp
index 34afc955f1..6754afc0d8 100644
--- a/qpid/cpp/src/qpid/broker/amqp/Connection.cpp
+++ b/qpid/cpp/src/qpid/broker/amqp/Connection.cpp
@@ -168,9 +168,9 @@ size_t Connection::encode(char* buffer, size_t size)
     }
 }
 
-void Connection::doOutput(ssize_t capacity)
+void Connection::doOutput(size_t capacity)
 {
-    for (ssize_t n = pn_transport_pending(transport); n > 0 && n < capacity; n = pn_transport_pending(transport)) {
+    for (ssize_t n = pn_transport_pending(transport); n > 0 && n < (ssize_t) capacity; n = pn_transport_pending(transport)) {
         if (dispatch()) processDeliveries();
         else break;
     }
diff --git a/qpid/cpp/src/qpid/broker/amqp/Connection.h b/qpid/cpp/src/qpid/broker/amqp/Connection.h
index 150df230d3..ed9a3a26b7 100644
--- a/qpid/cpp/src/qpid/broker/amqp/Connection.h
+++ b/qpid/cpp/src/qpid/broker/amqp/Connection.h
@@ -72,7 +72,7 @@ class Connection : public BrokerContext, public sys::ConnectionCodec, public Man
     bool closeRequested;
 
     virtual void process();
-    void doOutput(ssize_t);
+    void doOutput(size_t);
     bool dispatch();
     void processDeliveries();
     std::string getError();