size_t amount_read = 0;
data my_data;
memcpy(buffer+amount_read, &my_data.speed, sizeof(my_data.speed))
amount_read += sizeof(my_data.speed)
memcpy(buffer+amount_read, &my_data.length, sizeof(my_data.length))
amount_read += sizeof(my_data.length)
[2019-01-18 09:56:37,443: WARNING/MainProcess] consumer: Connection to broker lost. Trying to re-establish the connection...
Как упоминалось в сообщении об ошибке, брокер не работает. Вам необходимо запустить Rabbitmq
перед установкой соединения с ним. Вот почему потребитель выбрасывает Connection to broker lost
, поскольку брокер не работает.