Forgot another small thing. I'm a dummy.

utils/messageqcpp/bytestream.h

@@ -381,6 +381,11 @@ public:
      */
     inline void rewind();
 
+    /**
+     * Get the allocated size of the buffer.
+     */
+    inline uint32_t getBufferSize() const;
+    
     /**
      * Serializeable interface
      */
@@ -390,7 +395,7 @@ public:
      * Serializeable interface
      */
     EXPORT void deserialize(ByteStream& bs);
-
+    
     /**
      *	memory allocation chunk size
      */
@@ -529,6 +534,11 @@ inline ByteStream& ByteStream::operator=(const SBS& rhs)
     return *this;
 }
 
+inline uint32_t ByteStream::getBufferSize() const
+{
+    return fMaxLen;
+}
+
 /**
  * stream a ByteStream out to any ostream
  */

utils/messageqcpp/bytestreampool.cpp

@@ -73,8 +73,10 @@ void ByteStreamPool::returnByteStream(ByteStream *bs)
         boost::mutex::scoped_lock s(mutex);
         if (freeByteStream.size() > maxFreeBuffers)
             delete bs;
-        else
+        else {
+            bs->restart();
             freeByteStreams.push_back(bs);
+        }
     }
 }