#ifndef FAIRMQSOCKET_H_
#define FAIRMQSOCKET_H_

#include <nanomsg/nn.h>
#include <nanomsg/pipeline.h>
#include <nanomsg/pubsub.h>

#include "FairMQMessage.h"
#include "Rtypes.h"
#include "TString.h"

class FairMQSocket
{
  private:
    int fSocket;
    TString fId;
    ULong_t fBytesTx;
    ULong_t fBytesRx;
    ULong_t fMessagesTx;
    ULong_t fMessagesRx;
  public:
    FairMQSocket(int type, int num);
    virtual ~FairMQSocket();

    int GetSocket();
    TString GetId();
    static TString GetTypeString(int type);

    int Send(FairMQMessage* msg);
    int Receive(FairMQMessage* msg);
    int Bind(TString address);
    int Connect(TString address);

    void SetOption(int option, const void* value, size_t valueSize);

    void Close();

    ULong_t GetBytesTx();
    ULong_t GetBytesRx();
    ULong_t GetMessagesTx();
    ULong_t GetMessagesRx();
};

#endif /* FAIRMQSOCKET_H_ */