ZMQ: отправка пользовательского объекта CPP через очередь ZMQ

У меня есть класс с именем GenericMessage, показанный в 1-м фрагменте кода ниже (определен в GenericMessage.hxx).

У меня есть файл .cpp с именем TestFE.cpp (см. 2-й фрагмент кода ниже), который пытается отправить экземпляр класса GenericMessage через очередь ZMQ (см. Также 4-й фрагмент кода очень ниже — ZmqHandler.hxx). TesfFE.cpp реализует здесь паттерн ZMQ, включая ZmqHandler.hxx.

У меня есть еще один файл .cpp с именем TestBE.cpp (см. Третий фрагмент кода ниже), который получает упомянутый экземпляр GenericMessage через очередь ZMQ. TestBE.cpp реализует здесь шаблон извлечения ZMQ для извлечения экземпляра GenericMessage через очередь ZMQ.

В TestFE.cpp я использую стандартную функцию memcpy для преобразования объекта GenericMessage в форму, которая может быть принята в очереди ZMQ. В строке 21 файла TestBE.cpp (отмечен в третьем фрагменте кода в комментариях) я получаю сообщение об ошибке сегментации, поскольку похоже, что memcpy не работает должным образом на стороне отправителя, то есть TestFE.cpp. Я получил следующее сообщение, когда TestBE выполняется. Я также предоставляю трассировку GDB чуть ниже. Не могли бы вы сказать мне, что здесь не так? Как вы думаете, почему memcpy не может правильно скопировать мой объект GenericMessage в формат сообщения ZMQ? Или вы думаете, что проблема в другом? Любые замечания будут оценены.

СООБЩЕНИЕ ОБ ОШИБКЕ

  $ ./TestBE
Connecting to FE...
RECEIVED: 1
Segmentation fault (core dumped)

GDB Backtrace

  (gdb) r
Starting program: /home/holb/HOLB_DESIGN/ZMQ/WORK1/TestBE
[Thread debugging using libthread_db enabled]
Using host libthread_db library "/lib/i386-linux-gnu/libthread_db.so.1".
[New Thread 0xb7c84b40 (LWP 4252)]
[New Thread 0xb7483b40 (LWP 4253)]
Connecting to FE...
RECEIVED: 1

Program received signal SIGSEGV, Segmentation fault.
0xb7f371cc in std::basic_string<char, std::char_traits<char>, std::allocator<char>       >::basic_string(std::string const&) ()
from /usr/lib/i386-linux-gnu/libstdc++.so.6
(gdb) bt
#0  0xb7f371cc in std::basic_string<char, std::char_traits<char>,      std::allocator<char> >::basic_string(std::string const&) ()
from /usr/lib/i386-linux-gnu/libstdc++.so.6
#1  0x08049621 in GenericMessage<std::string>::getData (this=0xbffff06c)
at GenericMessage.hxx:18
#2  0x08049075 in main () at TestBE.cxx:21
(gdb)

КОД SNIPPET 1 (GenericMessage.hxx)
#включают
#включают
#включают

  template <class T>
class GenericMessage {
public:

GenericMessage(int id, T msg):
beId(id),
data(msg)
{}

~GenericMessage(){}

T getData()
{
//LINE 18 is the following line!
return data;
}

std::string toString()
{
std::ostringstream ss;
ss << getBeId();
std::string ret =  ss.str();

return ret;
}

void setBeId(int id)
{
beId = id;
}

int getBeId()
{
return beId;
}
private:
int beId;
T data;
};

КОД SNIPPET 2 (TestFE.cxx ==> Отправитель)
#include «ZmqHandler.hxx» // ПОСМОТРЕТЬ 4-й фрагмент внизу для содержимого ZmqHandler.hxx

 int main ()
{
ZmqHandler<std::string> zmqHandler;
int counter = 1;

while(1)
{
std::string data = "Hello there!\0";
GenericMessage<std::string> msg(counter, data);
zmqHandler.sendToBE(&msg);
counter++;
sleep(1);
}

return 0;
}

КОД SNIPPET 3 (TestBE.cxx ==> Получатель)

  #include "zmq.hpp"#include "GenericMessage.hxx"#include <string>
#include <iostream>

int main ()
{
//  Prepare our context and socket
zmq::context_t context (1);
zmq::socket_t socket (context, ZMQ_PULL);

std::cout << "Connecting to FE..." << std::endl;
socket.connect ("tcp://localhost:5555");

while(1){
zmq::message_t reply;
socket.recv (&reply);
GenericMessage<std::string> *msg = (GenericMessage<std::string>*)(reply.data());
std::cout << "RECEIVED: " << msg->toString() << std::endl;

/* *********************************  */
/*  SEGMENTATION FAULT HAPPENS HERE   */
/* The member "data" in class GenericMessage cannot be received while the  member "id" in the previous line can be received. */
std::cout << "DATA: " << ((std::string)msg->getData())  << std::endl;
/* ********************************** */
}

return 0;
}

КОД SNIPPET 4 (ZMQHandler.hxx)

  #include "zmq.hpp"#include "GenericMessage.hxx"#include <pthread.h>
#include <unistd.h>
#include <cassert>

template <class T>
class ZmqHandler {
public:
ZmqHandler():
mContext(1),
mOutbHandlerSocket(mContext, ZMQ_PUSH)
{
mOutbHandlerSocket.bind ("tcp://*:5555");
}

~ZmqHandler() {}

void *sendToBE(GenericMessage<T> *theMsg)
{
//  Place the new request to the zmq queue for BE consumption
zmq::message_t msgToSend(sizeof(*theMsg));

memcpy ( msgToSend.data(), ((GenericMessage<T>*)theMsg), sizeof(*  ((GenericMessage<T>*)theMsg)));

mOutbHandlerSocket.send(msgToSend);

std::cout << "SENT request: [" << theMsg->toString() << "]" << std::endl;

return (NULL);
}

private:
zmq::context_t mContext;
zmq::socket_t mOutbHandlerSocket;

};