#include <activemq/io/InputStream.h>
#include <activemq/concurrent/Mutex.h>
#include <vector>
#include <algorithm>