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/log.h>
#include <zeroeq/receiver.h> // base class

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;
};
}
}
#endif