#include <queue>
#include <activemq/concurrent/Mutex.h>
#include <activemq/exceptions/ActiveMQException.h>