#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); |