Помогите с boost::asio::udp

#ifndef UDP_SERVER_H
#define UDP_SERVER_H
 
#define MAX_BUFFLEN 50
#define MAX_DEQUE_LEN 500
 
#include <ctime>
#include <iostream>
#include <string>
#include <queue>
#include "common.h"
 
 
using boost::asio::ip::udp;
using namespace std;
 
class udp_server {
 
public:
    /**
     * @brief Инициализирует udp сервер приема сообщений библиотеки boost и начает прием на порт заданный в одноименном параметре
     * @param io_service
     * @param port - номер порта
     */
    udp_server(boost::asio::io_service& io_service, uint32_t port);
    /**
     * @brief Отправляет сообщение клиенту
     * @param message_send - отправляемое сообщение типа boost::shared_ptr<std::string>
     */
    void udp_send(boost::shared_ptr<std::string> message_send);
    /**
     * @brief Возвращает код и параметр события из очереди
     * @return returnCondition - структура обьявленная в common.h
     */
    returnCondition getLastCode();
    
    virtual ~udp_server();
private:
    void start_receive();
    /**
     * @brief Обработчик окончания приема, принятое сообщение записывает в очередь
     * @param error
     * @param bytes_transferred
     */
    void handle_receive(const boost::system::error_code& error,
                            std::size_t /*bytes_transferred*/);
                            
    void handle_send(boost::shared_ptr<std::string> /*message*/,
                        const boost::system::error_code& /*error*/,
                        std::size_t /*bytes_transferred*/);
      
    udp::socket socket_;
    udp::endpoint remote_endpoint_;
    deque <string> recv_buffer_1;
    char recv_buf_[MAX_BUFFLEN];
    //boost::mutex eth_mutex;
 
};
 
#endif // UDP_SERVER_H

#include "udp_server.h"
 
udp_server::udp_server(boost::asio::io_service& io_service, uint32_t port)
    : socket_(io_service, udp::endpoint(udp::v4(), port))
{
    start_receive();
}
 
void udp_server::udp_send(boost::shared_ptr<std::string> message_send)
{
    socket_.async_send_to(boost::asio::buffer(*message_send), remote_endpoint_,
          boost::bind(&udp_server::handle_send, this, message_send,
          boost::asio::placeholders::error,
          boost::asio::placeholders::bytes_transferred));
          
}
 
returnCondition udp_server::getLastCode()
{
    
    returnCondition ret;
    
    ret.r_Code=recv_buffer_1.size();
    if(ret.r_Code!=0)
    {
        ret.r_param=recv_buffer_1.front();
        recv_buffer_1.pop_front();
        
    }
    else ret.r_param="";
    
    return ret;
}
 
void udp_server::start_receive()
{
    socket_.async_receive_from(
        boost::asio::buffer(recv_buf_), remote_endpoint_,
        boost::bind(&udp_server::handle_receive, this,
        boost::asio::placeholders::error,
        boost::asio::placeholders::bytes_transferred));
}
 
void udp_server::handle_receive(const boost::system::error_code& error,
      std::size_t bytes_transferred)
{
 
    if(recv_buffer_1.size()<MAX_DEQUE_LEN) // Проверяем что бы размер очереди не превышал опред. размера
    {
        if (!error || error == boost::asio::error::message_size)
        {
            recv_buffer_1.push_back(recv_buf_);
            //cout<<"added to deque"<<endl;
            start_receive();
        }
        else cout<<"Error boost::handle message from ARM"<<endl;
    }
    
}
 
void udp_server::handle_send(boost::shared_ptr<std::string> /*message*/,
      const boost::system::error_code& /*error*/,
      std::size_t /*bytes_transferred*/)
{
 
}
 
 
  
udp_server::~udp_server()
{
}

try
    {
        /*
         * Инициализация UDP сервера
         */
        // запускаем udp_server в отдельном потоке
        
            cout<<"Starting thread of udp_server...";
            boost::asio::io_service io_service;
            server=new udp_server(io_service, 3333); //! Прослушиваемый порт задается тут!!!
            boost::thread thread_ethernet ( boost::bind(&boost::asio::io_service::run, boost::ref(io_service)) );
            cout<<"done"<<endl;
        
    }
    catch (std::exception &e)
    {
        cout<<"Something's wrong happend while initin udp_server"<<e.what()<<endl;
    }

ret1=server->getLastCode();
        if(ret1.r_Code>=E_READY_CONDITION) //Потому что возвращает количество кодовых комбинаций в очереди
        {
            cout<<"Was accepted from ethernet code="<<ret1.r_param<<endl;