broker.h

/* Copyright (c) 2014-2015, Human Brain Project
 *                          Stefan.Eilemann@epfl.ch
 */

#ifndef ZEROEQ_CONNECTION_BROKER_H
#define ZEROEQ_CONNECTION_BROKER_H

#include <zeroeq/receiver.h> // base class
#include <zeroeq/log.h>

namespace zeroeq
{
namespace connection
{
namespace detail { class Broker; }

class Broker : public Receiver
{
public:
    enum PortSelection
    {
        PORT_FIXED, 
        PORT_FIXED_OR_RANDOM 
    };

    ZEROEQ_API Broker( const std::string& name, Receiver& receiver,
                       const PortSelection mode );

    ZEROEQ_API Broker( const std::string& address, Receiver& receiver );

    ZEROEQ_API ~Broker();

    ZEROEQ_API std::string getAddress() const; 

private:
    detail::Broker* const _impl;

    // Receiver API
    void addSockets( std::vector< zeroeq::detail::Socket >& entries ) final;
    void process( zeroeq::detail::Socket& socket, uint32_t timeout ) final;
    void addConnection( const std::string& ) final { ZEROEQDONTCALL; } // LCOV_EXCL_LINE
};

}
}
#endif