#include <ctime>
#include <iostream>
#include <sstream>
#include <boost/scoped_ptr.hpp>
#include <activemq/library/ActiveMQCPP.h>
#include <activemq/core/ActiveMQConnection.h>
#include <activemq/core/MessageDispatchChannel.h>
#include <activemq/core/ActiveMQConnectionFactory.h>
#include <activemq/core/ActiveMQSession.h>
#include <activemq/core/ActiveMQProducer.h>
#include <activemq/commands/ActiveMQQueue.h>
#include <activemq/commands/ActiveMQMessage.h>
#include <activemq/commands/ActiveMQTextMessage.h>
#include <activemq/commands/ActiveMQBytesMessage.h>
#include <activemq/core/PrefetchPolicy.h>
#include <activemq/core/RedeliveryPolicy.h>
#include <cms/InvalidSelectorException.h>
#include "AmqHelper.h"
#include "Base64.h"
#include "Collections.h"
#include "StringUtil.h"
#include <unistd.h>
Classes | |
class | ActiveMQCPPLibraryManager |
Macros | |
#define | NO_THROW(X) do { try { X; } catch ( ... ) {} } while (0); |
#define | TEST_SESSION do { if ( m_Session == NULL ) throw logic_error("NULL Session at " + string(__FILE__) + ":" + StringUtil::ToString(__LINE__)); } while (0); |
#define | MQRO_NONE 0 |
#define MQRO_NONE 0 |
#define NO_THROW | ( | X | ) | do { try { X; } catch ( ... ) {} } while (0); |
#define TEST_SESSION do { if ( m_Session == NULL ) throw logic_error("NULL Session at " + string(__FILE__) + ":" + StringUtil::ToString(__LINE__)); } while (0); |