while(true){

        zmq::message_t id;


        int64_t more;


       // std::cout << "Received hello" << std::endl;
            int i = 0;
            int iid = -1;
            while (1) {
                //  Process all parts of the message

                if(i == 0){
                    subscriber.recv (&id);
                    iid = atoi((char *)id.data());
                    id.~message_t();
                }
                else{
                    zmq::message_t payload;
                    subscriber.recv (&payload);

                    size_t more_size = sizeof (more);
                    subscriber.getsockopt(ZMQ_RCVMORE, &more, &more_size);

                    std::cout << "Received Message,  to int: "<< iid << std::endl;
                    std::cout << "Received Message: "<< (char *)payload.data() << std::endl;

                    //backend.send(message, more? ZMQ_SNDMORE: 0);
                    payload.~message_t();

                    if (!more){
                        std::cout << "No more" << std::endl;
                        i = 0;
                        break;      //  Last message part
                    }
                }
                i++;
            }