Use libmq for interfacing with message brokers in the writer.
Update buffer to be an unsigned char *