amqp.hh

Go to the documentation of this file.

/*
 * amqp.hh
 *
 *  Created on: Jul 13, 2015
 *      Author: N.S. Oblath
 */

#ifndef DRIPLINE_AMQP_HH_
#define DRIPLINE_AMQP_HH_

#include "dripline_api.hh"

#include "param.hh"

#include "SimpleAmqpClient/SimpleAmqpClient.h"

#include "SimpleAmqpClient/AmqpException.h"
#include "SimpleAmqpClient/AmqpLibraryException.h"


namespace dripline
{
    // convenience typedefs
    typedef AmqpClient::Channel::ptr_t amqp_channel_ptr;
    typedef AmqpClient::Envelope::ptr_t amqp_envelope_ptr;
    typedef AmqpClient::BasicMessage::ptr_t amqp_message_ptr;

    typedef AmqpClient::AmqpException amqp_exception;
    typedef AmqpClient::AmqpLibraryException amqp_lib_exception;

    typedef std::vector< amqp_message_ptr > amqp_split_message_ptrs;

    // conversion functions
    DRIPLINE_API scarab::param_ptr_t table_to_param( const AmqpClient::Table& a_table );
    DRIPLINE_API scarab::param_ptr_t table_to_param( const AmqpClient::Array& a_array );
    DRIPLINE_API scarab::param_ptr_t table_to_param( const AmqpClient::TableValue& a_value );

    DRIPLINE_API AmqpClient::TableValue param_to_table( const scarab::param_node& a_node );
    DRIPLINE_API AmqpClient::TableValue param_to_table( const scarab::param_array& a_array );
    DRIPLINE_API AmqpClient::TableValue param_to_table( const scarab::param_value& a_value );
    DRIPLINE_API AmqpClient::TableValue param_to_table( const scarab::param& a_value );

} /* namespace dripline */

#endif /* DRIPLINE_AMPQ_HH_ */