The python portion of the shared memory provider

PythonModule.cpp

BOOST_PYTHON_MODULE(ScryUnlimitedCommunicator)
	{
		Py_Initialize();
		class_<SeralizedPythonSharedMemoryConsumer, boost::noncopyable>("SeralizedSharedMemoryConsumer",init<std::string>())
				.def("set_callable", &SeralizedPythonSharedMemoryConsumer::set_callable)
				.def("start",&SeralizedPythonSharedMemoryConsumer::start)
				.def("wait",&SeralizedPythonSharedMemoryConsumer::wait);

		class_<ImagePythonSharedMemoryConsumer, boost::noncopyable>("ImageSharedMemoryConsumer",init<std::string>())
				.def("set_callable", &ImagePythonSharedMemoryConsumer::set_callable)
				.def("start",&ImagePythonSharedMemoryConsumer::start)
				.def("wait",&ImagePythonSharedMemoryConsumer::wait);

		class_<SeralizedSharedMemoryProducer, boost::noncopyable>("SeralizedSharedMemoryProducer",init<std::string>())
				.def("write_data", &SeralizedSharedMemoryProducer::write_data);

		class_<ImageSharedMemoryProducer, boost::noncopyable>("ImageSharedMemoryProducer",init<std::string>())
				.def("write_data", &ImageSharedMemoryProducer::write_data);
	}

PythonSharedMemoryConsumer.hpp

template <size_t BufferSize>
	class PythonSharedMemoryConsumer
	{
	public:
		explicit PythonSharedMemoryConsumer(const std::string& memory_name)
				: sm_(memory_name) {}

		void set_callable(boost::python::object callback)
		{
			if (!PyCallable_Check(callback.ptr()))
			{
				PyErr_SetString(PyExc_TypeError, "Callback must be a callable object");
				boost::python::throw_error_already_set();
			}
			sm_.set_callable([=](const InterprocessMessage<BufferSize>& buffer)
							 {
								try
								{
									callback(boost::python::object(
											boost::python::handle<>(
													PyBytes_FromStringAndSize(buffer.message,buffer.message_length))));
								 //callback(buffer.to_string());
								 }
								catch (boost::python::error_already_set)
									{
										PyErr_Print();
									}
							 });
		}

		void start()
		{
			sm_.start();
		}

		void wait()
		{
			sm_.wait();
		}
	private:
		ScryUnlimited::SharedMemory::SharedMemoryConsumer<BufferSize> sm_;
	};