Sender.h

//
// Copyright (c) 2006-2014 Raphael David / CANTOR
//

#ifndef CMR_SENDER_INCLUDED
#define CMR_SENDER_INCLUDED

#include "Commore.h"
#include "AutoRef.h"

namespace commore
{
    const int ERR_CONNECTION_CLOSED = -400;
    const int     ERR_NO_CONNECTION = -401;
    const int        ERR_BAD_FORMAT = -402;
    const int      ERR_COMM_TIMEOUT = -403;
}


namespace commore
{
    class CMREXD Sender : public RefObject
    {
    protected:
        AString address_;
    public:
        Sender();
        virtual ~Sender();

        const AString& get_address() const { return address_; }
        
    public:
        virtual bool is_ok();

        virtual bool is_connected();

        //PF 20081210 done in ProxyService
        //                            //
        //                            // Check the connection (force a dummy request)
        //                            //
        //        virtual        bool check_connection();


        virtual  int call(const Tuple& in_req, Tuple& out_req);

        virtual        void set_param(const Tuple& param);
        virtual              Tuple& get_param(Tuple& param);

    public:
        static const AChar* factory_name()
        {
            return "commore::Sender";
        }
    };
    typedef IAutoRef<Sender> PSender;
}

#endif